Struct Downloads 

pub struct Downloads<ZN, ZV, ZS, ZSTip>
where
    ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static,
    ZN::Future: Send,
    ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static,
    ZV::Future: Send,
    ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static,
    ZS::Future: Send,
    ZSTip: ChainTip + Clone + Send + 'static,
{
    full_verify_concurrency_limit: usize,
    network: ZN,
    verifier: ZV,
    state: ZS,
    latest_chain_tip: ZSTip,
    pending: FuturesUnordered<JoinHandle<Result<Hash, (Box<dyn Error + Send + Sync + 'static>, Hash, Option<PeerSocketAddr>)>>>,
    cancel_handles: HashMap<Hash, (Sender<()>, Option<IpAddr>)>,
    in_flight_ips: HashSet<IpAddr>,
}

Manages download and verification of blocks gossiped to this peer.

Fields

full_verify_concurrency_limit: usize

The configured full verification concurrency limit, after applying the minimum limit.

network: ZN

A service that forwards requests to connected peers, and returns their responses.

verifier: ZV

A service that verifies downloaded blocks.

state: ZS

A service that manages cached blockchain state.

latest_chain_tip: ZSTip

Allows efficient access to the best tip of the blockchain.

pending: FuturesUnordered<JoinHandle<Result<Hash, (Box<dyn Error + Send + Sync + 'static>, Hash, Option<PeerSocketAddr>)>>>

A list of pending block download and verify tasks.

cancel_handles: HashMap<Hash, (Sender<()>, Option<IpAddr>)>

Cancellation handles for tasks in Self::pending, keyed by block hash. The Option<IpAddr> is the advertiser IP recorded in Self::in_flight_ips, so completion can remove it by hash lookup.

in_flight_ips: HashSet<IpAddr>

Advertiser IPs with an in-flight download and verify task.

Invariant: an IP is present iff some entry in Self::cancel_handles has value (_, Some(ip)). Enforces the one-download-per-IP cap.

Size-bounded by full_verify_concurrency_limit (≤ MAX_INBOUND_CONCURRENCY), inherited from the DownloadAction::FullQueue check on Self::pending.

Implementations

impl<ZN, ZV, ZS, ZSTip> Downloads<ZN, ZV, ZS, ZSTip>

where ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZN::Future: Send, ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZV::Future: Send, ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZS::Future: Send, ZSTip: ChainTip + Clone + Send + 'static,

pub(crate) fn project<'pin>( self: Pin<&'pin mut Self>, ) -> __DownloadsProjection<'pin, ZN, ZV, ZS, ZSTip>

pub(crate) fn project_ref<'pin>( self: Pin<&'pin Self>, ) -> __DownloadsProjectionRef<'pin, ZN, ZV, ZS, ZSTip>

impl<ZN, ZV, ZS, ZSTip> Downloads<ZN, ZV, ZS, ZSTip>

where ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZN::Future: Send, ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZV::Future: Send, ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZS::Future: Send, ZSTip: ChainTip + Clone + Send + 'static,

pub fn new( full_verify_concurrency_limit: usize, network: ZN, verifier: ZV, state: ZS, latest_chain_tip: ZSTip, ) -> Self

Initialize a new download stream with the provided network, verifier, and state services. The latest_chain_tip must be linked to the provided state service.

The download deadline covers network readiness and the response. Any retry policy should be applied to network without a separate timeout that includes queued requests.

pub fn download_and_verify( &mut self, hash: Hash, advertiser: Option<PeerSocketAddr>, ) -> DownloadAction

Queue a block for download and verification.

When advertiser is Some, it is passed to the network as a known block source, and its IP is tracked in Self::in_flight_ips to enforce the one-download-per-IP cap. None bypasses per-IP accounting (for example when Zebra triggers the download internally).

Trait Implementations

impl<ZN, ZV, ZS, ZSTip> Debug for Downloads<ZN, ZV, ZS, ZSTip>

where ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static + Debug, ZN::Future: Send, ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static + Debug, ZV::Future: Send, ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static + Debug, ZS::Future: Send, ZSTip: ChainTip + Clone + Send + 'static + Debug,

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

Formats the value using the given formatter.

impl<ZN, ZV, ZS, ZSTip> Stream for Downloads<ZN, ZV, ZS, ZSTip>

where ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZN::Future: Send, ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZV::Future: Send, ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZS::Future: Send, ZSTip: ChainTip + Clone + Send + 'static,

type Item = Result<Hash, (Box<dyn Error + Send + Sync>, Option<PeerSocketAddr>)>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'pin, ZN, ZV, ZS, ZSTip> Unpin for Downloads<ZN, ZV, ZS, ZSTip>

where ZN: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZN::Future: Send, ZV: Service<Request, Response = Hash, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZV::Future: Send, ZS: Service<Request, Response = Response, Error = Box<dyn Error + Send + Sync + 'static>> + Send + Clone + 'static, ZS::Future: Send, ZSTip: ChainTip + Clone + Send + 'static, PinnedFieldsOf<__Downloads<'pin, ZN, ZV, ZS, ZSTip>>: Unpin,

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.