diff options
Diffstat (limited to 'device/device.go')
-rw-r--r-- | device/device.go | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/device/device.go b/device/device.go index 52b0143..b93ad22 100644 --- a/device/device.go +++ b/device/device.go @@ -133,67 +133,6 @@ func (device *Device) isUp() bool { return device.deviceState() == deviceStateUp } -// An outboundQueue is a channel of QueueOutboundElements awaiting encryption. -// An outboundQueue is ref-counted using its wg field. -// An outboundQueue created with newOutboundQueue has one reference. -// Every additional writer must call wg.Add(1). -// Every completed writer must call wg.Done(). -// When no further writers will be added, -// call wg.Done to remove the initial reference. -// When the refcount hits 0, the queue's channel is closed. -type outboundQueue struct { - c chan *QueueOutboundElement - wg sync.WaitGroup -} - -func newOutboundQueue() *outboundQueue { - q := &outboundQueue{ - c: make(chan *QueueOutboundElement, QueueOutboundSize), - } - q.wg.Add(1) - go func() { - q.wg.Wait() - close(q.c) - }() - return q -} - -// A inboundQueue is similar to an outboundQueue; see those docs. -type inboundQueue struct { - c chan *QueueInboundElement - wg sync.WaitGroup -} - -func newInboundQueue() *inboundQueue { - q := &inboundQueue{ - c: make(chan *QueueInboundElement, QueueInboundSize), - } - q.wg.Add(1) - go func() { - q.wg.Wait() - close(q.c) - }() - return q -} - -// A handshakeQueue is similar to an outboundQueue; see those docs. -type handshakeQueue struct { - c chan QueueHandshakeElement - wg sync.WaitGroup -} - -func newHandshakeQueue() *handshakeQueue { - q := &handshakeQueue{ - c: make(chan QueueHandshakeElement, QueueHandshakeSize), - } - q.wg.Add(1) - go func() { - q.wg.Wait() - close(q.c) - }() - return q -} - /* Converts the peer into a "zombie", which remains in the peer map, * but processes no packets and does not exists in the routing table. * |