Struct LpdManager 

pub struct LpdManager {
    pub active_hashes: Arc<RwLock<HashSet<String>>>,
    /* private fields */
}

Manages LPD operations for all active torrents.

Maintains a registry of known peers discovered via LPD, handles periodic announcements for active downloads, and coordinates with the download engine.

Fields

active_hashes: Arc<RwLock<HashSet<String>>>

Track which info hashes we’re currently announcing

Implementations

impl LpdManager

pub fn new() -> Self

Create a new LpdManager

Initializes the UDP socket, joins multicast group, and sets up internal state tracking.

pub fn with_interval(announce_interval_secs: u64) -> Result<Self, String>

Create LpdManager with custom configuration

pub async fn register_torrent(&self, info_hash: &str) -> Result<(), String>

Register a torrent for LPD announcements

Adds the info_hash to the active set so it gets periodically announced.

pub async fn unregister_torrent(&self, info_hash: &str)

Unregister a torrent from LPD announcements

pub async fn announce_torrent( &self, info_hash: &str, port: u16, ) -> Result<(), String>

Manual announce for a specific torrent

pub async fn discover_peers( &self, _info_hash: &str, timeout_ms: Option<u64>, ) -> Vec<LpdPeer>

Discover peers for a specific info_hash via LPD

pub async fn get_peers_for(&self, info_hash: &str) -> Vec<LpdPeer>

Get all known peers for a given info_hash

pub fn start_background_announce(&mut self, port: u16) -> Option<JoinHandle<()>>

Start periodic background announce task

Spawns a Tokio task that announces all registered torrents every N seconds (default 5 min).

Arguments

• port - Our BT client listen port

Returns

JoinHandle that can be used to cancel the task

pub fn stop_background_announce(&mut self)

Stop background announce task

pub async fn update_peers(&self, info_hash: &str, new_peers: Vec<LpdPeer>)

Update peer registry with newly discovered peers

pub async fn cleanup_expired_peers(&self, max_age: Duration) -> usize

Clean up expired peers from all registries

pub fn is_available(&self) -> bool

Check if LPD is available and working

Trait Implementations

impl Default for LpdManager

fn default() -> Self

Returns the “default value” for a type.