Struct RefreshService 

pub struct RefreshService {
    table: Arc<RoutingTable>,
    listen_endpoint: Option<Endpoint>,
    task_group: TaskGroup,
    config: Arc<Config>,
    monitor: Arc<Monitor>,
}

Fields

table: Arc<RoutingTable>

Routing table

listen_endpoint: Option<Endpoint>

UDP listen endpoint (None when no udp discovery endpoint is configured).

task_group: TaskGroup

Managing spawned tasks.

config: Arc<Config>

Holds the configuration for the P2P network.

monitor: Arc<Monitor>

Responsible for network and system monitoring.

Implementations

impl RefreshService

pub fn new( config: Arc<Config>, table: Arc<RoutingTable>, monitor: Arc<Monitor>, listen_endpoint: Option<Endpoint>, executor: Executor, ) -> Self

Creates a new refresh service

pub async fn start(self: &Arc<Self>) -> Result<()>

Start the refresh service

pub async fn shutdown(&self)

Shuts down the refresh service

async fn refresh_loop(self: Arc<Self>) -> Result<()>

Periodically refresh the routing table by pinging the oldest entries.

async fn do_refresh(self: Arc<Self>, entries: &[BucketEntry]) -> usize

Iterates over the entries and initiates a connection. Returns the number of entries refreshed successfully.

async fn refresh_entry(self: Arc<Self>, bucket_entry: BucketEntry) -> bool

Refresh a specific entry by pinging it over UDP. Returns true if the ping succeeded.

async fn connect(&self, entry: &Entry) -> Result<()>

Send a ping over UDP with retries.

async fn listen_loop(self: Arc<Self>, endpoint: Endpoint) -> Result<()>

Listen on UDP for Ping messages.

async fn listen_to_ping_msg( &self, conn: &UdpConn, rate_limiter: &mut HashMap<IpAddr, RateBucket>, ) -> Result<()>

Listen for a Ping message and respond with a Pong message. Drops pings from sources not in the routing table or that exceed the per-IP rate limit.

async fn send_ping_msg( &self, conn: &UdpConn, peer_addr: SocketAddr, ) -> Result<()>

Sends a Ping msg and waits for the Pong response.