OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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