Home
last modified time | relevance | path

Searched refs:Protos (Results 1 – 25 of 32) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/ps/core/
Dabstract_node.h61 … const std::shared_ptr<MessageMeta> &meta, const Protos &protos,
152 const Protos &protos, const void *data, size_t size);
154 const Protos &protos, const void *data, size_t size);
157 const Protos &protos, const void *data, size_t size);
160 const Protos &protos, const void *data, size_t size);
164 const Protos &protos, const void *data, size_t size);
167 const Protos &protos, const void *data, size_t size);
171 const Protos &protos, const void *data, size_t size);
183 … const Protos &, const void *, size_t size, const uint32_t &timeout = kCommTimeoutInSeconds);
185 const Protos &protos, const void *data, size_t size);
[all …]
Dabstract_node.cc41 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, register_message.SerializeAsString().… in Register()
84 if (!client->SendMessage(message_meta, Protos::RAW, message.get(), size)) { in Broadcast()
118 if (!SendMessageSync(client_to_scheduler_, message_meta, Protos::PROTOBUF, in set_scale_out_done()
138 if (!SendMessageSync(client_to_scheduler_, message_meta, Protos::PROTOBUF, in set_scale_in_done()
158 …if (!SendMessageSync(client_to_scheduler_, message_meta, Protos::PROTOBUF, event_message.Serialize… in BroadcastEvent()
197 return SendMessageSync(client, message_meta, Protos::RAW, data.get(), len, timeout); in Send()
231 if (!client->SendMessage(message_meta, Protos::RAW, send.get(), len)) { in Send()
272 if (!client->SendMessage(message_meta, Protos::RAW, message.get(), len)) { in Send()
325 if (!client->SendMessage(message_meta, Protos::RAW, send.get(), len)) { in Send()
350 return SendMessageAsync(client, message_meta, Protos::RAW, data, size); in CollectiveSendAsync()
[all …]
Dinstance_manager.cc34 if (!client->SendMessage(message_meta, Protos::RAW, body.data(), body.length())) { in NewInstanceAsync()
54 if (!client->SendMessage(message_meta, Protos::RAW, res.data(), res.length())) { in QueryInstanceAsync()
74 if (!client->SendMessage(message_meta, Protos::RAW, res.data(), res.length())) { in EnableFLSAsync()
94 if (!client->SendMessage(message_meta, Protos::RAW, res.data(), res.length())) { in DisableFLSAsync()
Dnode.h73 …ync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageMeta> &, const Protos &,
84 const Protos &protos, const void *data, size_t size);
90 …void ProcessSendDataResp(const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const voi…
Dleader_scaler.cc33 …if (!node_->SendMessageSync(client, message_meta, Protos::PROTOBUF, scale_out_message.SerializeAsS… in ScaleOutAsync()
54 …if (!node_->SendMessageSync(client, message_meta, Protos::PROTOBUF, scale_in_message.SerializeAsSt… in ScaleInAsync()
Dscheduler_node.cc72 …if (!server->SendMessage(conn, meta, Protos::PROTOBUF, heartbeat_resp_message.SerializeAsString().… in ProcessHeartbeat()
122 const Protos &, const void *data, size_t size) { in CreateTcpServer() argument
171 …if (!server->SendMessage(conn, meta, Protos::PROTOBUF, register_resp_message.SerializeAsString().d… in ProcessRegister()
214 if (!server->SendMessage(conn, meta, Protos::PROTOBUF, data, size)) { in ProcessFinish()
254 …if (!server->SendMessage(conn, meta, Protos::PROTOBUF, fetch_servers_message.SerializeAsString().d… in ProcessFetchMetadata()
273 if (!server->SendMessage(conn, meta, Protos::PROTOBUF, data, size)) { in ProcessScaleOutDone()
301 if (!server->SendMessage(conn, meta, Protos::PROTOBUF, data, size)) { in ProcessScaleInDone()
329 if (!server->SendMessage(conn, meta, Protos::PROTOBUF, data, size)) { in ProcessSendEvent()
355 …if (!SendMessageAsync(client, message_meta, Protos::PROTOBUF, send_metadata_message.SerializeAsStr… in SendMetadata()
374 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, resp_data.data(), resp_data.size())) { in SendFinish()
[all …]
Dnode.cc58 const Protos &protos, const void *data, size_t size) { in SendMessageAsync()
73 … const Protos &protos, const void *data, size_t size, const uint32_t &timeout) { in SendMessageSync()
140 void Node::ProcessSendDataResp(const std::shared_ptr<MessageMeta> &meta, const Protos &, const void… in ProcessSendDataResp() argument
/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() argument
52 header.message_proto_ = Protos::RAW;
68 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30202() argument
82 header.message_proto_ = Protos::RAW;
104 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30302() argument
118 header.message_proto_ = Protos::RAW;
142 …handler.SetCallback([this](std::shared_ptr<MessageMeta> meta, const Protos &, const void *data, si… in __anone5e489d30402() argument
156 header.message_proto_ = Protos::RAW;
Dtcp_pb_server_test.cc38 const Protos &protos, const void *data, size_t size) { in SetUp()
67 …client_->SetMessageCallback([&](std::shared_ptr<MessageMeta> meta, const Protos &, const void *dat… in TEST_F() argument
84 …client_->SendMessage(message_meta, Protos::RAW, kv_message.SerializeAsString().data(), kv_message.… in TEST_F()
Dtcp_client_tests.cc34 …client->SetMessageCallback([&](std::shared_ptr<MessageMeta>, const Protos &, const void *data, siz… in TEST_F() argument
48 …client->SetMessageCallback([&](std::shared_ptr<MessageMeta>, const Protos &, const void *data, siz… in TEST_F() argument
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dmessage.h26 enum class Protos : uint32_t { RAW = 0, PROTOBUF = 1, FLATBUFFERS = 2 }; enum
41 Protos message_proto_ = Protos::RAW;
Dtcp_message_handler.cc39 message_header_.message_proto_ = *reinterpret_cast<const Protos *>(header_); in ReceiveMessage()
40 …if (message_header_.message_proto_ != Protos::RAW && message_header_.message_proto_ != Protos::FLA… in ReceiveMessage()
41 message_header_.message_proto_ != Protos::PROTOBUF) { in ReceiveMessage()
Dtcp_server.h63 …bool SendMessage(const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const void *data,…
79 const Protos &protos, const void *data, size_t size)>;
109 const Protos &protos, const void *data, size_t sizee);
Dtcp_client.h54 …std::function<void(const std::shared_ptr<MessageMeta> &, const Protos &, const void *, size_t size…
72 …bool SendMessage(const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const void *data,…
Dtcp_client.cc49 …[this](const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const void *data, size_t si… in TcpClient()
282 header.message_proto_ = Protos::PROTOBUF; in SendMessage()
301 bool TcpClient::SendMessage(const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const v… in SendMessage()
Dtcp_message_handler.h37 …std::function<void(const std::shared_ptr<MessageMeta> &, const Protos &, const void *, size_t size…
Dtcp_server.cc77 bool TcpConnection::SendMessage(const std::shared_ptr<MessageMeta> &meta, const Protos &protos, con… in SendMessage()
301 …[=](const std::shared_ptr<MessageMeta> &meta, const Protos &protos, const void *data, size_t size)… in ListenerCallback()
427 const Protos &protos, const void *data, size_t size) { in SendMessage()
/third_party/protobuf/
Dcc_proto_blacklist_test.bzl6 """Verifies that there are no C++ compile actions for Well-Known-Protos.
/third_party/protobuf/python/google/protobuf/pyext/
Dpython.proto40 // Protos optimized for SPEED use a strict superset of the generated code
/third_party/protobuf/src/google/protobuf/
Dunittest_lazy_dependencies_custom_option.proto54 // Protos optimized for SPEED use a strict superset of the generated code
Dunittest_lazy_dependencies_enum.proto51 // Protos optimized for SPEED use a strict superset of the generated code
Dunittest_lazy_dependencies.proto53 // Protos optimized for SPEED use a strict superset of the generated code
/third_party/protobuf/objectivec/ProtocolBuffers_tvOS.xcodeproj/
Dproject.pbxproj114 remoteInfo = "Compile Unittest Protos";
574 F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */ = {
577 …BBC111B0CDB50002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos" */;
584 name = "Compile Unittest Protos";
586 productName = "Compile Unittest Protos";
679 F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */,
828 target = F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */;
1122 …F45BBC111B0CDB50002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos"…
/third_party/protobuf/objectivec/ProtocolBuffers_OSX.xcodeproj/
Dproject.pbxproj113 remoteInfo = "Compile Unittest Protos";
568 F45BBC141B0CE3C6002D064D /* Compile Unittest Protos */ = {
571 …BBC171B0CE3C6002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos" */;
577 name = "Compile Unittest Protos";
579 productName = "Compile Unittest Protos";
672 F45BBC141B0CE3C6002D064D /* Compile Unittest Protos */,
821 target = F45BBC141B0CE3C6002D064D /* Compile Unittest Protos */;
1107 …F45BBC171B0CE3C6002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos"…
/third_party/protobuf/objectivec/ProtocolBuffers_iOS.xcodeproj/
Dproject.pbxproj114 remoteInfo = "Compile Unittest Protos";
574 F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */ = {
577 …BBC111B0CDB50002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos" */;
584 name = "Compile Unittest Protos";
586 productName = "Compile Unittest Protos";
679 F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */,
828 target = F45BBC0E1B0CDB50002D064D /* Compile Unittest Protos */;
1132 …F45BBC111B0CDB50002D064D /* Build configuration list for PBXLegacyTarget "Compile Unittest Protos"…

12