Enum ProcState

pub enum ProcState {
    Created {
        proc_id: ProcId,
        point: Point,
        pid: u32,
    },
    Running {
        proc_id: ProcId,
        mesh_agent: ActorRef<MeshAgent>,
        addr: ChannelAddr,
    },
    Stopped {
        proc_id: ProcId,
        reason: ProcStopReason,
    },
    Failed {
        world_id: WorldId,
        description: String,
    },
}

A proc’s status. A proc can only monotonically move from Created to Running to Stopped.

Variants

Created

A proc was added to the alloc.

Fields

proc_id: ProcId

The proc’s id.

point: Point

Its assigned point (in the alloc’s extent).

pid: u32

The system process ID of the created child process.

Running

A proc was started.

Fields

proc_id: ProcId

mesh_agent: ActorRef<MeshAgent>

Reference to this proc’s mesh agent. In the future, we’ll reserve a ‘well known’ PID (0) for this purpose.

addr: ChannelAddr

The address of this proc. The endpoint of this address is the proc’s mailbox, which accepts hyperactor::mailbox::MessageEnvelopes.

Stopped

A proc was stopped.

Fields

proc_id: ProcId

reason: ProcStopReason

Failed

Allocation process encountered an irrecoverable error. Depending on the implementation, the allocation process may continue transiently and calls to next() may return some events. But eventually the allocation will not be complete. Callers can use the description to determine the reason for the failure. Allocation can then be cleaned up by calling stop()`` on the Alloc` and drain the iterator for clean shutdown.

Fields

world_id: WorldId

The world ID of the failed alloc.

description: String

A description of the failure.

Implementations

impl ProcState

pub fn is_created(&self) -> bool

Returns true if this is a ProcState::Created, otherwise false

pub fn as_created_mut(&mut self) -> Option<(&mut ProcId, &mut Point, &mut u32)>

Optionally returns mutable references to the inner fields if this is a ProcState::Created, otherwise None

pub fn as_created(&self) -> Option<(&ProcId, &Point, &u32)>

Optionally returns references to the inner fields if this is a ProcState::Created, otherwise None

pub fn into_created(self) -> Result<(ProcId, Point, u32), Self>

Returns the inner fields if this is a ProcState::Created, otherwise returns back the enum in the Err case of the result

pub fn is_running(&self) -> bool

Returns true if this is a ProcState::Running, otherwise false

pub fn as_running_mut( &mut self, ) -> Option<(&mut ProcId, &mut ActorRef<MeshAgent>, &mut ChannelAddr)>

Optionally returns mutable references to the inner fields if this is a ProcState::Running, otherwise None

pub fn as_running( &self, ) -> Option<(&ProcId, &ActorRef<MeshAgent>, &ChannelAddr)>

Optionally returns references to the inner fields if this is a ProcState::Running, otherwise None

pub fn into_running( self, ) -> Result<(ProcId, ActorRef<MeshAgent>, ChannelAddr), Self>

Returns the inner fields if this is a ProcState::Running, otherwise returns back the enum in the Err case of the result

pub fn is_stopped(&self) -> bool

Returns true if this is a ProcState::Stopped, otherwise false

pub fn as_stopped_mut(&mut self) -> Option<(&mut ProcId, &mut ProcStopReason)>

Optionally returns mutable references to the inner fields if this is a ProcState::Stopped, otherwise None

pub fn as_stopped(&self) -> Option<(&ProcId, &ProcStopReason)>

Optionally returns references to the inner fields if this is a ProcState::Stopped, otherwise None

pub fn into_stopped(self) -> Result<(ProcId, ProcStopReason), Self>

Returns the inner fields if this is a ProcState::Stopped, otherwise returns back the enum in the Err case of the result

pub fn is_failed(&self) -> bool

Returns true if this is a ProcState::Failed, otherwise false

pub fn as_failed_mut(&mut self) -> Option<(&mut WorldId, &mut String)>

Optionally returns mutable references to the inner fields if this is a ProcState::Failed, otherwise None

pub fn as_failed(&self) -> Option<(&WorldId, &String)>

Optionally returns references to the inner fields if this is a ProcState::Failed, otherwise None

pub fn into_failed(self) -> Result<(WorldId, String), Self>

Returns the inner fields if this is a ProcState::Failed, otherwise returns back the enum in the Err case of the result

Trait Implementations

impl Clone for ProcState

fn clone(&self) -> ProcState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ProcState

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

Formats the value using the given formatter.

impl PartialEq for ProcState

fn eq(&self, other: &ProcState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ProcState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ProcState