Home
last modified time | relevance | path

Searched refs:ChannelData (Results 1 – 25 of 30) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/
Dclient_idle_filter.cc127 class ChannelData { class
141 ChannelData(grpc_channel_element* elem, grpc_channel_element_args* args,
143 ~ChannelData() = default;
173 grpc_error* ChannelData::Init(grpc_channel_element* elem, in Init()
176 new (elem->channel_data) ChannelData(elem, args, &error); in Init()
180 void ChannelData::Destroy(grpc_channel_element* elem) { in Destroy()
181 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy()
182 chand->~ChannelData(); in Destroy()
185 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
187 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOp()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dlame_client.cc42 struct ChannelData { struct
43 ChannelData() : state_tracker("lame_channel", GRPC_CHANNEL_SHUTDOWN) {} in ChannelData() function
44 ~ChannelData() { GRPC_ERROR_UNREF(error); } in ~ChannelData() argument
58 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_stream_op_batch()
68 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_op()
110 new (elem->channel_data) ChannelData; in lame_init_channel_elem()
115 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_destroy_channel_elem()
116 chand->~ChannelData(); in lame_destroy_channel_elem()
123 auto chand = static_cast<grpc_core::ChannelData*>(elem->channel_data); in SetLameFilterError()
136 sizeof(grpc_core::ChannelData),
Dserver.cc495 sizeof(Server::ChannelData),
496 Server::ChannelData::InitChannelElement,
497 Server::ChannelData::DestroyChannelElement,
612 ChannelData* chand = static_cast<ChannelData*>( in SetupTransport()
758 for (const ChannelData* chand : channels_) { in GetChannelsLocked()
956 class Server::ChannelData::ConnectivityWatcher
959 explicit ConnectivityWatcher(ChannelData* chand) : chand_(chand) { in ConnectivityWatcher()
977 ChannelData* chand_;
984 Server::ChannelData::~ChannelData() { in ~ChannelData()
1013 void Server::ChannelData::InitTransport(RefCountedPtr<Server> server, in InitTransport()
[all …]
Dserver.h182 class ChannelData {
184 ChannelData() = default;
185 ~ChannelData();
219 absl::optional<std::list<ChannelData*>::iterator> list_position_;
392 std::list<ChannelData*> channels_;
/external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/
DChannelData.java13 public final class ChannelData extends class
19 private ChannelData(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ChannelData() method in ChannelData
22 private ChannelData() { in ChannelData() method in ChannelData
34 private ChannelData( in ChannelData() method in ChannelData
141 io.grpc.channelz.v1.ChannelData.class, io.grpc.channelz.v1.ChannelData.Builder.class); in internalGetFieldAccessorTable()
405 if (!(obj instanceof io.grpc.channelz.v1.ChannelData)) { in equals()
408 io.grpc.channelz.v1.ChannelData other = (io.grpc.channelz.v1.ChannelData) obj; in equals()
473 public static io.grpc.channelz.v1.ChannelData parseFrom( in parseFrom()
478 public static io.grpc.channelz.v1.ChannelData parseFrom( in parseFrom()
484 public static io.grpc.channelz.v1.ChannelData parseFrom( in parseFrom()
[all …]
DChannel.java73 io.grpc.channelz.v1.ChannelData.Builder subBuilder = null; in Channel()
77 data_ = input.readMessage(io.grpc.channelz.v1.ChannelData.parser(), extensionRegistry); in Channel()
180 private io.grpc.channelz.v1.ChannelData data_;
198 public io.grpc.channelz.v1.ChannelData getData() { in getData()
199 return data_ == null ? io.grpc.channelz.v1.ChannelData.getDefaultInstance() : data_; in getData()
1054 private io.grpc.channelz.v1.ChannelData data_ = null;
1056 …io.grpc.channelz.v1.ChannelData, io.grpc.channelz.v1.ChannelData.Builder, io.grpc.channelz.v1.Chan…
1074 public io.grpc.channelz.v1.ChannelData getData() { in getData()
1076 return data_ == null ? io.grpc.channelz.v1.ChannelData.getDefaultInstance() : data_; in getData()
1088 public Builder setData(io.grpc.channelz.v1.ChannelData value) { in setData()
[all …]
DSubchannel.java74 io.grpc.channelz.v1.ChannelData.Builder subBuilder = null; in Subchannel()
78 data_ = input.readMessage(io.grpc.channelz.v1.ChannelData.parser(), extensionRegistry); in Subchannel()
181 private io.grpc.channelz.v1.ChannelData data_;
199 public io.grpc.channelz.v1.ChannelData getData() { in getData()
200 return data_ == null ? io.grpc.channelz.v1.ChannelData.getDefaultInstance() : data_; in getData()
1056 private io.grpc.channelz.v1.ChannelData data_ = null;
1058 …io.grpc.channelz.v1.ChannelData, io.grpc.channelz.v1.ChannelData.Builder, io.grpc.channelz.v1.Chan…
1076 public io.grpc.channelz.v1.ChannelData getData() { in getData()
1078 return data_ == null ? io.grpc.channelz.v1.ChannelData.getDefaultInstance() : data_; in getData()
1090 public Builder setData(io.grpc.channelz.v1.ChannelData value) { in setData()
[all …]
DChannelOrBuilder.java50 io.grpc.channelz.v1.ChannelData getData(); in getData()
DSubchannelOrBuilder.java50 io.grpc.channelz.v1.ChannelData getData(); in getData()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc47 class ChannelData { class
49 explicit ChannelData(const grpc_channel_element_args* args) in ChannelData() function in grpc_core::__anone4066a570111::ChannelData
60 CallData(const grpc_call_element_args& args, const ChannelData* chand) in CallData()
361 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressInitCallElem()
375 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressInitChannelElem()
376 new (chand) ChannelData(args); in DecompressInitChannelElem()
381 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressDestroyChannelElem()
382 chand->~ChannelData(); in DecompressDestroyChannelElem()
394 sizeof(ChannelData),
Dmessage_compress_filter.cc47 class ChannelData { class
49 explicit ChannelData(grpc_channel_element_args* args) { in ChannelData() function in __anon1526ae8e0111::ChannelData
107 ChannelData* channeld = static_cast<ChannelData*>(elem->channel_data); in CallData()
192 grpc_metadata_batch* initial_metadata, ChannelData* channeld) { in FindCompressionAlgorithm()
237 ChannelData* channeld = static_cast<ChannelData*>(elem->channel_data); in ProcessSendInitialMetadata()
523 new (elem->channel_data) ChannelData(args); in CompressInitChannelElem()
529 ChannelData* channeld = static_cast<ChannelData*>(elem->channel_data); in CompressDestroyChannelElem()
530 channeld->~ChannelData(); in CompressDestroyChannelElem()
542 sizeof(ChannelData),
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc126 class ChannelData { class
227 ExternalConnectivityWatcher(ChannelData* chand, grpc_polling_entity pollent,
235 static void RemoveWatcherFromExternalWatchersMap(ChannelData* chand,
250 ChannelData* chand_;
261 explicit ResolverResultHandler(ChannelData* chand) : chand_(chand) { in ResolverResultHandler()
281 ChannelData* chand_;
284 ChannelData(grpc_channel_element_args* args, grpc_error** error);
285 ~ChannelData();
436 CallData(grpc_call_element* elem, const ChannelData& chand,
514 ChannelData::ResolverQueuedCall resolver_queued_call_;
[all …]
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc49 struct ChannelData { struct
62 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in fill_metadata()
153 sizeof(grpc_core::ChannelData),
175 auto chand = static_cast<grpc_core::ChannelData*>(elem->channel_data); in grpc_lame_client_channel_create()
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.cc42 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
47 void ChannelData::GetInfo(grpc_channel_element* elem, in GetInfo()
Dchannel_filter.h231 class ChannelData {
233 ChannelData() {} in ChannelData() function
234 virtual ~ChannelData() {} in ~ChannelData()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.cc43 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
48 void ChannelData::GetInfo(grpc_channel_element* elem, in GetInfo()
Dchannel_filter.h231 class ChannelData {
233 ChannelData() {} in ChannelData() function
234 virtual ~ChannelData() {} in ~ChannelData()
/external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dchannel_filter.h28 class CensusChannelData : public ChannelData {
/external/grpc-grpc/src/cpp/ext/filters/census/
Dchannel_filter.h28 class CensusChannelData : public ChannelData {
/external/grpc-grpc/test/cpp/common/
Dchannel_filter_test.cc27 class MyChannelData : public ChannelData {
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzProtoUtilTest.java54 import io.grpc.channelz.v1.ChannelData;
102 private final ChannelData channelData = ChannelData
123 private final ChannelData subchannelData = ChannelData
860 ChannelData protoStats = channelData.toBuilder().setTrace(channelTrace).build(); in channelTrace_withoutEvents()
903 ChannelData protoStats = channelData in channelTrace_withEvents()
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.h29 class ServerLoadReportingChannelData : public ChannelData {
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.h31 class ServerLoadReportingChannelData : public ChannelData {
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzProtoUtil.java46 import io.grpc.channelz.v1.ChannelData;
355 static ChannelData extractChannelData(InternalChannelz.ChannelStats stats) { in extractChannelData()
356 ChannelData.Builder builder = ChannelData.newBuilder(); in extractChannelData()
/external/grpc-grpc/test/cpp/end2end/
Dfilter_end2end_test.cc100 class ChannelDataImpl : public ChannelData {

12