Struct test_raftstore::CollectSnapshotFilter[−][src]

pub struct CollectSnapshotFilter {
    dropped: AtomicBool,
    stale: AtomicBool,
    pending_msg: Mutex<HashMap<u64, RaftMessage>>,
    pending_count_sender: Mutex<Sender<usize>>,
}
[−]

CollectSnapshotFilter is a simulation transport filter to simulate the simultaneous delivery of multiple snapshots from different peers. It collects the snapshots from different peers and drop the subsequent snapshots from the same peers. Currently, if there are more than 1 snapshots in this filter, all the snapshots will be dilivered at once.

Fields

dropped: AtomicBoolstale: AtomicBoolpending_msg: Mutex<HashMap<u64, RaftMessage>>pending_count_sender: Mutex<Sender<usize>>

Implementations

impl CollectSnapshotFilter[src][−]

pub fn new(sender: Sender<usize>) -> CollectSnapshotFilter[src]

Trait Implementations

impl Filter for CollectSnapshotFilter[src][+]

Auto Trait Implementations

impl RefUnwindSafe for CollectSnapshotFilter

impl Send for CollectSnapshotFilter

impl Sync for CollectSnapshotFilter

impl Unpin for CollectSnapshotFilter

impl UnwindSafe for CollectSnapshotFilter

Blanket Implementations

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

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

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

impl<V, W> ConvertFrom<W> for V where
    W: ConvertTo<V>, [src][+]

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

impl<T> Instrument for T[src][+]

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

impl<T> Pointable for T[src][+]

type Init = T

The type for initializers.

impl<T> Pointable for T[src][+]

type Init = T

The type for initializers.

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

type Output = T

Should always be Self

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

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized, [src]

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

type Error = Infallible

The type returned in the event of a conversion error.

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

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

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, [src][+]