HomeSort by relevance Sort by last modified time
    Searched refs:RdmaMessageBuffer (Results 1 - 5 of 5) sorted by null

  /external/tensorflow/tensorflow/contrib/verbs/
rdma.h 367 class RdmaMessageBuffer;
373 friend class RdmaMessageBuffer;
409 friend class RdmaMessageBuffer;
422 inline const std::vector<RdmaMessageBuffer*>& message_buffers() const {
471 RdmaMessageBuffer* tx_message_buffer_;
472 RdmaMessageBuffer* rx_message_buffer_;
473 std::vector<RdmaMessageBuffer*> message_buffers_;
477 class RdmaMessageBuffer {
484 explicit RdmaMessageBuffer(RdmaChannel* channel, string name);
485 ~RdmaMessageBuffer();
    [all...]
grpc_verbs_service.cc 126 std::vector<RdmaMessageBuffer*> mb(rc->message_buffers());
133 RdmaMessageBuffer* rb = mb[idx[i]];
rdma.cc 461 RdmaMessageBuffer* rb;
483 RdmaMessageBuffer::SendAck(rc);
512 RdmaMessageBuffer* rb =
513 reinterpret_cast<RdmaMessageBuffer*>(wr_id->write_context);
620 tx_message_buffer_ = new RdmaMessageBuffer(this, buffer_names[0]);
621 rx_message_buffer_ = new RdmaMessageBuffer(this, buffer_names[1]);
761 RdmaMessageBuffer::RdmaMessageBuffer(RdmaChannel* channel, string name)
764 RdmaMessageBuffer::~RdmaMessageBuffer() {
    [all...]
rdma_mgr.cc 110 RdmaMessageBuffer* rb = rc->message_buffers_[idx[i]];
README.md 99 3. The sending of protocol messages (**RDMA_MESSAGE_TENSOR_REQUEST**, **RDMA_MESSAGE_META_DATA_RESPONSE** and **RDMA_MESSAGE_TENSOR_RE_REQUEST**) is done by the class **RdmaMessageBuffer**. All messages are sent using RDMA writes from/to fixed messages buffers. This implies that we cannot send on a specific channel more than one message at a time. In order to synchronize the messages, the **RdmaMessageBuffer** holds the a local and remote buffer statuses which can be either busy or idle. When a write is issued, both statuses will be changed to busy. When the write-complete event is received, the local status is changed to idle. When the write is received on the remote side, the remote side will parse the message, and return an ACK back to the sending side on which the sending side will update the remote status to idle. When both the local and remote statuses are idle, the next message can be sent.
133 * **class RdmaMessageBuffer** - Responsible for sending or receiving messages. It has a fixed size memory to store the data. It has a queue to store the pending jobs. A channel has two message buffers one for tx and one for rx.

Completed in 81 milliseconds