dope-manifold 0.36.0

Owned application and service composition for dope
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use o3::depot::{arena::slab::key, capacity};

use crate::service::pool::members::{Idle, Member, Unlinked};

pub(super) enum Unready<'a, 'h, I, A, const ROOT: bool> {
    Probing(Unlinked<'a, 'h, I, A, ROOT>),
    Exhausted(Unlinked<'a, 'h, I, A, ROOT>),
}

/// Owns the actual unscheduled resident admitted to its joint owner's retry heap.
pub(super) struct Backoff<'a, 'h, I, A, const ROOT: bool> {
    entry: Unlinked<'a, 'h, I, A, ROOT>,
}

impl<'a, 'h, I, A, const ROOT: bool> Backoff<'a, 'h, I, A, ROOT> {
    pub(super) fn try_new(
        entry: Unlinked<'a, 'h, I, A, ROOT>,
    ) -> Result<Self, Unready<'a, 'h, I, A, ROOT>> {
        match entry.get().health.idle {
            Idle::Backoff => Ok(Self { entry }),
            Idle::Probing => Err(Unready::Probing(entry)),
            Idle::Exhausted => Err(Unready::Exhausted(entry)),
        }
    }

    pub(super) fn key(&self) -> capacity::Key<'h, key::Handle<Member>> {
        self.entry.key()
    }

    pub(super) fn release(mut self) -> Unlinked<'a, 'h, I, A, ROOT> {
        self.entry.get_mut().health.idle = Idle::Exhausted;
        self.entry
    }
}