MCPcopy Create free account
hub / github.com/Oneflow-Inc/oneflow / SendCmdMsg

Function SendCmdMsg

oneflow/core/job/runtime.cpp:38–43  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

36namespace {
37
38void SendCmdMsg(const std::vector<const TaskProto*>& tasks, ActorCmd cmd) {
39 for (const TaskProto* task : tasks) {
40 ActorMsg msg = ActorMsg::BuildCommandMsg(task->task_id(), cmd);
41 Singleton<ActorMsgBus>::Get()->SendMsg(msg);
42 }
43}
44
45void HandoutTasks(const std::vector<const TaskProto*>& tasks) {
46 for (const TaskProto* task : tasks) {

Callers 2

HandoutTasksFunction · 0.85
RuntimeMethod · 0.85

Calls 3

GetFunction · 0.85
SendMsgMethod · 0.80
task_idMethod · 0.45

Tested by

no test coverage detected