Home
last modified time | relevance | path

Searched refs:channelz (Results 1 – 25 of 65) sorted by relevance

123

/third_party/grpc/src/cpp/server/channelz/
Dchannelz_service.h29 class ChannelzService final : public channelz::v1::Channelz::Service {
33 ServerContext* unused, const channelz::v1::GetTopChannelsRequest* request,
34 channelz::v1::GetTopChannelsResponse* response) override;
37 const channelz::v1::GetServersRequest* request,
38 channelz::v1::GetServersResponse* response) override;
41 const channelz::v1::GetServerRequest* request,
42 channelz::v1::GetServerResponse* response) override;
46 const channelz::v1::GetServerSocketsRequest* request,
47 channelz::v1::GetServerSocketsResponse* response) override;
50 const channelz::v1::GetChannelRequest* request,
[all …]
Dchannelz_service.cc41 const channelz::v1::GetTopChannelsRequest* request, in GetTopChannels()
42 channelz::v1::GetTopChannelsResponse* response) { in GetTopChannels()
57 ServerContext* /*unused*/, const channelz::v1::GetServersRequest* request, in GetServers()
58 channelz::v1::GetServersResponse* response) { in GetServers()
73 const channelz::v1::GetServerRequest* request, in GetServer()
74 channelz::v1::GetServerResponse* response) { in GetServer()
90 const channelz::v1::GetServerSocketsRequest* request, in GetServerSockets()
91 channelz::v1::GetServerSocketsResponse* response) { in GetServerSockets()
107 ServerContext* /*unused*/, const channelz::v1::GetChannelRequest* request, in GetChannel()
108 channelz::v1::GetChannelResponse* response) { in GetChannel()
[all …]
Dchannelz_service_plugin.cc29 namespace channelz { namespace
74 &grpc::channelz::experimental::CreateChannelzServicePlugin); in InitChannelzService()
/third_party/grpc/src/core/lib/channel/
Dchannelz_registry.cc39 namespace channelz { namespace
185 grpc_core::channelz::ChannelzRegistry::GetTopChannels(start_channel_id) in grpc_channelz_get_top_channels()
191 grpc_core::channelz::ChannelzRegistry::GetServers(start_server_id) in grpc_channelz_get_servers()
196 grpc_core::RefCountedPtr<grpc_core::channelz::BaseNode> server_node = in grpc_channelz_get_server()
197 grpc_core::channelz::ChannelzRegistry::Get(server_id); in grpc_channelz_get_server()
200 grpc_core::channelz::BaseNode::EntityType::kServer) { in grpc_channelz_get_server()
213 grpc_core::RefCountedPtr<grpc_core::channelz::BaseNode> base_node = in grpc_channelz_get_server_sockets()
214 grpc_core::channelz::ChannelzRegistry::Get(server_id); in grpc_channelz_get_server_sockets()
216 base_node->type() != grpc_core::channelz::BaseNode::EntityType::kServer || in grpc_channelz_get_server_sockets()
222 grpc_core::channelz::ServerNode* server_node = in grpc_channelz_get_server_sockets()
[all …]
Dchannelz_registry.h34 namespace channelz {
/third_party/grpc/test/cpp/util/
Dchannel_trace_proto_helper.cc78 VaidateProtoJsonTranslation<grpc::channelz::v1::ChannelTrace>(json_c_str); in ValidateChannelTraceProtoJsonTranslation()
82 VaidateProtoJsonTranslation<grpc::channelz::v1::Channel>(json_c_str); in ValidateChannelProtoJsonTranslation()
87 VaidateProtoJsonTranslation<grpc::channelz::v1::GetTopChannelsResponse>( in ValidateGetTopChannelsResponseProtoJsonTranslation()
92 VaidateProtoJsonTranslation<grpc::channelz::v1::GetChannelResponse>( in ValidateGetChannelResponseProtoJsonTranslation()
97 VaidateProtoJsonTranslation<grpc::channelz::v1::GetServerResponse>( in ValidateGetServerResponseProtoJsonTranslation()
102 VaidateProtoJsonTranslation<grpc::channelz::v1::Subchannel>(json_c_str); in ValidateSubchannelProtoJsonTranslation()
106 VaidateProtoJsonTranslation<grpc::channelz::v1::Server>(json_c_str); in ValidateServerProtoJsonTranslation()
110 VaidateProtoJsonTranslation<grpc::channelz::v1::GetServersResponse>( in ValidateGetServersResponseProtoJsonTranslation()
/third_party/grpc/src/proto/grpc/channelz/
DBUILD21 name = "channelz",
27 srcs = ["channelz.proto"],
34 srcs = ["channelz.proto"],
46 "channelz.proto",
/third_party/grpc/test/cpp/end2end/
Dchannelz_service_test.cc41 using grpc::channelz::v1::GetChannelRequest;
42 using grpc::channelz::v1::GetChannelResponse;
43 using grpc::channelz::v1::GetServerRequest;
44 using grpc::channelz::v1::GetServerResponse;
45 using grpc::channelz::v1::GetServerSocketsRequest;
46 using grpc::channelz::v1::GetServerSocketsResponse;
47 using grpc::channelz::v1::GetServersRequest;
48 using grpc::channelz::v1::GetServersResponse;
49 using grpc::channelz::v1::GetSocketRequest;
50 using grpc::channelz::v1::GetSocketResponse;
[all …]
/third_party/grpc/doc/python/sphinx/
Dgrpc_channelz.rst7 Design Document `gRPC Channelz <https://github.com/grpc/proposal/blob/master/A14-channelz.md>`_
12 .. automodule:: grpc_channelz.v1.channelz
/third_party/grpc/src/core/lib/surface/
Dchannel.cc125 channel->channelz_node = static_cast<grpc_core::channelz::ChannelNode*>( in grpc_channel_create_with_builder()
173 grpc_core::channelz::ChannelNode* node = in channelz_node_copy()
174 static_cast<grpc_core::channelz::ChannelNode*>(p); in channelz_node_copy()
179 grpc_core::channelz::ChannelNode* node = in channelz_node_destroy()
180 static_cast<grpc_core::channelz::ChannelNode*>(p); in channelz_node_destroy()
202 grpc_core::RefCountedPtr<grpc_core::channelz::ChannelNode> channelz_node = in CreateChannelzNode()
203 grpc_core::MakeRefCounted<grpc_core::channelz::ChannelNode>( in CreateChannelzNode()
207 grpc_core::channelz::ChannelTrace::Severity::Info, in CreateChannelzNode()
504 grpc_core::channelz::ChannelTrace::Severity::Info, in destroy_channel()
Dchannel.h64 grpc_core::channelz::ChannelNode* grpc_channel_get_channelz_node(
118 grpc_core::RefCountedPtr<grpc_core::channelz::ChannelNode> channelz_node;
134 inline grpc_core::channelz::ChannelNode* grpc_channel_get_channelz_node( in grpc_channel_get_channelz_node()
Dserver.h83 virtual channelz::ListenSocketNode* channelz_listen_socket_node() const = 0;
99 channelz::ServerNode* channelz_node() const { return channelz_node_.get(); } in channelz_node()
130 const RefCountedPtr<channelz::SocketNode>& socket_node,
361 RefCountedPtr<channelz::ServerNode> channelz_node_;
Dinit.cc145 grpc_core::channelz::ChannelzRegistry::Init(); in grpc_init()
191 grpc_core::channelz::ChannelzRegistry::Shutdown(); in grpc_shutdown_internal_locked()
/third_party/grpc/src/python/grpcio_channelz/grpc_channelz/v1/
DBUILD.bazel7 deps = ["//src/proto/grpc/channelz:channelz_proto_descriptors"],
12 srcs = ["//src/proto/grpc/channelz:channelz_proto_descriptors"],
/third_party/grpc/src/core/ext/filters/client_channel/
Dsubchannel.h77 RefCountedPtr<channelz::SubchannelNode> channelz_subchannel);
87 channelz::SubchannelNode* channelz_subchannel() const { in channelz_subchannel()
98 RefCountedPtr<channelz::SubchannelNode> channelz_subchannel_;
245 channelz::SubchannelNode* channelz_node();
428 RefCountedPtr<channelz::SubchannelNode> channelz_node_;
Dsubchannel.cc89 RefCountedPtr<channelz::SubchannelNode> channelz_subchannel) in ConnectedSubchannel()
277 channelz::SubchannelNode* channelz_subchannel = in RecvTrailingMetadataReady()
689 channelz_node_ = MakeRefCounted<channelz::SubchannelNode>( in Subchannel()
692 channelz::ChannelTrace::Severity::Info, in Subchannel()
700 channelz::ChannelTrace::Severity::Info, in ~Subchannel()
820 channelz::SubchannelNode* Subchannel::channelz_node() { in channelz_node()
963 channelz::ChannelTrace::Severity::Info, in SetConnectivityStateLocked()
1102 RefCountedPtr<channelz::SocketNode> socket = in PublishTransportLocked()
Dconnector.h52 RefCountedPtr<channelz::SocketNode> socket_node;
Dclient_channel_channelz.h32 namespace channelz {
/third_party/grpc/test/core/end2end/tests/
Dchannelz.cc212 grpc_core::channelz::ChannelNode* channelz_channel = in test_channelz()
216 grpc_core::channelz::ServerNode* channelz_server = in test_channelz()
273 grpc_core::channelz::ChannelNode* channelz_channel = in test_channelz_with_channel_trace()
277 grpc_core::channelz::ServerNode* channelz_server = in test_channelz_with_channel_trace()
309 grpc_core::channelz::ChannelNode* channelz_channel = in test_channelz_disabled()
319 void channelz(grpc_end2end_test_config config) { in channelz() function
/third_party/grpc/examples/python/debug/
Ddebug_server.py26 from grpc_channelz.v1 import channelz
55 channelz.add_channelz_servicer(server)
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h50 RefCountedPtr<channelz::SubchannelNode> channelz_node,
156 RefCountedPtr<channelz::SubchannelNode> channelz_node_;
/third_party/grpc/include/grpcpp/ext/
Dchannelz_service_plugin.h29 namespace channelz {
Dchannelz_service_plugin_impl.h29 namespace channelz {
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.h41 grpc_core::RefCountedPtr<grpc_core::channelz::SocketNode>
/third_party/grpc/src/core/ext/xds/
Dxds_client.h106 void AddChannelzLinkage(channelz::ChannelNode* parent_channelz_node);
107 void RemoveChannelzLinkage(channelz::ChannelNode* parent_channelz_node);

123