transport: refactor trInFlow.onData to eliminate redundant logic (g…

…rpc#7734)
easwars · Oct 16, 2024 · ec10e73 · ec10e73
1 parent 6cd00c9
commit ec10e73
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/internal/transport/flowcontrol.go b/internal/transport/flowcontrol.go
@@ -92,14 +92,11 @@ func (f *trInFlow) newLimit(n uint32) uint32 {
 
 func (f *trInFlow) onData(n uint32) uint32 {
 	f.unacked += n
-	if f.unacked >= f.limit/4 {
-		w := f.unacked
-		f.unacked = 0
+	if f.unacked < f.limit/4 {
 		f.updateEffectiveWindowSize()
-		return w
+		return 0
 	}
-	f.updateEffectiveWindowSize()
-	return 0
+	return f.reset()
 }
 
 func (f *trInFlow) reset() uint32 {