Searched defs:Protos (Results 1 – 7 of 7) sorted by relevance
/third_party/mindspore/tests/ut/cpp/ps/core/ |
D | tcp_message_handler_test.cc | 38 …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()
|
D | tcp_client_tests.cc | 34 …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()
|
D | tcp_pb_server_test.cc | 67 …client_->SetMessageCallback([&](std::shared_ptr<MessageMeta> meta, const Protos &, const void *dat… in TEST_F()
|
/third_party/mindspore/mindspore/ccsrc/ps/core/ |
D | abstract_node.cc | 635 … 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()
|
D | node.cc | 140 void Node::ProcessSendDataResp(const std::shared_ptr<MessageMeta> &meta, const Protos &, const void… in ProcessSendDataResp()
|
D | scheduler_node.cc | 122 const Protos &, const void *data, size_t size) { in CreateTcpServer()
|
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/ |
D | message.h | 26 enum class Protos : uint32_t { RAW = 0, PROTOBUF = 1, FLATBUFFERS = 2 }; enum
|