Skip to main content

replicate_fresh

Function replicate_fresh 

Source
pub async fn replicate_fresh(
    key: &XorName,
    data: &[u8],
    proof_of_payment: &[u8],
    p2p_node: &Arc<P2PNode>,
    paid_list: &Arc<PaidList>,
    config: &ReplicationConfig,
    send_semaphore: &Arc<Semaphore>,
)
Expand description

Execute fresh replication for a newly accepted record.

Sends fresh offers to close group members and PaidNotify to PaidCloseGroup. Both are fire-and-forget (no ack tracking or retry per Section 6.1, rule 8).

The send_semaphore limits how many outbound chunk transfers can be in-flight concurrently across the entire replication engine, preventing bandwidth saturation on home broadband connections.