kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #91566 from RainbowMango/pr_fix_invalid_recover_in_apiserver 

Fix a wrong usage of recover in apiserver

Kubernetes-commit: ae1103726f9aea1f9bbad1b215edfa47e0747dce
This commit is contained in:
Kubernetes Publisher 2020-05-29 11:56:39 -07:00
parent 88acf3194f efc2982011
commit 42642e7cb5
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/util/wsstream/stream.go
View File

@ -63,7 +63,7 @@ type Reader struct {
protocols map[string]ReaderProtocolConfig protocols map[string]ReaderProtocolConfig
selectedProtocol string selectedProtocol string
handleCrash func() // overridable for testing handleCrash func(additionalHandlers ...func(interface{})) // overridable for testing
} }
// NewReader creates a WebSocket pipe that will copy the contents of r to a provided // NewReader creates a WebSocket pipe that will copy the contents of r to a provided
@ -78,7 +78,7 @@ func NewReader(r io.Reader, ping bool, protocols map[string]ReaderProtocolConfig
err: make(chan error), err: make(chan error),
ping: ping, ping: ping,
protocols: protocols, protocols: protocols,
handleCrash: func() { runtime.HandleCrash() }, handleCrash: runtime.HandleCrash,
} }
} }

2
pkg/util/wsstream/stream_test.go
View File

@ -169,7 +169,7 @@ func TestStreamSurvivesPanic(t *testing.T) {
r := NewReader(errs, false, NewDefaultReaderProtocols()) r := NewReader(errs, false, NewDefaultReaderProtocols())
// do not call runtime.HandleCrash() in handler. Otherwise, the tests are interrupted. // do not call runtime.HandleCrash() in handler. Otherwise, the tests are interrupted.
r.handleCrash = func() { recover() } r.handleCrash = func(additionalHandlers ...func(interface{})) { recover() }
data, err := readWebSocket(r, t, nil) data, err := readWebSocket(r, t, nil)
if !reflect.DeepEqual(data, []byte(input)) { if !reflect.DeepEqual(data, []byte(input)) {