use crate::sync::{Arc, Mutex};
use crate::prelude::*;
+pub(super) const MAX_TIMER_TICKS: usize = 2;
+
/// A sender, receiver and forwarder of [`OnionMessage`]s.
///
/// # Handling Messages
L::Target: Logger,
MR::Target: MessageRouter,
OMH::Target: OffersMessageHandler,
- CMH:: Target: CustomOnionMessageHandler,
+ CMH::Target: CustomOnionMessageHandler,
{
entropy_source: ES,
node_signer: NS,
/// Messages for a node connected as a peer.
ConnectedPeer(VecDeque<OnionMessage>),
- /// Messages for a node that is not yet connected, which are dropped after a certain number of
- /// timer ticks defined in [`OnionMessenger::timer_tick_occurred`] and tracked here.
+ /// Messages for a node that is not yet connected, which are dropped after [`MAX_TIMER_TICKS`]
+ /// and tracked here.
PendingConnection(VecDeque<OnionMessage>, Option<Vec<SocketAddress>>, usize),
}
}
fn timer_tick_occurred(&self) {
- const MAX_TIMER_TICKS: usize = 2;
let mut message_buffers = self.message_buffers.lock().unwrap();
// Drop any pending recipients since the last call to avoid retaining buffered messages for