MCPcopy Create free account
hub / github.com/DeepRec-AI/DeepRec / EnqueueItem

Method EnqueueItem

tensorflow/contrib/verbs/rdma.cc:821–824  ·  view source on GitHub ↗

Put a task in the buffer's job queue

Source from the content-addressed store, hash-verified

819
820// Put a task in the buffer's job queue
821void RdmaMessageBuffer::EnqueueItem(string item) {
822 mutex_lock lock{mu_};
823 queue_.push(item);
824}
825
826// Rdma-Write the content of the buffer
827void RdmaMessageBuffer::Write(uint32_t imm_data, size_t buffer_size) {

Callers 3

SendMetaDataMethod · 0.80
SendErrorStatusMethod · 0.80
SendMethod · 0.80

Calls 1

pushMethod · 0.45

Tested by

no test coverage detected