Enum jormungandr::network::subscription::FragmentProcessorSendFragmentsState

enum FragmentProcessorSendFragmentsState {
    WaitingMessageBox,
    GetIngressAddress {
        fut: GetNodeAddress,
    },
    ReverseLookup {
        ingress_addr: SocketAddr,
        fut: Pin<Box<dyn Future<Output = Result<ReverseLookup, ResolveError>> + Send>>,
    },
    SendFragments {
        ingress_addr: SocketAddr,
        resolved_hostnames: Vec<String>,
    },
}

Possible states for FragmentProcessor::poll_send_fragments.

Variants

WaitingMessageBox

Wait for the message box to have capacity to send at least one fragment.

GetIngressAddress

Fields

fut: GetNodeAddress

Fetch the address of the inbound peer from which the FragmentProcessor is receiving fragments from.

ReverseLookup

Fields

ingress_addr: SocketAddr

fut: Pin<Box<dyn Future<Output = Result<ReverseLookup, ResolveError>> + Send>>

Executes a reverse DNS lookup query on the inbound peer address.

SendFragments

Fields

ingress_addr: SocketAddr

resolved_hostnames: Vec<String>

Checks the inbound peer address and (if resolved to any) resolved hostnames against the configured whitelist and sends fragments to the fragments task.

Trait Implementations

impl Display for FragmentProcessorSendFragmentsState

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

Formats the value using the given formatter.