* Called when a new authenticated message has been received * * NOTE: Not thread safe, but called by sequential receiver! */
()
| 53 | * NOTE: Not thread safe, but called by sequential receiver! |
| 54 | */ |
| 55 | func (peer *Peer) keepKeyFreshReceiving() { |
| 56 | if peer.timers.sentLastMinuteHandshake.Load() { |
| 57 | return |
| 58 | } |
| 59 | keypair := peer.keypairs.Current() |
| 60 | if keypair != nil && keypair.isInitiator && time.Since(keypair.created) > (RejectAfterTime-KeepaliveTimeout-RekeyTimeout) { |
| 61 | peer.timers.sentLastMinuteHandshake.Store(true) |
| 62 | peer.SendHandshakeInitiation(false) |
| 63 | } |
| 64 | } |
| 65 | |
| 66 | /* Receives incoming datagrams for the device |
| 67 | * |
no test coverage detected