Struct Coroutine 

pub struct Coroutine<E = ()> {

    pub id: usize,
    pub program_id: usize,
    pub pc: PC,
    pub regs: RegFile,
    pub status: CoroStatus,
    pub effect_ctx: EffectCtx<E>,
    pub owned_endpoints: Vec<Endpoint>,
    pub progress_tokens: Vec<ProgressToken>,
    pub knowledge_set: KnowledgeSet,
    pub spec_state: Option<SpeculationState>,
    pub session_id: SessionId,
    pub role: String,
    pub cost_budget: usize,
}

A single coroutine executing a role’s local protocol.

Fields

id: usize

Unique coroutine identifier.

program_id: usize

Program table index for instruction fetch.

pc: PC

Program counter.

regs: RegFile

Register file.

status: CoroStatus

Execution status.

effect_ctx: EffectCtx<E>

Effect execution context.

owned_endpoints: Vec<Endpoint>

Endpoints owned by this coroutine.

progress_tokens: Vec<ProgressToken>

Progress tokens for scheduling.

knowledge_set: KnowledgeSet

Knowledge facts owned by this coroutine.

spec_state: Option<SpeculationState>

Speculation state, if any.

session_id: SessionId

Session this coroutine participates in.

role: String

Role name within the session.

cost_budget: usize

Remaining instruction budget for deterministic cost accounting.

Implementations

impl Coroutine

pub fn new( id: usize, program_id: usize, session_id: SessionId, role: String, num_regs: u16, cost_budget: usize, ) -> Self

Create a new coroutine.

pub fn is_ready(&self) -> bool

Whether this coroutine is ready to execute.

pub fn is_terminal(&self) -> bool

Whether this coroutine has finished (done or faulted).

Trait Implementations

impl<E: Clone> Clone for Coroutine<E>

fn clone(&self) -> Coroutine<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for Coroutine<E>

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

Formats the value using the given formatter.

impl<'de, E> Deserialize<'de> for Coroutine<E>

where E: Deserialize<'de> + Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<E> Serialize for Coroutine<E>

where E: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.