| commit | 257f319c3d631f1bbef389d787075a62294a746b | [log] [tgz] |
|---|---|---|
| author | khenaidoo <knursimu@ciena.com> | Wed Dec 15 16:46:37 2021 -0500 |
| committer | khenaidoo <knursimu@ciena.com> | Thu Feb 10 13:35:20 2022 -0500 |
| tree | b380b238e2fe3b258c5e37b67d1251982dda9c88 | |
| parent | 345a5b7b4ff891253e9de24bed776bb8abba1f18 [diff] [blame] |
[VOL-4442] grpc streaming connection monitoring Change-Id: Id787e94cf28745d36e72f8ed2f5c316312714db4
diff --git a/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go b/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go index f262edd..97198c5 100644 --- a/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go +++ b/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go
@@ -136,12 +136,10 @@ // newLimit updates the inflow window to a new value n. // It assumes that n is always greater than the old limit. -func (f *inFlow) newLimit(n uint32) uint32 { +func (f *inFlow) newLimit(n uint32) { f.mu.Lock() - d := n - f.limit f.limit = n f.mu.Unlock() - return d } func (f *inFlow) maybeAdjust(n uint32) uint32 {