Struct ZakuraBlockSyncConfig 

pub struct ZakuraBlockSyncConfig {

    pub max_blocks_per_response: u32,
    pub max_inflight_requests: u32,
    pub initial_inflight_requests: u32,
    pub max_response_bytes: u32,
    pub max_inflight_block_bytes: u64,
    pub max_reorder_lookahead_bytes: u64,
    pub floor_peer_avoid_cooldown: Duration,
    pub max_submitted_block_applies: usize,
    pub request_timeout: Duration,
    pub floor_rescue_timeout: Duration,
    pub no_progress_peer_cooldown: Duration,
    pub initial_block_probe_requests: u32,
    pub max_requests_without_block_progress: u32,
    pub status_refresh_interval: Duration,
    pub size_deviation_tolerance: u32,
    pub bbr_cwnd_gain_percent: u32,
    pub bbr_probe_bw_gain_percent: u32,
    pub bbr_probe_rtt_interval: Duration,
    pub bbr_probe_rtt_duration: Duration,
    pub bbr_rtprop_window: Duration,
    pub bbr_delivery_rate_window: Duration,
    pub bbr_startup_growth_percent: u32,
    pub bbr_min_cwnd: u32,
    pub bbr_min_cwnd_bytes: u64,
    pub bbr_delay_gradient_percent: u32,
    pub bbr_reliability_weight_percent: u32,
    pub bbr_cwnd_unit: CwndUnit,
    pub floor_bypass_slots: u32,
    pub peer_limits: ServicePeerLimits,
    /* private fields */
}

Block-sync configuration nested under the Zakura P2P-v2 config.

Fields

max_blocks_per_response: u32

Maximum blocks this node advertises per GetBlocks response.

max_inflight_requests: u32

Maximum concurrent GetBlocks requests this node advertises per peer.

initial_inflight_requests: u32

Initial per-peer BBR cwnd (cold-start point), in blocks; converges to the BDP-derived target once the first delivery is measured.

max_response_bytes: u32

Maximum total response bytes this node advertises per GetBlocks response.

max_inflight_block_bytes: u64

Maximum estimated bytes reserved for outstanding block-body requests: a DoS/pacing bound on in-flight wire data, released at receipt. Received bodies are bounded by max_reorder_lookahead_bytes instead.

max_reorder_lookahead_bytes: u64

Maximum estimated resident memory of look-ahead block bodies retained by the download pipeline. Serialized backlog and reservations are charged at wire size; decoded input/submission windows add DESERIALIZED_MEM_FACTOR times their wire size.

floor_peer_avoid_cooldown: Duration

How long to avoid reassigning an expired floor height to the same peer.

max_submitted_block_applies: usize

Depth for block-sync action/body channels, clamped to at least one full checkpoint range.

request_timeout: Duration

Timeout for an outstanding block-body range request.

floor_rescue_timeout: Duration

Short leash on a floor request before its height is rescued to a faster carrier. Clamped positive and never above request_timeout.

no_progress_peer_cooldown: Duration

How long to keep a peer disconnected after it makes no accepted block progress.

initial_block_probe_requests: u32

GetBlocks requests an unproven peer may receive before its first accepted body, so a peer that accepts requests but never serves bodies can’t spend a full BBR cold-start burst.

max_requests_without_block_progress: u32

After a peer has proven progress, the cap on requests without an accepted body; past it the peer gets no more work until it makes progress or the liveness deadline disconnects it.

status_refresh_interval: Duration

How often this node sends unsolicited status refreshes after local frontier changes.

size_deviation_tolerance: u32

Percentage deviation from advertised body-size hints tolerated before soft scoring.

bbr_cwnd_gain_percent: u32

Steady-state cwnd as a percent of the measured bandwidth-delay product.

bbr_probe_bw_gain_percent: u32

ProbeBW up-probe pacing gain, percent. Reserved: the ProbeBW gain cycle is not yet wired into the controller, so this knob is currently inert (the BtlBw max-filter already adopts higher delivery rates without an explicit up-probe).

bbr_probe_rtt_interval: Duration

How often to enter ProbeRTT to refresh the min-RTT estimate.

bbr_probe_rtt_duration: Duration

How long to hold the drained cwnd during ProbeRTT.

bbr_rtprop_window: Duration

Windowed-min horizon for the RTprop (min-RTT) estimate.

bbr_delivery_rate_window: Duration

Max-filter horizon for the delivery-rate (BtlBw) estimate.

bbr_startup_growth_percent: u32

Per-RTT Startup cwnd growth, percent. Reserved: there is no separate Startup ramp phase yet, so this knob is currently inert (cold start uses initial_inflight_requests and the BDP estimate takes over once samples arrive).

bbr_min_cwnd: u32

Minimum cwnd, in blocks (the floor under CwndUnit::Blocks).

bbr_min_cwnd_bytes: u64

Minimum cwnd, in bytes (the floor under CwndUnit::Bytes). Doubles as the cold-start byte window before the first delivery sample, and as the binding operating window for low-latency peers whose byte-BDP is below it.

bbr_delay_gradient_percent: u32

Delay-gradient down-adjust threshold, percent of RTprop.

bbr_reliability_weight_percent: u32

Weight (0..=100) with which measured reliability discounts the BDP-derived cwnd: 0 = plain BBR, 100 = full goodput discount, so a request-dropping carrier holds proportionally less in flight. See [DEFAULT_BS_BBR_RELIABILITY_WEIGHT_PERCENT].

bbr_cwnd_unit: CwndUnit

Unit the BBR cwnd budgets in-flight work against (bytes = header-hinted reserved body bytes, default; blocks = request count, the A/B baseline).

floor_bypass_slots: u32

Slots a floor (lowest-missing-height) request may borrow beyond the BBR cwnd, up to the peer’s advertised hard cap. Lets the floor be fetched even when every servable peer is saturated at its cwnd; 0 disables the bypass.

peer_limits: ServicePeerLimits

Block-sync peer caps and queue limits owned by this service.

Implementations

impl ZakuraBlockSyncConfig

pub fn advertised_max_blocks_per_response(&self) -> u32

Return the clamped block-count advertisement for wire status messages.

pub fn advertised_max_inflight_requests(&self) -> u32

Return the locally capped in-flight advertisement for status messages.

pub fn advertised_max_response_bytes(&self) -> u32

Return the non-zero response byte advertisement for status messages.

pub fn submitted_apply_limit(&self) -> usize

Return the non-zero block-sync action/body channel depth.

pub fn effective_max_reorder_lookahead_bytes(&self) -> u64

Return the resident look-ahead byte cap.

Currently the raw configured value; kept as an accessor for the semantic seam with the clamp interplay. The outstanding-request cap (max_inflight_block_bytes) no longer implies retention, so it must not silently shrink this memory budget.

pub fn effective_floor_peer_avoid_cooldown(&self) -> Duration

Return the floor avoid cooldown clamped to a positive duration.

pub fn floor_request_byte_reservation(&self) -> u64

Return the largest byte reservation a single floor request can need.

pub fn validate(&self) -> Result<(), &'static str>

Validate production-safety bounds after deserialization.

pub fn clamp_reorder_lookahead_to_floor(&mut self)

Clamp the resident look-ahead budget up to one worst-case checkpoint range of wire bytes.

This is defense-in-depth for the speculative above-window lane: checkpoint sync liveness already comes from the commit-window admission exemption, but a sub-range byte budget would reject nearly all gated look-ahead work. Serialized pools are charged at wire size, so the floor is the range’s wire bytes, not its decoded multiple: the bounded decode window’s cost is carried by the exempt lane, which bypasses this budget entirely.

pub fn clamp_inflight_block_bytes_to_request_floor(&mut self)

Clamp a positive but sub-floor-request max_inflight_block_bytes up to just above one floor request.

validate() requires the outstanding-request budget to cover at least one floor request (the bounded floor overdraft repays against it). Rather than refuse to start — which would break older configs written when the field also bounded retention and small values were clamped — raise the budget to the smallest valid value and warn.

pub fn initial_status(&self) -> BlockSyncStatus

Build the inert local status used before the block-sync reactor is wired.

Trait Implementations

impl Clone for ZakuraBlockSyncConfig

fn clone(&self) -> ZakuraBlockSyncConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ZakuraBlockSyncConfig

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

Formats the value using the given formatter.

impl Default for ZakuraBlockSyncConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ZakuraBlockSyncConfig

where ZakuraBlockSyncConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ZakuraBlockSyncConfig

impl PartialEq for ZakuraBlockSyncConfig

fn eq(&self, other: &ZakuraBlockSyncConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ZakuraBlockSyncConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ZakuraBlockSyncConfig