Struct GetHostProcStates 

pub struct GetHostProcStates {
    pub proc_mesh_id: ProcMeshId,
    pub region: Region,
    pub keepalive: Option<SystemTime>,
    pub reply: PortRef<ValueOverlay<State<ProcState>>>,
}

Query the state of a proc mesh’s procs, cast to the host agents backing that mesh. The caller casts ONE of these carrying the queried region (the mesh may be sliced, so the region need not be a dense 0..n). The cast reaches every routing host, but each rank’s proc lives on exactly one host, so each HostAgent that owns at least one selected proc reports those procs in a single batch. Hosts that own no selected procs do not reply.

The bound reply port is split by the cast tree, so replies reduce up the tree (to cast actor 0) instead of every host dialing the caller directly. One batched reply per owning host means the caller sees O(hosts) reply messages instead of O(procs).

GetState<ProcState> cannot be cast this way because it carries a fully-resolved id; this message resolves ids host-side instead.

If keepalive is Some, each proc’s expiry is extended (same orphan-protection semantics as KeepaliveGetState).

Fields

proc_mesh_id: ProcMeshId

region: Region

The (possibly sliced) region being queried. Each host keeps the procs it owns for this mesh whose global rank lies in the region, tested with Slice::contains (offset/stride-aware) — so a sliced or host-offset region resolves correctly without relying on the recipient’s stamped rank.

keepalive: Option<SystemTime>

reply: PortRef<ValueOverlay<State<ProcState>>>

Sparse overlay of the ranks this host owns for the mesh. The caller opens an accumulator port seeded with a full-region template, so per-host overlays reduce up the cast tree into the complete proc-state mesh (see ProcMeshRef::states).

Trait Implementations

impl Clone for GetHostProcStates

fn clone(&self) -> GetHostProcStates

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GetHostProcStates

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GetHostProcStates

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Handler<GetHostProcStates> for HostAgent

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: GetHostProcStates, ) -> 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 GetHostProcStates

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 GetHostProcStates

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Accepts<GetHostProcStates> for HostAgent

where GetHostProcStates: RemoteMessage,

impl RemoteHandles<GetHostProcStates> for HostAgent

where GetHostProcStates: RemoteMessage,