Home
last modified time | relevance | path

Searched defs:Protos (Results 1 – 7 of 7) sorted by relevance

/third_party/mindspore/tests/ut/cpp/ps/core/
Dtcp_message_handler_test.cc38 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30102()
68 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30202()
104 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30302()
142 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30402()
Dtcp_client_tests.cc34 …client->SetMessageCallback([&](std::shared_ptr<MessageMeta>, const Protos &, const void *data, siz… in TEST_F()
48 …client->SetMessageCallback([&](std::shared_ptr<MessageMeta>, const Protos &, const void *data, siz… in TEST_F()
Dtcp_pb_server_test.cc67 …client_->SetMessageCallback([&](std::shared_ptr<MessageMeta> meta, const Protos &, const void *dat… in TEST_F()
/third_party/mindspore/mindspore/ccsrc/ps/core/
Dabstract_node.cc635 … const std::shared_ptr<MessageMeta> &meta, const Protos &, const void *data, in ProcessSendMetadata()
687 const Protos &, const void *data, size_t size) { in ProcessFinish()
699 … const std::shared_ptr<MessageMeta> &meta, const Protos &, const void *data, in ProcessScaleOutDone()
712 … const std::shared_ptr<MessageMeta> &meta, const Protos &, const void *data, in ProcessScaleInDone()
725 const Protos &, const void *data, size_t size) { in ProcessEvent()
739 const Protos &, const void *data, size_t size) { in ProcessScaleOut()
759 const Protos &, const void *data, size_t size) { in ProcessScaleIn()
821 [&](const std::shared_ptr<MessageMeta> &meta, const Protos &, const void *data, size_t size) { in InitClientToScheduler()
943 const Protos &, const void *data, size_t size) { in ProcessSendData()
976 void AbstractNode::RunReceiveCallback(const std::shared_ptr<MessageMeta> &meta, const Protos &, con… in RunReceiveCallback()
Dnode.cc140 void Node::ProcessSendDataResp(const std::shared_ptr<MessageMeta> &meta, const Protos &, const void… in ProcessSendDataResp()
Dscheduler_node.cc122 const Protos &, const void *data, size_t size) { in CreateTcpServer()
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dmessage.h26 enum class Protos : uint32_t { RAW = 0, PROTOBUF = 1, FLATBUFFERS = 2 }; enum