Struct InFlight 

pub(crate) struct InFlight {
    calls: Option<Arc<Sender<Calls>>>,
    seq: u64,
    pending: Option<PendingPid>,
    stop: CancellationToken,
}

Counts a runtime call as in progress until dropped. A successful ChildReaper::create_child hands it to the caller, which passes it to ChildReaper::watch_grandchild, so the call ends with the registration of its child, or wherever the caller gives up.

Fields

calls: Option<Arc<Sender<Calls>>>

seq: u64

The number of the call, see Calls.

pending: Option<PendingPid>

Keeps the process which the call started pending until the call ends, also if the call gets dropped before its registration, see InFlight::claim.

stop: CancellationToken

Cancelled once the shutdown stops the call, see ChildReaper::stop_calls.

Implementations

impl InFlight

fn claim(&mut self, pending: &Arc<Mutex<HashMap<Pid, usize>>>, pid: Pid)

Mark the process pid which the call started as pending until the call ends, and record it for the shutdown, which kills it if the call does not end in time, see ChildReaper::kill_pending. It is pending before it gets recorded. A shutdown which did not see the record stopped the call before it looked at the calls, so the call sees that here and kills the process itself.

Trait Implementations

impl Debug for InFlight

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

Formats the value using the given formatter.

impl Drop for InFlight

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.