github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mzq-test

Browse Source
This commit is contained in:
maoziqiang 2025-07-24 19:50:01 +08:00
parent a168768fe0
commit 992c2d87c4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
View File

@ -219,6 +219,7 @@ func (conn *Conn) Open(w http.ResponseWriter, req *http.Request) (string, []io.R
serveHTTPComplete := make(chan struct{}) serveHTTPComplete := make(chan struct{})
// Ensure panic in spawned goroutine is propagated into the parent goroutine. // Ensure panic in spawned goroutine is propagated into the parent goroutine.
panicChan := make(chan any, 1) panicChan := make(chan any, 1)
klog.Infof("mzq-test, conn.go Open, req: %+v, req.Body: %+v, conn: %+v, timeout: %+v\n", req, req.Body, conn, conn.timeout.String())
go func() { go func() {
// If websocket server returns, propagate panic if necessary. Otherwise, // If websocket server returns, propagate panic if necessary. Otherwise,
// signal HTTPServe finished by closing "serveHTTPComplete". // signal HTTPServe finished by closing "serveHTTPComplete".
@ -336,7 +337,7 @@ func (conn *Conn) handle(ws *websocket.Conn) {
var data []byte var data []byte
if err := websocket.Message.Receive(ws, &data); err != nil { if err := websocket.Message.Receive(ws, &data); err != nil {
if err != io.EOF { if err != io.EOF {
klog.Errorf("Error on socket receive: %v", err) klog.Errorf("mzq-test, Error on socket receive: %v, ws: %+v, data: %v", err, ws, string(data))
} }
break break
} }