peer.routines.starting.Done()
logDebug.Println(peer, "- Routine: nonce worker - started")
+NextPacket:
for {
- NextPacket:
peer.queue.packetInNonceQueueIsAwaitingKey.Set(false)
select {
case <-peer.signals.flushNonceQueue:
flush()
- goto NextPacket
+ continue NextPacket
case elem, ok := <-peer.queue.nonce:
device.PutMessageBuffer(elem.buffer)
device.PutOutboundElement(elem)
flush()
- goto NextPacket
+ continue NextPacket
case <-peer.routines.stop:
device.PutMessageBuffer(elem.buffer)
atomic.StoreUint64(&keypair.sendNonce, RejectAfterMessages)
device.PutMessageBuffer(elem.buffer)
device.PutOutboundElement(elem)
- goto NextPacket
+ continue NextPacket
}
elem.keypair = keypair