| /third_party/mindspore/mindspore/ccsrc/ps/core/ |
| D | server_node.cc | 23 bool ServerNode::Start(const uint32_t &timeout) { in Start()
43 void ServerNode::Initialize() { in Initialize()
68 bool ServerNode::Stop() { in Stop()
86 bool ServerNode::Finish(const uint32_t &timeout) { in Finish()
|
| D | server_node.h | 41 class ServerNode : public AbstractNode {
43 ServerNode() = default;
45 ~ServerNode() override = default;
|
| /third_party/grpc/src/core/lib/channel/ |
| D | channelz.cc | 253 ServerNode::ServerNode(size_t channel_tracer_max_nodes) in ServerNode() function in grpc_core::channelz::ServerNode
256 ServerNode::~ServerNode() {} in ~ServerNode()
258 void ServerNode::AddChildSocket(RefCountedPtr<SocketNode> node) { in AddChildSocket()
263 void ServerNode::RemoveChildSocket(intptr_t child_uuid) { in RemoveChildSocket()
268 void ServerNode::AddChildListenSocket(RefCountedPtr<ListenSocketNode> node) { in AddChildListenSocket()
273 void ServerNode::RemoveChildListenSocket(intptr_t child_uuid) { in RemoveChildListenSocket()
278 std::string ServerNode::RenderServerSockets(intptr_t start_socket_id, in RenderServerSockets()
305 Json ServerNode::RenderJson() { in RenderJson()
|
| D | channelz.h | 230 class ServerNode : public BaseNode {
232 explicit ServerNode(size_t channel_tracer_max_nodes);
234 ~ServerNode() override;
|
| D | channelz_registry.cc | 222 grpc_core::channelz::ServerNode* server_node = in grpc_channelz_get_server_sockets()
223 static_cast<grpc_core::channelz::ServerNode*>(base_node.get()); in grpc_channelz_get_server_sockets()
|
| /third_party/mindspore/mindspore/ccsrc/fl/server/ |
| D | collective_ops_impl.h | 45 void Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node);
67 std::shared_ptr<ps::core::ServerNode> server_node_;
|
| D | distributed_metadata_store.h | 47 void Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node);
92 std::shared_ptr<ps::core::ServerNode> server_node_;
|
| D | distributed_count_service.h | 57 …void Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node, uint32_t counting_server…
110 std::shared_ptr<ps::core::ServerNode> server_node_;
|
| D | iteration.h | 56 void RegisterEventCallback(const std::shared_ptr<ps::core::ServerNode> &server_node);
198 std::shared_ptr<ps::core::ServerNode> server_node_;
|
| D | server.h | 152 std::shared_ptr<ps::core::ServerNode> server_node_;
|
| D | distributed_metadata_store.cc | 25 void DistributedMetadataStore::Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node)… in Initialize()
|
| D | collective_ops_impl.cc | 22 void CollectiveOpsImpl::Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node) { in Initialize()
|
| D | distributed_count_service.cc | 25 void DistributedCountService::Initialize(const std::shared_ptr<ps::core::ServerNode> &server_node, in Initialize()
|
| D | server.cc | 150 server_node_ = std::make_shared<ps::core::ServerNode>(); in InitCluster()
|
| D | iteration.cc | 54 void Iteration::RegisterEventCallback(const std::shared_ptr<ps::core::ServerNode> &server_node) { in RegisterEventCallback()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.h | 99 channelz::ServerNode* channelz_node() const { return channelz_node_.get(); } in channelz_node()
361 RefCountedPtr<channelz::ServerNode> channelz_node_;
|
| D | server.cc | 515 RefCountedPtr<channelz::ServerNode> CreateChannelzNode( in CreateChannelzNode()
517 RefCountedPtr<channelz::ServerNode> channelz_node; in CreateChannelzNode()
524 MakeRefCounted<channelz::ServerNode>(channel_tracer_max_memory); in CreateChannelzNode()
|
| D | call.cc | 486 grpc_core::channelz::ServerNode* channelz_node = in grpc_call_create()
769 grpc_core::channelz::ServerNode* channelz_node = in set_final_status()
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | channelz.cc | 216 grpc_core::channelz::ServerNode* channelz_server = in test_channelz()
277 grpc_core::channelz::ServerNode* channelz_server = in test_channelz_with_channel_trace()
|
| /third_party/mindspore/mindspore/ccsrc/ps/ |
| D | parameter_server.h | 177 std::shared_ptr<core::ServerNode> server_node_;
|
| D | parameter_server.cc | 29 server_node_ = std::make_shared<core::ServerNode>(); in Run()
|
| /third_party/grpc/test/core/channel/ |
| D | channelz_test.cc | 235 void ValidateServer(ServerNode* server, const ValidateChannelDataArgs& args) { in ValidateServer()
522 ServerNode* channelz_server = grpc_server_get_channelz_node(server.server()); in TEST()
|