From 8df99f175dfb4fc1b2f80d3cc38364598a2f1990 Mon Sep 17 00:00:00 2001
From: "yuxuan.wang1" <yuxuan.wang1@bytedance.com>
Date: Wed, 16 Oct 2024 11:23:06 +0800
Subject: [PATCH] add WindowUpdate Frame log

---
 pkg/remote/trans/nphttp2/grpc/controlbuf.go  | 1 +
 pkg/remote/trans/nphttp2/grpc/flowcontrol.go | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/remote/trans/nphttp2/grpc/controlbuf.go b/pkg/remote/trans/nphttp2/grpc/controlbuf.go
index 20996c0935..282d481c68 100644
--- 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
index ec98206cb8..ea361d80d2 100644
--- 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 {