Struct InventoryRegistry

pub struct InventoryRegistry {
    current: IndexMap<InventoryHash, IndexMap<PeerSocketAddr, InventoryResponse<(), ()>>>,
    prev: IndexMap<InventoryHash, IndexMap<PeerSocketAddr, InventoryResponse<(), ()>>>,
    inv_stream: Pin<Box<dyn Stream<Item = Result<InventoryResponse<(AtLeastOne<InventoryHash>, PeerSocketAddr), (AtLeastOne<InventoryHash>, PeerSocketAddr)>, BroadcastStreamRecvError>> + Send + 'static>>,
    interval: IntervalStream,
}

An Inventory Registry for tracking recent inventory advertisements and missing inventory.

For more details please refer to the RFC.

Fields

current: IndexMap<InventoryHash, IndexMap<PeerSocketAddr, InventoryResponse<(), ()>>>

Map tracking the latest inventory status from the current interval period.

prev: IndexMap<InventoryHash, IndexMap<PeerSocketAddr, InventoryResponse<(), ()>>>

Map tracking inventory statuses from the previous interval period.

inv_stream: Pin<Box<dyn Stream<Item = Result<InventoryResponse<(AtLeastOne<InventoryHash>, PeerSocketAddr), (AtLeastOne<InventoryHash>, PeerSocketAddr)>, BroadcastStreamRecvError>> + Send + 'static>>

Stream of incoming inventory statuses to register.

interval: IntervalStream

Interval tracking when we should next rotate our maps.

Implementations

impl InventoryRegistry

pub fn new( inv_stream: Receiver<InventoryResponse<(AtLeastOne<InventoryHash>, PeerSocketAddr), (AtLeastOne<InventoryHash>, PeerSocketAddr)>>, ) -> Self

Returns a new Inventory Registry for inv_stream.

pub fn advertising_peers( &self, hash: InventoryHash, ) -> impl Iterator<Item = &PeerSocketAddr>

Returns an iterator over addrs of peers that have recently advertised hash in their inventory.

pub fn missing_peers( &self, hash: InventoryHash, ) -> impl Iterator<Item = &PeerSocketAddr>

Returns an iterator over addrs of peers that have recently missed hash in their inventory.

pub fn status_peers( &self, hash: InventoryHash, ) -> impl Iterator<Item = InventoryResponse<&PeerSocketAddr, &PeerSocketAddr>>

Returns an iterator over peer inventory statuses for hash.

Prefers current statuses to previously rotated statuses for the same peer.

pub fn has_current_status( &self, hash: InventoryHash, addr: PeerSocketAddr, ) -> bool

Returns true if there is a current status entry for hash and addr.

pub fn status_hashes( &self, ) -> impl Iterator<Item = (&InventoryHash, &IndexMap<PeerSocketAddr, InventoryResponse<(), ()>>)>

Returns an iterator over peer inventory status hashes.

Yields current statuses first, then previously rotated statuses. This can include multiple statuses for the same hash.

pub fn update(&mut self) -> Update<'_>

Returns a future that waits for new registry updates.

pub fn poll_inventory( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), BoxError>>

Drive periodic inventory tasks.

Rotates the inventory HashMaps on every timer tick. Drains the inv_stream channel and registers all advertised inventory.

Returns an error if the inventory channel is closed.

Otherwise, returns Ok if it performed at least one update or rotation, or Poll::Pending if there was no inventory change. Always registers a wakeup for the next inventory update or rotation, even when it returns Ok.

fn register( &mut self, change: InventoryResponse<(AtLeastOne<InventoryHash>, PeerSocketAddr), (AtLeastOne<InventoryHash>, PeerSocketAddr)>, )

Record the given inventory change for the peer addr.

Missing markers are not updated until the registry rotates, for security reasons.

fn rotate(&mut self)

Replace the prev HashMap with current’s and replace current with an empty HashMap

Trait Implementations

impl Debug for InventoryRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.