Cleanup retrySendTimeout func creation (#1872)

wavetermdev · Jan 31, 2025 · a8dd0b7 · a8dd0b7
1 parent 5db84e5
commit a8dd0b7
Showing 1 changed file with 14 additions and 14 deletions.
diff --git a/pkg/wshutil/wshrpc.go b/pkg/wshutil/wshrpc.go
@@ -736,21 +736,21 @@ func (w *WshRpc) setServerDone() {
 }
 
 func (w *WshRpc) retrySendTimeout(resId string) {
+	done := func() bool {
+		w.Lock.Lock()
+		defer w.Lock.Unlock()
+		if w.ServerDone {
+			return true
+		}
+		select {
+		case w.CtxDoneCh <- resId:
+			return true
+		default:
+			return false
+		}
+	}
 	for {
-		done := func() bool {
-			w.Lock.Lock()
-			defer w.Lock.Unlock()
-			if w.ServerDone {
-				return true
-			}
-			select {
-			case w.CtxDoneCh <- resId:
-				return true
-			default:
-				return false
-			}
-		}()
-		if done {
+		if done() {
 			return
 		}
 		time.Sleep(100 * time.Millisecond)