Searched refs:RdmaMessage (Results 1 – 2 of 2) sorted by relevance
86 struct RdmaMessage { struct138 static string CreateMessage(const RdmaMessage& rm); argument139 static void ParseMessage(RdmaMessage& rm, void* buffer);311 RdmaTensorResponse(RdmaChannel* channel, const RdmaMessage& rm) in RdmaTensorResponse()314 void Update(const RdmaMessage& rm) { rm_ = rm; } in Update()353 RdmaMessage rm_; // The request message439 RdmaTensorResponse* AddTensorResponse(const RdmaMessage& rm);440 RdmaTensorResponse* UpdateTensorResponse(const RdmaMessage& rm);
461 RdmaMessage rm; in Process_CQ()481 RdmaMessage::ParseMessage(rm, rb->buffer_); in Process_CQ()625 tx_message_buffer_->CreateCPUBuffer(RdmaMessage::kRdmaMessageBufferSize); in RdmaChannel()626 rx_message_buffer_->CreateCPUBuffer(RdmaMessage::kRdmaMessageBufferSize); in RdmaChannel()972 RdmaTensorResponse* RdmaChannel::AddTensorResponse(const RdmaMessage& rm) { in AddTensorResponse()981 RdmaTensorResponse* RdmaChannel::UpdateTensorResponse(const RdmaMessage& rm) { in UpdateTensorResponse()1171 RdmaMessage rm; in SendMetaData()1191 string message = RdmaMessage::CreateMessage(rm); in SendMetaData()1236 RdmaMessage rm; in SendErrorStatus()1247 string message = RdmaMessage::CreateMessage(rm); in SendErrorStatus()[all …]