add WindowUpdate Frame log

cloudwego · Oct 16, 2024 · 8df99f1 · 8df99f1
1 parent 4c90600
commit 8df99f1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pkg/remote/trans/nphttp2/grpc/controlbuf.go b/pkg/remote/trans/nphttp2/grpc/controlbuf.go
@@ -572,6 +572,7 @@ func (l *loopyWriter) outgoingWindowUpdateHandler(w *outgoingWindowUpdate) error
 func (l *loopyWriter) incomingWindowUpdateHandler(w *incomingWindowUpdate) error {
 	// Otherwise update the quota.
 	if w.streamID == 0 {
+		klog.Infof("Recv WindowUpdate Frame, increment: %d", w.increment)
 		l.sendQuota += w.increment
 		return nil
 	}

diff --git a/pkg/remote/trans/nphttp2/grpc/flowcontrol.go b/pkg/remote/trans/nphttp2/grpc/flowcontrol.go
@@ -137,10 +137,10 @@ func (w *ctxWriteQuota) realReplenish(n int) bool {
 			}
 		} else {
 			klog.CtxInfof(w.ctx, "replenish quota failed, curQuota: %d, oriQuota: %d", a, b)
-			return false
+			return true
 		}
 	}
-	return true
+	return false
 }
 
 type trInFlow struct {