30 lines
1.0 KiB
Diff
30 lines
1.0 KiB
Diff
From 99ca0fbb527b3c3137d8ea16aa82db009517adf0 Mon Sep 17 00:00:00 2001
|
|
From: zhangxiaoyu <zhangxiaoyu58@huawei.com>
|
|
Date: Tue, 1 Nov 2022 15:34:16 +0800
|
|
Subject: [PATCH] timeout wait backend to frontend complete
|
|
|
|
Signed-off-by: zhangxiaoyu <zhangxiaoyu58@huawei.com>
|
|
---
|
|
pkg/kubelet/cri/streaming/remotecommand/proxy.go | 5 +++++
|
|
1 file changed, 5 insertions(+)
|
|
|
|
diff --git a/pkg/kubelet/cri/streaming/remotecommand/proxy.go b/pkg/kubelet/cri/streaming/remotecommand/proxy.go
|
|
index f21629af..65860c87 100644
|
|
--- a/pkg/kubelet/cri/streaming/remotecommand/proxy.go
|
|
+++ b/pkg/kubelet/cri/streaming/remotecommand/proxy.go
|
|
@@ -129,6 +129,11 @@ func ProxyToWebSocket(w http.ResponseWriter, r *http.Request, url *url.URL, opts
|
|
case <-frontendResizeToBackendComplete:
|
|
}
|
|
|
|
+ select {
|
|
+ case <-backendToFrontendComplete:
|
|
+ case <-time.Tick(5 * time.Second):
|
|
+ }
|
|
+
|
|
if errConnection != nil {
|
|
klog.Errorf("SpdyProxy: the connection disconnected: %v", errConnection)
|
|
if exitErr, ok := errConnection.(exec.ExitError); ok && exitErr.Exited() {
|
|
--
|
|
2.25.1
|
|
|