pub struct HostcallRequestQueue<T: Clone + QueueTenant> { /* private fields */ }Implementations§
Source§impl<T: Clone + QueueTenant> HostcallRequestQueue<T>
impl<T: Clone + QueueTenant> HostcallRequestQueue<T>
pub fn with_capacities(fast_capacity: usize, overflow_capacity: usize) -> Self
pub fn with_mode( fast_capacity: usize, overflow_capacity: usize, reclamation_mode: HostcallQueueMode, ) -> Self
pub fn len(&self) -> usize
pub fn is_empty(&self) -> bool
pub const fn reclamation_mode(&self) -> HostcallQueueMode
pub fn pin_epoch(&self) -> HostcallEpochPin
pub fn clear(&mut self)
pub fn push_back(&mut self, request: T) -> HostcallQueueEnqueueResult
pub fn drain_all(&mut self) -> VecDeque<T>
Sourcepub fn force_reclaim(&mut self)
pub fn force_reclaim(&mut self)
Explicit reclamation point used by tests and slow-path maintenance.
Sourcepub fn force_safe_fallback(&mut self)
pub fn force_safe_fallback(&mut self)
Immediately disable EBR and switch to the safe fallback mode.
Sourcepub fn observe_contention_window(
&mut self,
sample: ContentionSample,
) -> BravoPolicyDecision
pub fn observe_contention_window( &mut self, sample: ContentionSample, ) -> BravoPolicyDecision
Feed one deterministic contention observation window into the BRAVO policy controller.
pub const fn contention_policy_snapshot(&self) -> BravoPolicyTelemetry
pub fn snapshot(&self) -> HostcallQueueTelemetry
Trait Implementations§
Source§impl<T: Debug + Clone + QueueTenant> Debug for HostcallRequestQueue<T>
impl<T: Debug + Clone + QueueTenant> Debug for HostcallRequestQueue<T>
Source§impl<T: Clone + QueueTenant> Default for HostcallRequestQueue<T>
impl<T: Clone + QueueTenant> Default for HostcallRequestQueue<T>
Auto Trait Implementations§
impl<T> !Freeze for HostcallRequestQueue<T>
impl<T> RefUnwindSafe for HostcallRequestQueue<T>where
T: RefUnwindSafe,
impl<T> Send for HostcallRequestQueue<T>where
T: Send,
impl<T> Sync for HostcallRequestQueue<T>
impl<T> Unpin for HostcallRequestQueue<T>where
T: Unpin,
impl<T> UnsafeUnpin for HostcallRequestQueue<T>
impl<T> UnwindSafe for HostcallRequestQueue<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, _span: NoopSpan) -> Self
fn instrument(self, _span: NoopSpan) -> Self
Instruments this future with a span (no-op when disabled).
Source§fn in_current_span(self) -> Self
fn in_current_span(self) -> Self
Instruments this future with the current span (no-op when disabled).
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>
Converts
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>
Converts
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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<R, P> ReadPrimitive<R> for P
impl<R, P> ReadPrimitive<R> for P
Source§fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
Read this value from the supplied reader. Same as
ReadEndian::read_from_little_endian().