Struct Stabilizer 

pub struct Stabilizer { /* private fields */ }

The stabilization runner.

Implementations

impl Stabilizer

pub async fn wait(self: Arc<Self>, interval: Duration)

Run topology stabilization and storage repair in staggered phases.

pub async fn wait_with(self: Arc<Self>, interval: Duration, stop: StopToken)

Run staggered maintenance until stop asks this loop to exit.

Repair requests are shared with disconnect handlers and survive missed phase deadlines. Cooperative stop is observed between phases; the per-step deadline may still cancel a hung network maintenance future.

impl Stabilizer

pub async fn repair_storage(&self) -> Result<StorageRepairOutcome>

Republish locally-held entries to their current affine owners.

impl Stabilizer

pub fn new(transport: Arc<SwarmTransport>) -> Self

Create a new stabilization runner.

pub async fn stabilize(&self) -> Result<()>

Run stabilization once.

pub async fn clean_unavailable_connections(&self) -> Result<()>

Clean unavailable connections in transport.

State relation:

• TopologyPeer(n, p) iff p appears in n’s successor list, predecessor slot, or finger table.
• Routable(n, p) iff p has an admitted local transport with a stable readiness observation in Ready = ({Connecting, Connected}, Open).
• Evictable(n, p) iff p has no admitted transport, has no raw connection object, is terminal, is Connected with a data channel that is not open, is the disconnected successor head while a live successor-tail or finger fallback exists, stayed disconnected past grace, left a liveness probe unanswered past its deadline, or reached the local failure-evidence limit, including an admitted connection explicitly terminalized after an irrevocable send or delivery failure.
• PrunableTopologyPeer(n, p) iff p is disconnected and appears only in non-head topology slots. These slots are hints, so they are removed from local DHT state immediately while the transport is allowed to recover until the disconnected grace elapses.

Post: after this step returns Ok, every observed local TopologyPeer(n, p) ∪ AdmittedPeer(n, p) that was Evictable(n, p) at snapshot time and still owns the same active transport evidence has been removed through PeerRing::remove, so successor, predecessor, and finger state are cleaned together. Evidence superseded by a newer connection is a successful no-op that preserves the replacement and its topology.

pub async fn notify_predecessor(&self) -> Result<()>

Notify predecessor, this is a DHT operation.

pub async fn correct_stabilize(&self) -> Result<()>

Call stabilization from correct chord implementation

Trait Implementations

impl Clone for Stabilizer

fn clone(&self) -> Stabilizer

Returns a duplicate of the value.

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

Performs copy-assignment from source.