diff options
| author |  Dominik Süß <dominik@suess.wtf> | 2025-02-06 12:14:37 +0100 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2025-02-06 12:14:37 +0100 |
| commit | dd094e401282e135989f57c0ca3dee7dea3f5207 (patch) | |
| tree | 74cb77830f621840273255a17565ced73b4fa997 /vendor/google.golang.org/grpc/internal/transport/flowcontrol.go | |
| parent | [feature] Use `X-Robots-Tag` headers to instruct scrapers/crawlers (#3737) (diff) | |
| download | gotosocial-dd094e401282e135989f57c0ca3dee7dea3f5207.tar.xz | |
[chore] update otel libraries (#3740)
* chore: update otel dependencies
* refactor: combine tracing & metrics in observability package
* chore: update example tracing compose file
Diffstat (limited to 'vendor/google.golang.org/grpc/internal/transport/flowcontrol.go')
| -rw-r--r-- | vendor/google.golang.org/grpc/internal/transport/flowcontrol.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go b/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go index 97198c515..dfc0f224e 100644 --- a/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go +++ b/vendor/google.golang.org/grpc/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 { |