diff options
author | gVisor bot <gvisor-bot@google.com> | 2020-10-09 19:17:35 +0000 |
---|---|---|
committer | gVisor bot <gvisor-bot@google.com> | 2020-10-09 19:17:35 +0000 |
commit | 578aece760dd47a06a686f82efab5b650807d4c5 (patch) | |
tree | e57a1d077e19bf33dd2818e399557f7b359adbc5 /pkg/tcpip/stack/pending_packets.go | |
parent | 9774e9a0ca4110d88e5c4b4a59c188d5bedc0adc (diff) | |
parent | 257703c050e5901aeb3734f200f5a6b41856b4d9 (diff) |
Merge release-20200928.0-77-g257703c05 (automated)
Diffstat (limited to 'pkg/tcpip/stack/pending_packets.go')
-rw-r--r-- | pkg/tcpip/stack/pending_packets.go | 133 |
1 files changed, 133 insertions, 0 deletions
diff --git a/pkg/tcpip/stack/pending_packets.go b/pkg/tcpip/stack/pending_packets.go new file mode 100644 index 000000000..f838eda8d --- /dev/null +++ b/pkg/tcpip/stack/pending_packets.go @@ -0,0 +1,133 @@ +// Copyright 2020 The gVisor Authors. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package stack + +import ( + "fmt" + + "gvisor.dev/gvisor/pkg/sync" + "gvisor.dev/gvisor/pkg/tcpip" +) + +const ( + // maxPendingResolutions is the maximum number of pending link-address + // resolutions. + maxPendingResolutions = 64 + maxPendingPacketsPerResolution = 256 +) + +type pendingPacket struct { + route *Route + proto tcpip.NetworkProtocolNumber + pkt *PacketBuffer +} + +// packetsPendingLinkResolution is a queue of packets pending link resolution. +// +// Once link resolution completes successfully, the packets will be written. +type packetsPendingLinkResolution struct { + sync.Mutex + + // The packets to send once the resolver completes. + packets map[<-chan struct{}][]pendingPacket + + // FIFO of channels used to cancel the oldest goroutine waiting for + // link-address resolution. + cancelChans []chan struct{} +} + +func (f *packetsPendingLinkResolution) init() { + f.Lock() + defer f.Unlock() + f.packets = make(map[<-chan struct{}][]pendingPacket) +} + +func (f *packetsPendingLinkResolution) enqueue(ch <-chan struct{}, r *Route, proto tcpip.NetworkProtocolNumber, pkt *PacketBuffer) { + f.Lock() + defer f.Unlock() + + packets, ok := f.packets[ch] + if len(packets) == maxPendingPacketsPerResolution { + p := packets[0] + packets[0] = pendingPacket{} + packets = packets[1:] + p.route.Stats().IP.OutgoingPacketErrors.Increment() + p.route.Release() + } + + if l := len(packets); l >= maxPendingPacketsPerResolution { + panic(fmt.Sprintf("max pending packets for resolution reached; got %d packets, max = %d", l, maxPendingPacketsPerResolution)) + } + + f.packets[ch] = append(packets, pendingPacket{ + route: r, + proto: proto, + pkt: pkt, + }) + + if ok { + return + } + + // Wait for the link-address resolution to complete. + cancel := f.newCancelChannelLocked() + go func() { + cancelled := false + select { + case <-ch: + case <-cancel: + cancelled = true + } + + f.Lock() + packets, ok := f.packets[ch] + delete(f.packets, ch) + f.Unlock() + + if !ok { + panic(fmt.Sprintf("link-resolution goroutine woke up but no entry exists in the queue of packets")) + } + + for _, p := range packets { + if cancelled { + p.route.Stats().IP.OutgoingPacketErrors.Increment() + } else if _, err := p.route.Resolve(nil); err != nil { + p.route.Stats().IP.OutgoingPacketErrors.Increment() + } else { + p.route.nic.writePacket(p.route, nil /* gso */, p.proto, p.pkt) + } + p.route.Release() + } + }() +} + +// newCancelChannel creates a channel that can cancel a pending forwarding +// activity. The oldest channel is closed if the number of open channels would +// exceed maxPendingResolutions. +func (f *packetsPendingLinkResolution) newCancelChannelLocked() chan struct{} { + if len(f.cancelChans) == maxPendingResolutions { + ch := f.cancelChans[0] + f.cancelChans[0] = nil + f.cancelChans = f.cancelChans[1:] + close(ch) + } + if l := len(f.cancelChans); l >= maxPendingResolutions { + panic(fmt.Sprintf("max pending resolutions reached; got %d active resolutions, max = %d", l, maxPendingResolutions)) + } + + ch := make(chan struct{}) + f.cancelChans = append(f.cancelChans, ch) + return ch +} |