pub struct Tier1SimdExecutor { /* private fields */ }Expand description
Per-fiber Tier-1 executor. The scalar and native register kernels share no mutable state with another fiber.
Implementations§
Source§impl Tier1SimdExecutor
impl Tier1SimdExecutor
Sourcepub fn descriptor(&self) -> &Tier1SimdDescriptor
pub fn descriptor(&self) -> &Tier1SimdDescriptor
The plan’s description.
Sourcepub const fn stats(&self) -> Tier1SimdStats
pub const fn stats(&self) -> Tier1SimdStats
The counters so far.
Sourcepub fn scalar_program(&self) -> &Arc<PolydatProgram> ⓘ
pub fn scalar_program(&self) -> &Arc<PolydatProgram> ⓘ
The scalar program the plan falls back to.
Sourcepub const fn has_active_lease(&self) -> bool
pub const fn has_active_lease(&self) -> bool
Whether a lease is open.
Sourcepub fn set_broadcast(
&mut self,
name: &str,
value: Value,
) -> Result<(), Tier1SimdError>
pub fn set_broadcast( &mut self, name: &str, value: Value, ) -> Result<(), Tier1SimdError>
Freeze one scope-stable input value for subsequent packet evaluation. Rebinding during an owned lease is rejected rather than invalidating already-reserved logical inputs.
Sourcepub fn begin_lease(
&mut self,
lease: OrdinalBatchLease,
activation_epoch: u64,
) -> Result<(), Tier1LeaseStartError>
pub fn begin_lease( &mut self, lease: OrdinalBatchLease, activation_epoch: u64, ) -> Result<(), Tier1LeaseStartError>
Accept an owned source reservation. A rejection returns the lease in
Tier1LeaseStartError so the caller can scalar-process it.
Sourcepub fn force_scalar_recovery(&mut self)
pub fn force_scalar_recovery(&mut self)
Discard an uncommitted register packet and process the remainder of the active lease through the retained scalar graph. The consumer frontier does not move and the shared source cursor is not touched.
Sourcepub fn drain_into(&mut self, output: &mut [Value]) -> usize
pub fn drain_into(&mut self, output: &mut [Value]) -> usize
Drain committed scalar values in ordinal order. Calls may use arbitrary
burst sizes; a partly consumed register packet remains in BatchState.
Auto Trait Implementations§
impl !RefUnwindSafe for Tier1SimdExecutor
impl !UnwindSafe for Tier1SimdExecutor
impl Freeze for Tier1SimdExecutor
impl Send for Tier1SimdExecutor
impl Sync for Tier1SimdExecutor
impl Unpin for Tier1SimdExecutor
impl UnsafeUnpin for Tier1SimdExecutor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more