pub struct SyncCopperListsManager<P: CopperListTuple + Default, const NBCL: usize> {
pub last_encoded_bytes: u64,
pub last_handle_bytes: u64,
/* private fields */
}Expand description
Manages the lifecycle of the copper lists and logging on the synchronous path.
Fields§
§last_encoded_bytes: u64Last encoded size returned by logger.log
last_handle_bytes: u64Last handle-backed payload bytes observed during logger.log
Implementations§
Source§impl<P: CopperListTuple + Default, const NBCL: usize> SyncCopperListsManager<P, NBCL>
impl<P: CopperListTuple + Default, const NBCL: usize> SyncCopperListsManager<P, NBCL>
pub fn new(
logger: Option<Box<dyn WriteStream<CopperList<P>>>>,
) -> CuResult<Self>where
P: CuListZeroedInit,
pub fn next_cl_id(&self) -> u64
pub fn last_cl_id(&self) -> u64
pub fn peek(&self) -> Option<&CopperList<P>>
pub fn last_completed_encoded(&self) -> Option<&[u8]>
pub fn set_last_completed_encoded(&mut self, _snapshot: Option<Vec<u8>>)
pub fn create(&mut self) -> CuResult<&mut CopperList<P>>
pub fn end_of_processing(&mut self, culistid: u64) -> CuResult<()>
pub fn finish_pending(&mut self) -> CuResult<()>
pub fn available_copper_lists(&mut self) -> CuResult<usize>
pub fn end_of_processing_boxed( &mut self, culist: Box<CopperList<P>>, ) -> CuResult<OwnedCopperListSubmission<P>>
pub fn try_reclaim_boxed(&mut self) -> CuResult<Option<Box<CopperList<P>>>>
pub fn wait_reclaim_boxed(&mut self) -> CuResult<Box<CopperList<P>>>
pub fn finish_pending_boxed(&mut self) -> CuResult<Vec<Box<CopperList<P>>>>
Auto Trait Implementations§
impl<P, const NBCL: usize> Freeze for SyncCopperListsManager<P, NBCL>
impl<P, const NBCL: usize> !RefUnwindSafe for SyncCopperListsManager<P, NBCL>
impl<P, const NBCL: usize> Send for SyncCopperListsManager<P, NBCL>where
P: Send,
impl<P, const NBCL: usize> Sync for SyncCopperListsManager<P, NBCL>where
P: Sync,
impl<P, const NBCL: usize> Unpin for SyncCopperListsManager<P, NBCL>
impl<P, const NBCL: usize> UnsafeUnpin for SyncCopperListsManager<P, NBCL>
impl<P, const NBCL: usize> !UnwindSafe for SyncCopperListsManager<P, NBCL>
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
Mutably borrows from an owned value. Read more
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSend for T
impl<T> DowncastSend for T
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 more