From f0ad46f89f8d152abdc9a078b9e32170b10b7750 Mon Sep 17 00:00:00 2001 From: lixiaobing1 Date: Wed, 15 Jul 2020 18:14:10 +0800 Subject: [PATCH] fix HandleCrash() order --- staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go b/staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go index 8271e9b707e..99f6770b919 100644 --- a/staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go +++ b/staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go @@ -97,9 +97,9 @@ func (sw *StreamWatcher) stopping() bool { // receive reads result from the decoder in a loop and sends down the result channel. func (sw *StreamWatcher) receive() { + defer utilruntime.HandleCrash() defer close(sw.result) defer sw.Stop() - defer utilruntime.HandleCrash() for { action, obj, err := sw.source.Decode() if err != nil {