Home
last modified time | relevance | path

Searched refs:grpc_channel_element (Results 1 – 25 of 43) sorted by relevance

12

/external/grpc-grpc/src/core/lib/channel/
Dchannel_stack.h50 typedef struct grpc_channel_element grpc_channel_element; typedef
106 void (*start_transport_op)(grpc_channel_element* elem, grpc_transport_op* op);
142 grpc_error* (*init_channel_elem)(grpc_channel_element* elem,
146 void (*destroy_channel_elem)(grpc_channel_element* elem);
149 void (*get_channel_info)(grpc_channel_element* elem,
158 struct grpc_channel_element { struct
194 grpc_channel_element* grpc_channel_stack_element(grpc_channel_stack* stack,
197 grpc_channel_element* grpc_channel_stack_last_element(
260 void grpc_channel_next_op(grpc_channel_element* elem, grpc_transport_op* op);
262 void grpc_channel_next_get_info(grpc_channel_element* elem,
[all …]
Dchannel_stack.cc52 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()
229 void grpc_channel_next_get_info(grpc_channel_element* elem, in grpc_channel_next_get_info()
231 grpc_channel_element* next_elem = elem + 1; in grpc_channel_next_get_info()
[all …]
Dconnected_channel.cc140 static void con_start_transport_op(grpc_channel_element* elem, in con_start_transport_op()
180 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
189 static void destroy_channel_elem(grpc_channel_element* elem) { in destroy_channel_elem()
197 static void con_get_channel_info(grpc_channel_element* elem, in con_get_channel_info()
215 grpc_channel_element* elem, void* t) { in bind_transport()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.h44 grpc_channel_element* elem, grpc_core::ChildRefsList* child_subchannels,
48 grpc_channel_element* elem, int try_to_connect);
51 grpc_channel_element* elem);
54 grpc_channel_element* elem, grpc_polling_entity pollent,
Dchannel_connectivity.cc36 grpc_channel_element* client_channel_elem = in grpc_channel_check_connectivity_state()
81 grpc_channel_element* client_channel_elem = grpc_channel_stack_last_element( in delete_state_watcher()
116 grpc_channel_element* client_channel_elem = grpc_channel_stack_last_element( in partly_done()
175 grpc_channel_element* client_channel_elem = in grpc_channel_num_external_connectivity_watchers()
195 grpc_channel_element* client_channel_elem = in grpc_channel_support_connectivity_watcher()
203 grpc_channel_element* client_channel_elem = in grpc_channel_watch_connectivity_state()
/external/grpc-grpc/test/core/channel/
Dchannel_stack_builder_test.cc32 static grpc_error* channel_init_func(grpc_channel_element* elem, in channel_init_func()
42 static void channel_destroy_func(grpc_channel_element* elem) {} in channel_destroy_func()
51 static void channel_func(grpc_channel_element* elem, grpc_transport_op* op) { in channel_func()
61 grpc_channel_element* elem, void* arg) { in set_arg_once_fn()
Dchannel_stack_test.cc30 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()
62 static void channel_func(grpc_channel_element* elem, grpc_transport_op* op) { in channel_func()
92 grpc_channel_element* channel_elem; in test_create_channel_stack()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h239 virtual grpc_error* Init(grpc_channel_element* elem, in Init()
245 virtual void Destroy(grpc_channel_element* elem) {} in Destroy()
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()
Dchannel_filter.cc43 void ChannelData::StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
48 void ChannelData::GetInfo(grpc_channel_element* elem, in GetInfo()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc94 static void lame_get_channel_info(grpc_channel_element* elem, in lame_get_channel_info()
97 static void lame_start_transport_op(grpc_channel_element* elem, in lame_start_transport_op()
133 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
140 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()
166 grpc_channel_element* elem; in grpc_lame_client_channel_create()
Dchannel_ping.cc54 grpc_channel_element* top_elem = in grpc_channel_ping()
Dchannel.cc279 grpc_channel_element* elem = in grpc_channel_get_info()
290 grpc_channel_element* elem = in grpc_channel_reset_connect_backoff()
452 grpc_channel_element* elem; in grpc_channel_destroy()
/external/grpc-grpc/test/core/surface/
Dsecure_channel_create_test.cc37 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()
Dchannel_create_test.cc39 grpc_channel_element* elem = in test_unknown_scheme_target()
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc261 grpc_channel_element* elem = in close_max_idle_channel()
323 grpc_channel_element* elem = in close_max_age_channel()
341 grpc_channel_element* elem = in force_close_max_age_channel()
414 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
502 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc30 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
35 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc89 grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
112 void destroy_channel_elem(grpc_channel_element* elem) { in destroy_channel_elem()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc367 static void StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
382 grpc_error* InitChannelElem(grpc_channel_element* elem, in InitChannelElem()
387 void DestroyChannelElem(grpc_channel_element* elem) {} in DestroyChannelElem()
389 void GetChannelInfo(grpc_channel_element* elem, in GetChannelInfo()
649 static void StartTransportOp(grpc_channel_element* elem, in StartTransportOp()
673 grpc_error* InitChannelElem(grpc_channel_element* elem, in InitChannelElem()
678 void DestroyChannelElem(grpc_channel_element* elem) {} in DestroyChannelElem()
680 void GetChannelInfo(grpc_channel_element* elem, in GetChannelInfo()
/external/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc124 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
130 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dchannel_filter.cc25 grpc_error* CensusChannelData::Init(grpc_channel_element* elem, in Init()
Dchannel_filter.h30 grpc_error* Init(grpc_channel_element* elem,
/external/grpc-grpc/test/cpp/common/
Dchannel_filter_test.cc31 grpc_error* Init(grpc_channel_element* elem, in Init()
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_causes_close.cc230 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
235 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.h31 grpc_error* Init(grpc_channel_element* elem,
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc243 static grpc_error* init_channel_elem(grpc_channel_element* elem, in init_channel_elem()
250 static void destroy_channel_elem(grpc_channel_element* elem) {} in destroy_channel_elem()

12