pub struct MessageHeader {
pub channel: usize,
pub source: usize,
pub target_lower: usize,
pub target_upper: usize,
pub length: usize,
pub seqno: usize,
}
Expand description
Framing data for each Vec<u8>
transmission, indicating a typed channel, the source and
destination workers, and the length in bytes.
Fields§
§channel: usize
index of channel.
source: usize
index of worker sending message.
target_lower: usize
lower bound of index of worker receiving message.
target_upper: usize
upper bound of index of worker receiving message.
This is often self.target_lower + 1
for point to point messages,
but can be larger for broadcast messages.
length: usize
number of bytes in message.
seqno: usize
sequence number.
Implementations§
Source§impl MessageHeader
impl MessageHeader
Sourcepub fn try_read(bytes: &[u8]) -> Option<MessageHeader>
pub fn try_read(bytes: &[u8]) -> Option<MessageHeader>
Returns a header when there is enough supporting data
Sourcepub fn write_to<W>(&self, writer: &mut W) -> Result<(), Error>where
W: Write,
pub fn write_to<W>(&self, writer: &mut W) -> Result<(), Error>where
W: Write,
Writes the header as binary data.
Sourcepub fn required_bytes(&self) -> usize
pub fn required_bytes(&self) -> usize
The number of bytes required for the header and data.
Sourcepub fn header_bytes(&self) -> usize
pub fn header_bytes(&self) -> usize
The number of bytes required for the header.
Trait Implementations§
Source§impl Clone for MessageHeader
impl Clone for MessageHeader
Source§fn clone(&self) -> MessageHeader
fn clone(&self) -> MessageHeader
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Columnar for MessageHeader
impl Columnar for MessageHeader
Source§type Container = MessageHeaderContainer<<usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container>
type Container = MessageHeaderContainer<<usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container, <usize as Columnar>::Container>
The type that stores the columnar representation. Read more
Source§fn copy_from<'a>(
&mut self,
other: <<MessageHeader as Columnar>::Container as Container>::Ref<'a>,
)
fn copy_from<'a>( &mut self, other: <<MessageHeader as Columnar>::Container as Container>::Ref<'a>, )
Repopulates
self
from a reference. Read moreSource§fn into_owned<'a>(
other: <<MessageHeader as Columnar>::Container as Container>::Ref<'a>,
) -> MessageHeader
fn into_owned<'a>( other: <<MessageHeader as Columnar>::Container as Container>::Ref<'a>, ) -> MessageHeader
Produce an instance of
Self
from Self::Ref<'a>
.Source§fn as_columns<'a, I>(selves: I) -> Self::Containerwhere
I: IntoIterator<Item = &'a Self>,
Self: 'a,
fn as_columns<'a, I>(selves: I) -> Self::Containerwhere
I: IntoIterator<Item = &'a Self>,
Self: 'a,
Converts a sequence of the references to the type into columnar form.
Source§fn into_columns<I>(selves: I) -> Self::Containerwhere
I: IntoIterator<Item = Self>,
Self: Sized,
fn into_columns<I>(selves: I) -> Self::Containerwhere
I: IntoIterator<Item = Self>,
Self: Sized,
Converts a sequence of the type into columnar form. Read more
Source§impl Debug for MessageHeader
impl Debug for MessageHeader
Source§impl<'de> Deserialize<'de> for MessageHeader
impl<'de> Deserialize<'de> for MessageHeader
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<MessageHeader, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<MessageHeader, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Hash for MessageHeader
impl Hash for MessageHeader
Source§impl<R0, R1, R2, R3, R4, R5> PartialEq<MessageHeader> for MessageHeaderReference<R0, R1, R2, R3, R4, R5>
impl<R0, R1, R2, R3, R4, R5> PartialEq<MessageHeader> for MessageHeaderReference<R0, R1, R2, R3, R4, R5>
Source§impl PartialEq for MessageHeader
impl PartialEq for MessageHeader
Source§impl<'columnar, C0, C1, C2, C3, C4, C5> Push<&'columnar MessageHeader> for MessageHeaderContainer<C0, C1, C2, C3, C4, C5>
impl<'columnar, C0, C1, C2, C3, C4, C5> Push<&'columnar MessageHeader> for MessageHeaderContainer<C0, C1, C2, C3, C4, C5>
Source§fn push(&mut self, item: &'columnar MessageHeader)
fn push(&mut self, item: &'columnar MessageHeader)
Pushes an item onto
self
.Source§fn extend(&mut self, iter: impl IntoIterator<Item = T>)
fn extend(&mut self, iter: impl IntoIterator<Item = T>)
Pushes elements of an iterator onto
self
.Source§impl<C0, C1, C2, C3, C4, C5> Push<MessageHeader> for MessageHeaderContainer<C0, C1, C2, C3, C4, C5>
impl<C0, C1, C2, C3, C4, C5> Push<MessageHeader> for MessageHeaderContainer<C0, C1, C2, C3, C4, C5>
Source§fn push(&mut self, item: MessageHeader)
fn push(&mut self, item: MessageHeader)
Pushes an item onto
self
.Source§fn extend(&mut self, iter: impl IntoIterator<Item = T>)
fn extend(&mut self, iter: impl IntoIterator<Item = T>)
Pushes elements of an iterator onto
self
.Source§impl Serialize for MessageHeader
impl Serialize for MessageHeader
Source§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Serialize this value into the given Serde serializer. Read more
impl Copy for MessageHeader
impl Eq for MessageHeader
impl StructuralPartialEq for MessageHeader
Auto Trait Implementations§
impl Freeze for MessageHeader
impl RefUnwindSafe for MessageHeader
impl Send for MessageHeader
impl Sync for MessageHeader
impl Unpin for MessageHeader
impl UnwindSafe for MessageHeader
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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