Module resident_work_queue 

Resident work-queue protocols, scheduling policy, and runtime IO. Resident work-queue protocol, host mirrors, scheduling policy, and IO.

Artifact compilation and target selection live in vyre-megakernel. Authenticated execution and recovery live in crate::ArtifactSession. This module owns only mutable queue policy and wire state.

Re-exports

pub use automata_worklist::AutomataStateIndex;

pub use automata_worklist::AutomataWorklistEvidence;

pub use automata_worklist::AutomataWorklistMode;

pub use automata_worklist::AutomataWorklistPolicy;

pub use automata_worklist::AutomataWorklistRecommendation;

pub use automata_worklist::AutomataWorklistRequest;

pub use automata_worklist::AUTOMATA_WORKLIST_EVIDENCE_SCHEMA_VERSION;

pub use builder::build_program;

pub use builder::build_program_jit;

pub use builder::build_program_jit_slots;

pub use builder::build_program_priority;

pub use builder::build_program_priority_slots;

pub use builder::build_program_sharded;

pub use builder::build_program_sharded_no_io;

pub use builder::build_program_sharded_once_slots;

pub use builder::build_program_sharded_once_slots_control_report_shared;

pub use builder::build_program_sharded_once_slots_shared;

pub use builder::build_program_sharded_slots;

pub use builder::build_program_sharded_slots_shared;

pub use builder::build_program_sharded_with_io_polling;

pub use builder::build_program_sharded_with_workspace_adapter;

pub use builder::persistent_body;

pub use builder::persistent_body_jit;

pub use builder::persistent_body_priority;

pub use builder::persistent_body_priority_slots;

pub use builder::try_build_program_with_self_loading_miss_handler;

pub use descriptor::BatchDescriptor;

pub use descriptor::BuiltinOpcode;

pub use descriptor::PackedOpDescriptor;

pub use descriptor::SlotDescriptor;

pub use descriptor::SlotOpcode;

pub use descriptor::WindowClass;

pub use descriptor::WindowDescriptor;

pub use handlers::OpcodeHandler;

pub use io::IoCompletion;

pub use io::IoRequest;

pub use io::ResidentIoQueue;

pub use io::IO_SLOT_COUNT;

pub use io::IO_SLOT_WORDS;

pub use mixed_work::mixed_work_protocol_evidence;

pub use mixed_work::validate_mixed_work_protocol;

pub use mixed_work::MixedWorkProtocolError;

pub use mixed_work::MixedWorkProtocolEvidence;

pub use mixed_work::MixedWorkProtocolPlan;

pub use mixed_work::MixedWorkQueueClass;

pub use mixed_work::MixedWorkUnit;

pub use mixed_work::MixedWorkUnitType;

pub use mixed_work::OutputSlabId;

pub use mixed_work::ResidentArtifactId;

pub use mixed_work::MIXED_WORK_PROTOCOL_SCHEMA_VERSION;

pub use planner::build_bellman_tn_order_program;

pub use planner::build_kfac_autotune_step_program;

pub use planner::build_persistent_fixpoint_program;

pub use planner::build_scallop_provenance_wide_program;

pub use planner::build_sinkhorn_clustering_program;

pub use planner::build_sinkhorn_full_clustering_program;

pub use planner::dispatch_grid_for;

pub use planner::padded_slot_count;

pub use planner::worker_workgroup_size;

pub use planner::ResidentGridLimits;

pub use planner::ResidentGridPlan;

pub use planner::ResidentGridRequest;

pub use planner::ResidentLaunchGeometry;

pub use planner::ResidentQueueCapabilities;

pub use planner::ResidentQueueConfig;

pub use planner::ResidentQueueReport;

pub use planner::ResidentQueueTelemetry;

pub use planner::ResidentSizingPolicy;

pub use planner::ResidentWorkItem;

pub use planner::ResidentWorkloadHints;

pub use policy::try_diffuse_priority_across_siblings;

pub use policy::try_diffuse_priority_across_siblings_into;

pub use policy::PriorityDrainReason;

pub use policy::PriorityDrainRecommendation;

pub use policy::PriorityRequeueAccounting;

pub use policy::ResidentExecutionMode;

pub use policy::ResidentGraphBlasSwitchClass;

pub use policy::ResidentLaunchCacheStats;

pub use policy::ResidentLaunchPolicy;

pub use policy::ResidentLaunchRecommendation;

pub use policy::ResidentLaunchRequest;

pub use policy::ResidentPromotionEvidence;

pub use policy::ResidentPromotionRoute;

pub use policy::ResidentQueuePressure;

pub use policy::ResidentQueueTopology;

pub use policy::ResidentTopologyEvidence;

pub use policy::HOT_WINDOW_PROMOTION_EVIDENCE_SCHEMA_VERSION;

pub use policy::PRIORITY_COUNTER_DRAIN_FIX;

pub use policy::PRIORITY_COUNTER_DRAIN_HEADROOM;

pub use policy::TOPOLOGY_EVIDENCE_SCHEMA_VERSION;

pub use protocol::control;

pub use protocol::control_byte_len;

pub use protocol::count_done_ring_slots;

pub use protocol::debug;

pub use protocol::debug_log_byte_len;

pub use protocol::encode_control;

pub use protocol::encode_empty_debug_log;

pub use protocol::encode_empty_ring;

pub use protocol::opcode;

pub use protocol::read_debug_log;

pub use protocol::read_done_count;

pub use protocol::read_epoch;

pub use protocol::read_metrics;

pub use protocol::read_observable;

pub use protocol::ring_byte_len;

pub use protocol::slot;

pub use protocol::try_count_done_ring_slots;

pub use protocol::try_encode_control;

pub use protocol::try_encode_control_into;

pub use protocol::try_encode_empty_debug_log;

pub use protocol::try_encode_empty_debug_log_into;

pub use protocol::try_encode_empty_ring;

pub use protocol::try_encode_empty_ring_into;

pub use protocol::try_read_debug_log;

pub use protocol::try_read_done_count;

pub use protocol::try_read_epoch;

pub use protocol::try_read_metrics;

pub use protocol::try_read_observable;

pub use protocol::DebugRecord;

pub use protocol::ProtocolError;

pub use protocol::ARG0_WORD;

pub use protocol::ARGS_PER_SLOT;

pub use protocol::CONTROL_MIN_WORDS;

pub use protocol::OPCODE_WORD;

pub use protocol::PRIORITY_WORD;

pub use protocol::SLOT_WORDS;

pub use protocol::STATUS_WORD;

pub use protocol::TENANT_WORD;

pub use readback::ResidentQueueReadback;

pub use readback::ResidentReadbackCounters;

pub use resident::ResidentQueueBuffers;

pub use rule_catalog::BatchRuleProgram;

pub use rule_catalog::BatchRuleRejection;

pub use scheduler::default_priority_offsets_array;

pub use scheduler::priority_partition_active_lane_count;

pub use scheduler::priority_partition_probe_budget;

pub use scheduler::priority_partition_probe_count;

pub use scheduler::priority_scan_body;

pub use scheduler::priority_scan_body_with_stride;

pub use scheduler::write_default_priority_offsets;

pub use speculation::PairedSpeculationSample;

pub use speculation::PairedSpeculationUpdate;

pub use speculation::PairedSpeculationWindow;

pub use task::TaskPriority;

pub use task::TaskQueueSnapshot;

pub use task::TaskState;

pub use task::TaskWorkItem;

pub use telemetry::ControlSnapshot;

pub use telemetry::CountMinSketch;

pub use telemetry::ResidentRuntimeCounters;

pub use telemetry::RingOccupancy;

pub use telemetry::RingSlotSnapshot;

pub use telemetry::RingStatus;

pub use telemetry::RingTelemetry;

pub use telemetry::SketchTelemetry;

pub use telemetry::WindowTelemetry;

pub use telemetry::ResidentRuntimeEvidence;

pub use telemetry::RuntimeEvidenceMetricCoverage;

pub use telemetry::RuntimeEvidenceMetricFamily;

pub use telemetry::TelemetryDecodeCapacityEvidence;

pub use telemetry::TelemetryDecodeScratch;

pub use telemetry::RUNTIME_IO_EVIDENCE_SCHEMA_VERSION;

pub use telemetry::TELEMETRY_DECODE_CAPACITY_SCHEMA_VERSION;

pub use workspace_adapter::ResidentWorkspaceAdapter;

pub use workspace_layout::build_workspace_regions;

pub use workspace_layout::first_workspace_region;

pub use workspace_layout::next_record_workspace_region;

pub use workspace_layout::next_workspace_region;

pub use workspace_layout::workspace_record_words;

pub use workspace_layout::ResidentWorkspaceLayoutError;

pub use workspace_layout::ResidentWorkspaceRegion;

pub use workspace_layout::ResidentWorkspaceRegionSpec;

Modules

advanced

Advanced Tier-2 LEGO building blocks for the persistent megakernel.

automata_worklist

Non-blocking automata worklist policy for resident megakernel scheduling.

builder

IR program builders - construct the megakernel Program from vyre IR.

descriptor

Typed host-side descriptors for publishing work into the megakernel ring.

handlers

Built-in opcode handler bodies - STORE_U32, ATOMIC_ADD, PRINTF, SHUTDOWN.

io

IO subsystem - GPU↔runtime DMA request queue for the persistent megakernel.

ir_util

Shared IR fragments used by megakernel builders and schedulers.

mixed_work

Runtime-owned mixed-work protocol for resident megakernel batches.

planner

Resident work-queue sizing, launch geometry, and work-item contracts.

policy

Resident megakernel launch policy and queue-pressure decisions.

protocol

Ring-buffer protocol constants - slot layout, control words, opcodes, debug log.

readback

Typed host readback view for persistent megakernel outputs.

resident

Host mirrors for resident work-queue runtime buffers.

ring

Ring producer / consumer traits for the megakernel host protocol.

rule_catalog

DFA rule catalog packing for batched megakernel dispatch.

scaling

Occupancy-aware resident work-queue scaling.

scheduler

Work scheduler - priority-aware slot scanning for the persistent megakernel.

speculation

Runtime-side paired speculation races for megakernel dispatch.

task

Resident task queue ABI for pause, resume, requeue, and priority aging.

telemetry

Host-side telemetry decoders for the megakernel ring and control buffers.

workspace_adapter

Consumer-neutral resident workspace adapter for megakernel programs.

workspace_layout

Generic resident workspace region layout for megakernel adapters.

Structs

ResidentWorkQueue

Stateless owner of resident work-queue encoding and decoding operations.

Enums

RingSlotTransition

Explicit host-observable ring slot lifecycle transition.