Struct tensorflow_proto::tensorflow::RecvBufRequest

pub struct RecvBufRequest {
    pub step_id: i64,
    pub buf_rendezvous_key: String,
    pub num_bytes: i64,
    pub buf_ptr: u64,
    pub client_locality: Option<DeviceLocality>,
    pub server_locality: Option<DeviceLocality>,
    pub transport_options: Option<Any>,
    pub src_device: String,
    pub dst_device: String,
    pub request_id: i64,
    pub src_incarnation: u64,
}

Use of the fields below may vary by implementation. For example the buf_ptr and num_bytes may be set only for local operations and not sent on the wire, or only sent on the wire in one direction.

Fields

step_id: i64

Used at server side to find the correct BufRendezvous.

buf_rendezvous_key: String

Arbitrary string identifying a BufRendezvous entry.

num_bytes: i64

Size of value expected, must agree with BufRendezvous entry.

buf_ptr: u64

When RDMA is in use, address of destination field on client.

client_locality: Option<DeviceLocality>

Optional information on client-side device locality.

server_locality: Option<DeviceLocality>

Optional information on server-side device locality.

transport_options: Option<Any>

Optional, implementation-specific data.

src_device: String

For annotating timeline and device incarnation check.

dst_device: String

Optional, for annotating the timeline.

request_id: i64

Depending on the RPC system in use, it may be necessary to set this id to detect resends of RPCs where the server is not aware that the prior RPC failed.

src_incarnation: u64

Incarnation number of the source device, used to detect worker failures.

Trait Implementations

impl Clone for RecvBufRequest

fn clone(&self) -> RecvBufRequest

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RecvBufRequest

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Default for RecvBufRequest

fn default() -> RecvBufRequest

Returns the "default value" for a type.

impl Message for RecvBufRequest

fn encode_raw<B>(&self, buf: &mut B) where
    B: BufMut, 

fn merge_field<B>(
    &mut self,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf, 

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message to a buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message with a length-delimiter to a buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<RecvBufRequest> for RecvBufRequest

fn eq(&self, other: &RecvBufRequest) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &RecvBufRequest) -> bool

This method tests for !=.

impl StructuralPartialEq for RecvBufRequest