Enum RingKernelIntrinsic 

pub enum RingKernelIntrinsic {
    IsActive,
    ShouldTerminate,
    MarkTerminated,
    GetMessagesProcessed,
    InputQueueSize,
    OutputQueueSize,
    InputQueueEmpty,
    OutputQueueEmpty,
    EnqueueResponse,
    HlcTick,
    HlcUpdate,
    HlcNow,
    K2kSend,
    K2kTryRecv,
    K2kHasMessage,
    K2kPeek,
    K2kPendingCount,
    Nanosleep,
}

Ring kernel intrinsics for persistent actor kernels.

These intrinsics provide access to control block state, queue operations, and HLC (Hybrid Logical Clock) functionality within ring kernel handlers.

Variants

IsActive

Check if kernel is active: is_active()

ShouldTerminate

Check if termination requested: should_terminate()

MarkTerminated

Mark kernel as terminated: mark_terminated()

GetMessagesProcessed

Get messages processed count: messages_processed()

InputQueueSize

Get input queue size: input_queue_size()

OutputQueueSize

Get output queue size: output_queue_size()

InputQueueEmpty

Check if input queue empty: input_queue_empty()

OutputQueueEmpty

Check if output queue empty: output_queue_empty()

EnqueueResponse

Enqueue a response: enqueue_response(&response)

HlcTick

Increment HLC logical counter: hlc_tick()

HlcUpdate

Update HLC with received timestamp: hlc_update(received_ts)

HlcNow

Get current HLC timestamp: hlc_now()

K2kSend

Send message to another kernel: k2k_send(target_id, &msg)

K2kTryRecv

Try to receive K2K message: k2k_try_recv()

K2kHasMessage

Check for K2K messages: k2k_has_message()

K2kPeek

Peek at next K2K message without consuming: k2k_peek()

K2kPendingCount

Get number of pending K2K messages: k2k_pending_count()

Nanosleep

Sleep for nanoseconds: nanosleep(ns)

Implementations

impl RingKernelIntrinsic

pub fn to_cuda(&self, args: &[String]) -> String

Get the CUDA code for this intrinsic.

pub fn from_name(name: &str) -> Option<Self>

Parse a function name to get the intrinsic.

pub fn requires_control_block(&self) -> bool

Check if this intrinsic requires the control block.

pub fn requires_hlc(&self) -> bool

Check if this intrinsic requires HLC state.

pub fn requires_k2k(&self) -> bool

Check if this intrinsic requires K2K support.

Trait Implementations

impl Clone for RingKernelIntrinsic

fn clone(&self) -> RingKernelIntrinsic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RingKernelIntrinsic

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

Formats the value using the given formatter.

impl PartialEq for RingKernelIntrinsic

fn eq(&self, other: &RingKernelIntrinsic) -> 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 Copy for RingKernelIntrinsic

impl Eq for RingKernelIntrinsic

impl StructuralPartialEq for RingKernelIntrinsic