| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | leader_scaler.cc | 33 …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()
|
| D | node.h | 73 …bool SendMessageSync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageMeta> …
80 bool SendMessageSync(const std::shared_ptr<TcpClient> &client, const CommMessage &message,
|
| D | abstract_node.cc | 41 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, register_message.SerializeAsString().… in Register()
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()
543 if (!SendMessageSync(client, meta, Protos::PROTOBUF, heartbeat_message.SerializeAsString().data(), in Heartbeat()
615 if (!SendMessageSync(client, meta, Protos::PROTOBUF, fetch_servers.SerializeAsString().data(), in FetchServers()
795 if (!SendMessageSync(client, meta, Protos::RAW, finish_message.data(), finish_message.length())) { in Disconnect()
894 bool AbstractNode::SendMessageSync(const std::shared_ptr<TcpClient> &client, const CommMessage &mes… in SendMessageSync() function in mindspore::ps::core::AbstractNode
919 bool AbstractNode::SendMessageSync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<… in SendMessageSync() function in mindspore::ps::core::AbstractNode
|
| D | node.cc | 44 bool Node::SendMessageSync(const std::shared_ptr<TcpClient> &client, const CommMessage &message, in SendMessageSync() function in mindspore::ps::core::Node
72 bool Node::SendMessageSync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageM… in SendMessageSync() function in mindspore::ps::core::Node
|
| D | abstract_node.h | 180 bool SendMessageSync(const std::shared_ptr<TcpClient> &client, const CommMessage &message,
182 …bool SendMessageSync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageMeta> …
|
| D | scheduler_node.cc | 374 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, resp_data.data(), resp_data.size())) { in SendFinish()
392 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, resp_data.data(), resp_data.size())) { in SendScaleOutDone()
410 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, resp_data.data(), resp_data.size())) { in SendScaleInDone()
428 …if (!SendMessageSync(client, message_meta, Protos::PROTOBUF, event_resp_message.SerializeAsString(… in SendEvent()
|