Searched defs:message_meta (Results 1 – 7 of 7) sorted by relevance
53 auto message_meta = std::make_shared<MessageMeta>(); in Register() local79 auto message_meta = std::make_shared<MessageMeta>(); in SendFailMessageToScheduler() local148 auto message_meta = std::make_shared<MessageMeta>(); in Broadcast() local184 auto message_meta = std::make_shared<MessageMeta>(); in set_scale_out_done() local204 auto message_meta = std::make_shared<MessageMeta>(); in set_scale_in_done() local223 auto message_meta = std::make_shared<MessageMeta>(); in BroadcastEvent() local272 auto message_meta = std::make_shared<MessageMeta>(); in Send() local323 auto message_meta = std::make_shared<MessageMeta>(); in Send() local350 auto message_meta = std::make_shared<MessageMeta>(); in SendToScheduler() local388 std::shared_ptr<MessageMeta> message_meta = std::make_shared<MessageMeta>(); in CollectiveSendAsync() local[all …]
138 auto message_meta = std::make_shared<MessageMeta>(); in RunRecovery() local623 auto message_meta = std::make_shared<MessageMeta>(); in SendPrepareBuildingNetwork() local639 auto message_meta = std::make_shared<MessageMeta>(); in SendMetadata() local664 auto message_meta = std::make_shared<MessageMeta>(); in SendFinish() local682 auto message_meta = std::make_shared<MessageMeta>(); in SendScaleOutDone() local700 auto message_meta = std::make_shared<MessageMeta>(); in SendScaleInDone() local718 auto message_meta = std::make_shared<MessageMeta>(); in SendEvent() local
105 auto message_meta = std::make_shared<MessageMeta>(); in Register() local
106 auto message_meta = std::make_shared<MessageMeta>(); in Register() local
81 auto message_meta = std::make_shared<MessageMeta>(); in TEST_F() local
105 namespace message_meta { namespace
31 PyObject* message_meta; // We own a ref. member