Home
last modified time | relevance | path

Searched refs:channel_stack (Results 1 – 25 of 48) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc54 grpc_channel_stack* channel_stack; member
187 GRPC_CHANNEL_STACK_REF(chand->channel_stack, in decrease_call_count()
215 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_idle_timer_after_init()
224 GRPC_CHANNEL_STACK_REF(chand_->channel_stack, "max_age conn_watch"); in ConnectivityWatcher()
228 GRPC_CHANNEL_STACK_UNREF(chand_->channel_stack, "max_age conn_watch"); in ~ConnectivityWatcher()
265 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_timer"); in start_max_age_timer_after_init()
273 grpc_channel_next_op(grpc_channel_stack_element(chand->channel_stack, 0), op); in start_max_age_timer_after_init()
274 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_timer_after_init()
283 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_grace_timer"); in start_max_age_grace_timer_after_goaway_op()
291 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_grace_timer_after_goaway_op()
[all …]
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc51 grpc_channel_stack* channel_stack; member
188 GRPC_CHANNEL_STACK_REF(chand->channel_stack, in decrease_call_count()
216 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_idle_timer_after_init()
224 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_timer"); in start_max_age_timer_after_init()
232 grpc_channel_next_op(grpc_channel_stack_element(chand->channel_stack, 0), op); in start_max_age_timer_after_init()
233 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_timer_after_init()
242 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_grace_timer"); in start_max_age_grace_timer_after_goaway_op()
250 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_grace_timer_after_goaway_op()
262 grpc_channel_stack_element(chand->channel_stack, 0); in close_max_idle_channel()
287 GRPC_CHANNEL_STACK_REF(chand->channel_stack, in max_idle_timer_cb()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Ddynamic_filters.cc40 : channel_stack_(std::move(args.channel_stack)) { in Call()
100 RefCountedPtr<DynamicFilters> channel_stack = std::move(self->channel_stack_); in Destroy() local
127 grpc_channel_stack* channel_stack = static_cast<grpc_channel_stack*>(arg); in DestroyChannelStack() local
128 grpc_channel_stack_destroy(channel_stack); in DestroyChannelStack()
129 gpr_free(channel_stack); in DestroyChannelStack()
138 grpc_channel_stack* channel_stack = in CreateChannelStack() local
142 /*initial_refs=*/1, DestroyChannelStack, channel_stack, filters.data(), in CreateChannelStack()
144 channel_stack); in CreateChannelStack()
148 grpc_channel_stack_destroy(channel_stack); in CreateChannelStack()
149 gpr_free(channel_stack); in CreateChannelStack()
[all …]
Ddynamic_filters.h39 RefCountedPtr<DynamicFilters> channel_stack; member
86 explicit DynamicFilters(grpc_channel_stack* channel_stack) in DynamicFilters() argument
87 : channel_stack_(channel_stack) {} in DynamicFilters()
Dsubchannel.h76 grpc_channel_stack* channel_stack, const grpc_channel_args* args,
85 grpc_channel_stack* channel_stack() const { return channel_stack_; } in channel_stack() function
Dsubchannel.cc88 grpc_channel_stack* channel_stack, const grpc_channel_args* args, in ConnectedSubchannel() argument
94 channel_stack_(channel_stack), in ConnectedSubchannel()
156 *error = grpc_call_stack_init(connected_subchannel_->channel_stack(), 1, in SubchannelCall()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dchannel_stack.h69 grpc_channel_stack* channel_stack; member
225 grpc_error* grpc_call_stack_init(grpc_channel_stack* channel_stack,
239 #define GRPC_CHANNEL_STACK_REF(channel_stack, reason) \ argument
240 grpc_stream_ref(&(channel_stack)->refcount, reason)
241 #define GRPC_CHANNEL_STACK_UNREF(channel_stack, reason) \ argument
242 grpc_stream_unref(&(channel_stack)->refcount, reason)
254 #define GRPC_CHANNEL_STACK_REF(channel_stack, reason) \ argument
256 grpc_stream_ref(&(channel_stack)->refcount); \
259 #define GRPC_CHANNEL_STACK_UNREF(channel_stack, reason) \ argument
261 grpc_stream_unref(&(channel_stack)->refcount); \
Dchannel_stack.cc75 grpc_channel_stack* channel_stack, size_t index) { in grpc_channel_stack_element() argument
76 return CHANNEL_ELEMS_FROM_STACK(channel_stack) + index; in grpc_channel_stack_element()
80 grpc_channel_stack* channel_stack) { in grpc_channel_stack_last_element() argument
81 return grpc_channel_stack_element(channel_stack, channel_stack->count - 1); in grpc_channel_stack_last_element()
113 args.channel_stack = stack; in grpc_channel_stack_init()
152 grpc_error* grpc_call_stack_init(grpc_channel_stack* channel_stack, in grpc_call_stack_init() argument
156 grpc_channel_element* channel_elems = CHANNEL_ELEMS_FROM_STACK(channel_stack); in grpc_call_stack_init()
157 size_t count = channel_stack->count; in grpc_call_stack_init()
Dchannel_stack_builder.cc294 grpc_channel_stack* channel_stack = reinterpret_cast<grpc_channel_stack*>( in grpc_channel_stack_builder_finish() local
300 channel_stack); in grpc_channel_stack_builder_finish()
303 grpc_channel_stack_destroy(channel_stack); in grpc_channel_stack_builder_finish()
312 p->init(channel_stack, grpc_channel_stack_element(channel_stack, i), in grpc_channel_stack_builder_finish()
Dconnected_channel.cc217 static void bind_transport(grpc_channel_stack* channel_stack, in bind_transport() argument
230 channel_stack->call_stack_size += in bind_transport()
Dchannel_stack_builder.h109 grpc_channel_stack* channel_stack, grpc_channel_element* elem, void* arg);
/external/grpc-grpc/src/core/lib/channel/
Dchannel_stack.h57 grpc_channel_stack* channel_stack; member
217 grpc_error* grpc_call_stack_init(grpc_channel_stack* channel_stack,
231 #define GRPC_CHANNEL_STACK_REF(channel_stack, reason) \ argument
232 grpc_stream_ref(&(channel_stack)->refcount, reason)
233 #define GRPC_CHANNEL_STACK_UNREF(channel_stack, reason) \ argument
234 grpc_stream_unref(&(channel_stack)->refcount, reason)
240 #define GRPC_CHANNEL_STACK_REF(channel_stack, reason) \ argument
241 grpc_stream_ref(&(channel_stack)->refcount)
242 #define GRPC_CHANNEL_STACK_UNREF(channel_stack, reason) \ argument
243 grpc_stream_unref(&(channel_stack)->refcount)
Dchannel_stack.cc75 grpc_channel_stack* channel_stack, size_t index) { in grpc_channel_stack_element() argument
76 return CHANNEL_ELEMS_FROM_STACK(channel_stack) + index; in grpc_channel_stack_element()
80 grpc_channel_stack* channel_stack) { in grpc_channel_stack_last_element() argument
81 return grpc_channel_stack_element(channel_stack, channel_stack->count - 1); in grpc_channel_stack_last_element()
113 args.channel_stack = stack; in grpc_channel_stack_init()
152 grpc_error* grpc_call_stack_init(grpc_channel_stack* channel_stack, in grpc_call_stack_init() argument
156 grpc_channel_element* channel_elems = CHANNEL_ELEMS_FROM_STACK(channel_stack); in grpc_call_stack_init()
157 size_t count = channel_stack->count; in grpc_call_stack_init()
Dchannel_stack_builder.cc282 grpc_channel_stack* channel_stack = reinterpret_cast<grpc_channel_stack*>( in grpc_channel_stack_builder_finish() local
288 channel_stack); in grpc_channel_stack_builder_finish()
291 grpc_channel_stack_destroy(channel_stack); in grpc_channel_stack_builder_finish()
300 p->init(channel_stack, grpc_channel_stack_element(channel_stack, i), in grpc_channel_stack_builder_finish()
Dconnected_channel.cc214 static void bind_transport(grpc_channel_stack* channel_stack, in bind_transport() argument
227 channel_stack->call_stack_size += in bind_transport()
Dchannel_stack_builder.h101 grpc_channel_stack* channel_stack, grpc_channel_element* elem, void* arg);
/external/grpc-grpc/test/core/channel/
Dchannel_stack_test.cc90 grpc_channel_stack* channel_stack; in test_create_channel_stack() local
108 channel_stack = static_cast<grpc_channel_stack*>( in test_create_channel_stack()
110 grpc_channel_stack_init(1, free_channel, channel_stack, &filters, 1, in test_create_channel_stack()
111 &chan_args, nullptr, "test", channel_stack); in test_create_channel_stack()
112 GPR_ASSERT(channel_stack->count == 1); in test_create_channel_stack()
113 channel_elem = grpc_channel_stack_element(channel_stack, 0); in test_create_channel_stack()
118 static_cast<grpc_call_stack*>(gpr_malloc(channel_stack->call_stack_size)); in test_create_channel_stack()
130 grpc_call_stack_init(channel_stack, 1, free_call, call_stack, &args); in test_create_channel_stack()
144 GRPC_CHANNEL_STACK_UNREF(channel_stack, "done"); in test_create_channel_stack()
Dchannel_stack_builder_test.cc60 void set_arg_once_fn(grpc_channel_stack* channel_stack, in set_arg_once_fn() argument
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.h88 explicit ConnectedSubchannel(grpc_channel_stack* channel_stack,
92 grpc_channel_stack* channel_stack() { return channel_stack_; } in channel_stack() function
Dsubchannel.cc761 grpc_channel_stack* chanstk = subchannel_call->connection->channel_stack(); in grpc_connected_subchannel_call_get_parent_data()
813 grpc_channel_stack* channel_stack, in ConnectedSubchannel() argument
816 channel_stack_(channel_stack), in ConnectedSubchannel()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc528 grpc_channel_stack* channel_stack = in BM_IsolatedFilter() local
532 grpc_channel_stack_init(1, FilterDestroy, channel_stack, &filters[0], in BM_IsolatedFilter()
537 "CHANNEL", channel_stack))); in BM_IsolatedFilter()
540 static_cast<grpc_call_stack*>(gpr_zalloc(channel_stack->call_stack_size)); in BM_IsolatedFilter()
558 grpc_call_stack_init(channel_stack, 1, DoNothing, nullptr, &call_args)); in BM_IsolatedFilter()
570 grpc_channel_stack_destroy(channel_stack); in BM_IsolatedFilter()
572 gpr_free(channel_stack); in BM_IsolatedFilter()
/external/grpc-grpc/doc/
Dc-style-guide.md41 `src/core/lib/channel/channel_stack.h` →
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/
Dclient_idle_filter.cc288 channel_stack_(args->channel_stack), in ChannelData()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc297 grpc_channel_stack* channel_stack = in grpc_call_create() local
305 channel_stack->call_stack_size)); in grpc_call_create()
398 add_init_error(&error, grpc_call_stack_init(channel_stack, 1, destroy_call, in grpc_call_create()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcall.cc347 grpc_channel_stack* channel_stack = in grpc_call_create() local
353 channel_stack->call_stack_size; in grpc_call_create()
437 add_init_error(&error, grpc_call_stack_init(channel_stack, 1, destroy_call, in grpc_call_create()

12