| /third_party/grpc/src/core/lib/channel/ |
| D | channel_stack.h | 62 typedef struct grpc_channel_element grpc_channel_element; typedef
115 void (*start_transport_op)(grpc_channel_element* elem, grpc_transport_op* op);
151 grpc_error* (*init_channel_elem)(grpc_channel_element* elem,
155 void (*destroy_channel_elem)(grpc_channel_element* elem);
158 void (*get_channel_info)(grpc_channel_element* elem,
166 struct grpc_channel_element { struct
202 grpc_channel_element* grpc_channel_stack_element(grpc_channel_stack* stack,
205 grpc_channel_element* grpc_channel_stack_last_element(
280 void grpc_channel_next_op(grpc_channel_element* elem, grpc_transport_op* op);
282 void grpc_channel_next_get_info(grpc_channel_element* elem,
[all …]
|
| D | channel_stack.cc | 52 sizeof(grpc_channel_element)); in grpc_channel_stack_size()
67 ((grpc_channel_element*)((char*)(stk) + GPR_ROUND_UP_TO_ALIGNMENT_SIZE( \
74 grpc_channel_element* grpc_channel_stack_element( in grpc_channel_stack_element()
79 grpc_channel_element* grpc_channel_stack_last_element( in grpc_channel_stack_last_element()
97 grpc_channel_element* elems; in grpc_channel_stack_init()
108 sizeof(grpc_channel_element)); in grpc_channel_stack_init()
142 grpc_channel_element* channel_elems = CHANNEL_ELEMS_FROM_STACK(stack); in grpc_channel_stack_destroy()
156 grpc_channel_element* channel_elems = CHANNEL_ELEMS_FROM_STACK(channel_stack); in grpc_call_stack_init()
230 void grpc_channel_next_get_info(grpc_channel_element* elem, in grpc_channel_next_get_info()
232 grpc_channel_element* next_elem = elem + 1; in grpc_channel_next_get_info()
[all …]
|
| D | connected_channel.cc | 142 static void connected_channel_start_transport_op(grpc_channel_element* elem, in connected_channel_start_transport_op()
183 grpc_channel_element* elem, grpc_channel_element_args* args) { in connected_channel_init_channel_elem()
191 static void connected_channel_destroy_channel_elem(grpc_channel_element* elem) { in connected_channel_destroy_channel_elem()
200 grpc_channel_element* /*elem*/, const grpc_channel_info* /*channel_info*/) { in connected_channel_get_channel_info() argument
218 grpc_channel_element* elem, void* t) { in bind_transport()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.h | 42 grpc_channel_element* elem, int try_to_connect);
45 grpc_channel_element* elem);
57 grpc_channel_element* elem, grpc_polling_entity pollent,
69 grpc_channel_element* elem, grpc_connectivity_state initial_state,
73 grpc_channel_element* elem,
|
| D | channel_connectivity.cc | 36 grpc_channel_element* client_channel_elem = in grpc_channel_check_connectivity_state()
82 grpc_channel_element* client_channel_elem = grpc_channel_stack_last_element( in delete_state_watcher()
123 grpc_channel_element* client_channel_elem = grpc_channel_stack_last_element( in partly_done()
190 grpc_channel_element* client_channel_elem = in grpc_channel_num_external_connectivity_watchers()
210 grpc_channel_element* client_channel_elem = in grpc_channel_support_connectivity_watcher()
218 grpc_channel_element* client_channel_elem = in grpc_channel_watch_connectivity_state()
|
| D | service_config_channel_arg_filter.cc | 93 grpc_channel_element* elem, grpc_channel_element_args* args) { in ServiceConfigChannelArgInitChannelElem()
100 void ServiceConfigChannelArgDestroyChannelElem(grpc_channel_element* elem) { in ServiceConfigChannelArgDestroyChannelElem()
|
| /third_party/grpc/src/core/ext/filters/client_idle/ |
| D | client_idle_filter.cc | 129 static grpc_error* Init(grpc_channel_element* elem,
131 static void Destroy(grpc_channel_element* elem);
133 static void StartTransportOp(grpc_channel_element* elem,
141 ChannelData(grpc_channel_element* elem, grpc_channel_element_args* args,
152 grpc_channel_element* elem_;
173 grpc_error* ChannelData::Init(grpc_channel_element* elem, in Init()
180 void ChannelData::Destroy(grpc_channel_element* elem) { in Destroy()
185 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
284 ChannelData::ChannelData(grpc_channel_element* elem, in ChannelData()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | lame_client.cc | 63 static void lame_get_channel_info(grpc_channel_element* /*elem*/, in lame_get_channel_info() argument
66 static void lame_start_transport_op(grpc_channel_element* elem, in lame_start_transport_op()
106 static grpc_error* lame_init_channel_elem(grpc_channel_element* elem, in lame_init_channel_elem()
114 static void lame_destroy_channel_elem(grpc_channel_element* elem) { in lame_destroy_channel_elem()
121 void SetLameFilterError(grpc_channel_element* elem, grpc_error* error) { in SetLameFilterError()
149 grpc_channel_element* elem; in grpc_lame_client_channel_create()
|
| D | lame_client.h | 29 void SetLameFilterError(grpc_channel_element* elem, grpc_error* error);
|
| D | channel_ping.cc | 53 grpc_channel_element* top_elem = in grpc_channel_ping()
|
| /third_party/grpc/src/cpp/common/ |
| D | channel_filter.h | 239 virtual grpc_error* Init(grpc_channel_element* /*elem*/, in Init() argument
245 virtual void Destroy(grpc_channel_element* /*elem*/) {} in Destroy() argument
247 virtual void StartTransportOp(grpc_channel_element* elem, TransportOp* op);
249 virtual void GetInfo(grpc_channel_element* elem,
291 static grpc_error* InitChannelElement(grpc_channel_element* elem, in InitChannelElement()
298 static void DestroyChannelElement(grpc_channel_element* elem) { in DestroyChannelElement()
305 static void StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
313 static void GetChannelInfo(grpc_channel_element* elem, in GetChannelInfo()
|
| D | channel_filter.cc | 42 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
47 void ChannelData::GetInfo(grpc_channel_element* elem, in GetInfo()
|
| /third_party/grpc/test/core/channel/ |
| D | channel_stack_test.cc | 30 static grpc_error* channel_init_func(grpc_channel_element* elem, in channel_init_func()
49 static void channel_destroy_func(grpc_channel_element* /*elem*/) {} in channel_destroy_func() argument
62 static void channel_func(grpc_channel_element* elem, in channel_func()
93 grpc_channel_element* channel_elem; in test_create_channel_stack()
|
| D | channel_stack_builder_test.cc | 32 static grpc_error* channel_init_func(grpc_channel_element* /*elem*/, in channel_init_func() argument
42 static void channel_destroy_func(grpc_channel_element* /*elem*/) {} in channel_destroy_func() argument
51 grpc_channel_element* /*elem*/, void* arg) { in set_arg_once_fn() argument
|
| /third_party/grpc/test/core/surface/ |
| D | secure_channel_create_test.cc | 37 grpc_channel_element* elem = in test_unknown_scheme_target()
55 grpc_channel_element* elem = in test_security_connector_already_in_arg()
65 grpc_channel_element* elem = in test_null_creds()
|
| D | channel_create_test.cc | 39 grpc_channel_element* elem = in test_unknown_scheme_target()
|
| /third_party/grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 305 grpc_channel_element* elem = in close_max_idle_channel()
368 grpc_channel_element* elem = in close_max_age_channel()
387 grpc_channel_element* elem = in force_close_max_age_channel()
431 static grpc_error* max_age_init_channel_elem(grpc_channel_element* elem, in max_age_init_channel_elem()
517 static void max_age_destroy_channel_elem(grpc_channel_element* elem) { in max_age_destroy_channel_elem()
|
| /third_party/grpc/ |
| D | libgrpc.map | 177 "grpc_channel_next_op(grpc_channel_element*, grpc_transport_op*)";
178 "grpc_channel_next_get_info(grpc_channel_element*, grpc_channel_info const*)";
183 …ilder*, grpc_channel_filter const*, void (*)(grpc_channel_stack*, grpc_channel_element*, void*), v…
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 351 static void StartTransportOp(grpc_channel_element* /*elem*/, in StartTransportOp() argument
366 grpc_error* InitChannelElem(grpc_channel_element* /*elem*/, in InitChannelElem() argument
371 void DestroyChannelElem(grpc_channel_element* /*elem*/) {} in DestroyChannelElem() argument
373 void GetChannelInfo(grpc_channel_element* /*elem*/, in GetChannelInfo() argument
636 static void StartTransportOp(grpc_channel_element* /*elem*/, in StartTransportOp() argument
660 grpc_error* InitChannelElem(grpc_channel_element* /*elem*/, in InitChannelElem() argument
665 void DestroyChannelElem(grpc_channel_element* /*elem*/) {} in DestroyChannelElem() argument
667 void GetChannelInfo(grpc_channel_element* /*elem*/, in GetChannelInfo() argument
|
| /third_party/grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 89 grpc_channel_element* elem, grpc_channel_element_args* args) { in client_authority_init_channel_elem()
113 void client_authority_destroy_channel_elem(grpc_channel_element* elem) { in client_authority_destroy_channel_elem()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 33 static grpc_error* clr_init_channel_elem(grpc_channel_element* /*elem*/, in clr_init_channel_elem() argument
38 static void clr_destroy_channel_elem(grpc_channel_element* /*elem*/) {} in clr_destroy_channel_elem() argument
|
| /third_party/grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 126 grpc_channel_element* /*elem*/, grpc_channel_element_args* /*args*/) { in cronet_compression_init_channel_elem() argument
132 grpc_channel_element* /*elem*/) {} in cronet_compression_destroy_channel_elem() argument
|
| /third_party/grpc/src/cpp/ext/filters/census/ |
| D | channel_filter.cc | 25 grpc_error* CensusChannelData::Init(grpc_channel_element* /*elem*/, in Init() argument
|
| D | channel_filter.h | 30 grpc_error* Init(grpc_channel_element* elem,
|
| /third_party/grpc/test/cpp/common/ |
| D | channel_filter_test.cc | 31 grpc_error* Init(grpc_channel_element* /*elem*/, in Init() argument
|