Searched refs:RdmaMessageBuffer (Results 1 – 5 of 5) sorted by relevance
367 class RdmaMessageBuffer; variable373 friend class RdmaMessageBuffer; variable409 friend class RdmaMessageBuffer; variable422 inline const std::vector<RdmaMessageBuffer*>& message_buffers() const { in message_buffers()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();
460 RdmaMessageBuffer* rb; in Process_CQ()482 RdmaMessageBuffer::SendAck(rc); in Process_CQ()511 RdmaMessageBuffer* rb = in Process_CQ()512 reinterpret_cast<RdmaMessageBuffer*>(wr_id->write_context); in Process_CQ()619 tx_message_buffer_ = new RdmaMessageBuffer(this, buffer_names[0]); in RdmaChannel()620 rx_message_buffer_ = new RdmaMessageBuffer(this, buffer_names[1]); in RdmaChannel()760 RdmaMessageBuffer::RdmaMessageBuffer(RdmaChannel* channel, string name) in RdmaMessageBuffer() function in tensorflow::RdmaMessageBuffer763 RdmaMessageBuffer::~RdmaMessageBuffer() { in ~RdmaMessageBuffer()768 void RdmaMessageBuffer::FreeBuffer() { in FreeBuffer()780 void RdmaMessageBuffer::CreateCPUBuffer(size_t size, bool lock) { in CreateCPUBuffer()[all …]
126 std::vector<RdmaMessageBuffer*> mb(rc->message_buffers()); in GetRemoteAddressSync()133 RdmaMessageBuffer* rb = mb[idx[i]]; in GetRemoteAddressSync()
112 RdmaMessageBuffer* rb = rc->message_buffers_[idx[i]]; in SetupChannels()
99 …RdmaMessageBuffer**. All messages are sent using RDMA writes from/to fixed messages buffers. This …133 * **class RdmaMessageBuffer** - Responsible for sending or receiving messages. It has a fixed si…