diff options
| author | gVisor bot <gvisor-bot@google.com> | 2021-04-20 16:38:23 +0000 |
|---|---|---|
| committer | gVisor bot <gvisor-bot@google.com> | 2021-04-20 16:38:23 +0000 |
| commit | 54422516dff22248de676ddca1fb4176e661491c (patch) | |
| tree | 50fe32b0a3c798ab186f9fab2afcf8e49af92e86 /pkg/tcpip/transport/tcp/rcv.go | |
| parent | 908e108fd49d40e9a90170156bf10a855b6414c4 (diff) | |
| parent | 3fff4c4a0fbb1b132348d4b82f61cc38a4cc6cb2 (diff) | |
Merge release-20210412.0-37-g3fff4c4a0 (automated)
Diffstat (limited to 'pkg/tcpip/transport/tcp/rcv.go')
| -rw-r--r-- | pkg/tcpip/transport/tcp/rcv.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/tcpip/transport/tcp/rcv.go b/pkg/tcpip/transport/tcp/rcv.go index fc11b4ba9..ee2c08cd6 100644 --- a/pkg/tcpip/transport/tcp/rcv.go +++ b/pkg/tcpip/transport/tcp/rcv.go @@ -466,7 +466,7 @@ func (r *receiver) handleRcvdSegment(s *segment) (drop bool, err tcpip.Error) { // segments. This ensures that we always leave some space for the inorder // segments to arrive allowing pending segments to be processed and // delivered to the user. - if r.ep.receiveBufferAvailable() > 0 && r.PendingBufUsed < r.ep.receiveBufferSize()>>2 { + if rcvBufSize := r.ep.ops.GetReceiveBufferSize(); rcvBufSize > 0 && r.PendingBufUsed < int(rcvBufSize)>>2 { r.ep.rcvQueueInfo.rcvQueueMu.Lock() r.PendingBufUsed += s.segMemSize() r.ep.rcvQueueInfo.rcvQueueMu.Unlock() |