diff options
| author |   Jason A. Donenfeld <Jason@zx2c4.com> | 2019-07-01 09:39:08 +0200 |
|---|---|---|
| committer | Jason A. Donenfeld <Jason@zx2c4.com> | 2019-07-01 09:39:08 +0200 |
| commit | 647d7b7157b6957b61ebe6be60f49828c025a4d7 (patch) | |
| tree | d7ddeb99b49f8b33b15946f106e274252e446c43 /device/receive.go | |
| parent | tun: windows: inform wintun of maximum buffer length for writes (diff) | |
| download | wireguard-go-647d7b7157b6957b61ebe6be60f49828c025a4d7.tar.xz wireguard-go-647d7b7157b6957b61ebe6be60f49828c025a4d7.zip | |
device: prepare for multiple send/receive
Diffstat (limited to 'device/receive.go')
| -rw-r--r-- | device/receive.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/device/receive.go b/device/receive.go index 62b5ef4..be0ee4e 100644 --- a/device/receive.go +++ b/device/receive.go @@ -485,7 +485,7 @@ func (device *Device) RoutineHandshake() { } } -func (peer *Peer) elementStopOrFlush(shouldFlush *bool) (stop bool, elemOk bool, elem *QueueInboundElement) { +func (peer *Peer) receiveElementStopOrFlush(shouldFlush *bool) (stop bool, elemOk bool, elem *QueueInboundElement) { if !*shouldFlush { select { case <-peer.routines.stop: @@ -505,9 +505,9 @@ func (peer *Peer) elementStopOrFlush(shouldFlush *bool) (stop bool, elemOk bool, *shouldFlush = false err := peer.device.tun.device.Flush() if err != nil { - peer.device.log.Error.Printf("Unable to flush packets: %v", err) + peer.device.log.Error.Printf("Unable to flush receive packets: %v", err) } - return peer.elementStopOrFlush(shouldFlush) + return peer.receiveElementStopOrFlush(shouldFlush) } } } @@ -549,7 +549,7 @@ func (peer *Peer) RoutineSequentialReceiver() { elem = nil } - stop, ok, elem = peer.elementStopOrFlush(&shouldFlush) + stop, ok, elem = peer.receiveElementStopOrFlush(&shouldFlush) if stop || !ok { return } |