Enum vapcore_sync::PriorityTask[−][src]

pub enum PriorityTask {
    PropagateBlock {
        started: Instant,
        block: Bytes,
        hash: H256,
        difficulty: U256,
    },
    PropagateTransactions(Instant, Arc<AtomicBool>),
}

A prioritized tasks run in a specialised timer. Every task should be completed within a hard deadline, if it’s not it’s either cancelled or split into multiple tasks. NOTE These tasks might not complete at all, so anything that happens here should work even if the task is cancelled.

Variants

PropagateBlock

Propagate given block

Fields of PropagateBlock

started: Instant

When the task was initiated

block: Bytes

Raw block RLP to propagate

hash: H256

Block hash

difficulty: U256

Blocks difficulty

PropagateTransactions(Instant, Arc<AtomicBool>)

Propagate a list of transactions

Implementations

`impl PriorityTask`[src]

`pub fn starting(&self)`[src]

Mark the task as being processed, right after it’s retrieved from the queue.

Trait Implementations

`impl Debug for PriorityTask`[src]

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

Auto Trait Implementations

`impl RefUnwindSafe for PriorityTask`

`impl Send for PriorityTask`

`impl Sync for PriorityTask`

`impl Unpin for PriorityTask`

`impl UnwindSafe for PriorityTask`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> Erased for T`

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> MaybeDebug for T where T: Debug,`

`impl<T> Pointable for T`

`pub const ALIGN: usize`

`type Init = T`

The type for initializers.

`pub unsafe fn init(init: <T as Pointable>::Init) -> usize`

`pub unsafe fn deref<'a>(ptr: usize) -> &'a T`

`pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T`

`pub unsafe fn drop(ptr: usize)`

`impl<T> Same<T> for T`

`type Output = T`

Should always be Self

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

Enum vapcore_sync::PriorityTask[−][src]

Variants

Fields of PropagateBlock

Implementations

impl PriorityTask[src]

pub fn starting(&self)[src]

Trait Implementations

impl Debug for PriorityTask[src]

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

Auto Trait Implementations

impl RefUnwindSafe for PriorityTask

impl Send for PriorityTask

impl Sync for PriorityTask

impl Unpin for PriorityTask

impl UnwindSafe for PriorityTask

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> Erased for T

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T> MaybeDebug for T where T: Debug,

impl<T> MaybeDebug for T where T: Debug,

impl<T> MaybeDebug for T where T: Debug,

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

`impl PriorityTask`[src]

`pub fn starting(&self)`[src]

`impl Debug for PriorityTask`[src]

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

`impl RefUnwindSafe for PriorityTask`

`impl Send for PriorityTask`

`impl Sync for PriorityTask`

`impl Unpin for PriorityTask`

`impl UnwindSafe for PriorityTask`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> Erased for T`

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> MaybeDebug for T where T: Debug,`

`impl<T> MaybeDebug for T where T: Debug,`

`impl<T> MaybeDebug for T where T: Debug,`

`impl<T> Pointable for T`

`pub const ALIGN: usize`

`type Init = T`

`pub unsafe fn init(init: <T as Pointable>::Init) -> usize`

`pub unsafe fn deref<'a>(ptr: usize) -> &'a T`

`pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T`

`pub unsafe fn drop(ptr: usize)`

`impl<T> Same<T> for T`

`type Output = T`

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

`type Error = <U as TryFrom<T>>::Error`

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src]

`impl<V, T> VZip<V> for T where V: MultiLane<T>,`

`pub fn vzip(self) -> V`