diff options
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 } |