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

Method EnqueueActorMsg

oneflow/core/thread/thread.h:40–46  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

38 Channel<ActorMsg>* GetMsgChannelPtr() { return &msg_channel_; }
39
40 inline void EnqueueActorMsg(const ActorMsg& msg) {
41 if (UseLocalMsgQueue()) {
42 local_msg_queue_.push(msg);
43 } else {
44 msg_channel_.Send(msg);
45 }
46 }
47
48 template<typename InputIt>
49 inline void EnqueueActorMsg(InputIt first, InputIt last) {

Callers 4

InitActMsgMethod · 0.80
ActOnceMethod · 0.80
SendMsgWithoutCommNetMethod · 0.80

Calls 2

pushMethod · 0.80
SendMethod · 0.45

Tested by

no test coverage detected