MCPcopy Create free account
hub / github.com/dmlc/parameter_server / waitOutgoingTask

Method waitOutgoingTask

src/system/remote_node.cc:131–137  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

129}
130
131void RNode::waitOutgoingTask(int time) {
132 // if (time <= Message::kInvalidTime) return;
133 for (auto& w : exec_.group(id())) {
134 // LL << w->id();
135 w->outgoing_task_.wait(time);
136 }
137}
138
139bool RNode::tryWaitOutgoingTask(int time) {
140 // if (time <= Message::kInvalidTime) return true;

Callers 2

waitOutMsgMethod · 0.80
startMethod · 0.80

Calls 1

waitMethod · 0.80

Tested by

no test coverage detected