Struct ShutdownHost 

pub struct ShutdownHost {
    pub timeout: Duration,
    pub max_in_flight: usize,
    pub rank: Rank,
    pub ack: PortRef<usize>,
}

Fields

timeout: Duration

Grace window: send SIGTERM and wait this long before escalating.

max_in_flight: usize

Max number of children to terminate concurrently on this host.

rank: Rank

This host’s ordinal within the shutdown cast region, stamped by the cast layer. The host echoes it back via ack so the caller can tell exactly which hosts acknowledged shutdown.

ack: PortRef<usize>

Direct reply carrying this host’s rank once shutdown work is done.

Intentionally must NOT be split/tree-reduced: ShutdownHost makes each host exit right after acking, so a tree-reduced ack would stall — the node that fans in peers’ acks tears down before they arrive. Replying directly to the caller survives the responders exiting. The caller binds this port .unsplit() so the cast layer leaves it alone, and collects one direct reply per host (see HostMeshRef::cast_shutdown).

Trait Implementations

impl Clone for ShutdownHost

fn clone(&self) -> ShutdownHost

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShutdownHost

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ShutdownHost

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Handler<ShutdownHost> for HostAgent

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, msg: ShutdownHost, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle the next M-typed message.

impl Named for ShutdownHost

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

A globally unique numeric identifier for this type.

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl Serialize for ShutdownHost

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Accepts<ShutdownHost> for HostAgent

where ShutdownHost: RemoteMessage,

impl RemoteHandles<ShutdownHost> for HostAgent

where ShutdownHost: RemoteMessage,