diff options
| -rw-r--r-- | receive.go | 6 | ||||
| -rw-r--r-- | send.go | 6 |
2 files changed, 6 insertions, 6 deletions
@@ -238,8 +238,8 @@ func (device *Device) RoutineDecryption() { logDebug := device.log.Debug defer func() { - device.state.stopping.Done() logDebug.Println("Routine: decryption worker - stopped") + device.state.stopping.Done() }() logDebug.Println("Routine: decryption worker - started") @@ -304,8 +304,8 @@ func (device *Device) RoutineHandshake() { logDebug := device.log.Debug defer func() { - device.state.stopping.Done() logDebug.Println("Routine: handshake worker - stopped") + device.state.stopping.Done() }() logDebug.Println("Routine: handshake worker - started") @@ -534,8 +534,8 @@ func (peer *Peer) RoutineSequentialReceiver() { logDebug := device.log.Debug defer func() { - peer.routines.stopping.Done() logDebug.Println(peer, ": Routine: sequential receiver - stopped") + peer.routines.stopping.Done() }() logDebug.Println(peer, ": Routine: sequential receiver - started") @@ -200,8 +200,8 @@ func (peer *Peer) RoutineNonce() { logDebug := device.log.Debug defer func() { - peer.routines.stopping.Done() logDebug.Println(peer, ": Routine: nonce worker - stopped") + peer.routines.stopping.Done() }() peer.routines.starting.Done() @@ -274,8 +274,8 @@ func (device *Device) RoutineEncryption() { logDebug := device.log.Debug defer func() { - device.state.stopping.Done() logDebug.Println("Routine: encryption worker - stopped") + device.state.stopping.Done() }() logDebug.Println("Routine: encryption worker - started") @@ -348,8 +348,8 @@ func (peer *Peer) RoutineSequentialSender() { logDebug := device.log.Debug defer func() { - peer.routines.stopping.Done() logDebug.Println(peer, ": Routine: sequential sender - stopped") + peer.routines.stopping.Done() }() logDebug.Println(peer, ": Routine: sequential sender - started") |