Home
last modified time | relevance | path

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

12

/third_party/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()
266 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_timer"); in start_max_age_timer_after_init()
275 grpc_channel_next_op(grpc_channel_stack_element(chand->channel_stack, 0), op); in start_max_age_timer_after_init()
276 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_timer_after_init()
286 GRPC_CHANNEL_STACK_REF(chand->channel_stack, "max_age max_age_grace_timer"); in start_max_age_grace_timer_after_goaway_op()
294 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack, in start_max_age_grace_timer_after_goaway_op()
[all …]
/third_party/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()
Dclient_channel.cc1875 owning_stack_(args->channel_stack), in ChannelData()
3168 DynamicFilters* channel_stack = args.channel_stack.get(); in CreateDynamicCall() local
3173 chand, this, channel_stack); in CreateDynamicCall()
3175 dynamic_call_ = channel_stack->CreateCall(std::move(args), &error); in CreateDynamicCall()
/third_party/grpc/test/core/channel/
Dchannel_stack_test.cc91 grpc_channel_stack* channel_stack; in test_create_channel_stack() local
109 channel_stack = static_cast<grpc_channel_stack*>( in test_create_channel_stack()
111 grpc_channel_stack_init(1, free_channel, channel_stack, &filters, 1, in test_create_channel_stack()
112 &chan_args, nullptr, "test", channel_stack); in test_create_channel_stack()
113 GPR_ASSERT(channel_stack->count == 1); in test_create_channel_stack()
114 channel_elem = grpc_channel_stack_element(channel_stack, 0); in test_create_channel_stack()
119 static_cast<grpc_call_stack*>(gpr_malloc(channel_stack->call_stack_size)); in test_create_channel_stack()
131 grpc_call_stack_init(channel_stack, 1, free_call, call_stack, &args); in test_create_channel_stack()
145 GRPC_CHANNEL_STACK_UNREF(channel_stack, "done"); in test_create_channel_stack()
/third_party/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);
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc512 grpc_channel_stack* channel_stack = in BM_IsolatedFilter() local
516 grpc_channel_stack_init(1, FilterDestroy, channel_stack, in BM_IsolatedFilter()
522 "CHANNEL", channel_stack))); in BM_IsolatedFilter()
525 static_cast<grpc_call_stack*>(gpr_zalloc(channel_stack->call_stack_size)); in BM_IsolatedFilter()
544 grpc_call_stack_init(channel_stack, 1, DoNothing, nullptr, &call_args)); in BM_IsolatedFilter()
556 grpc_channel_stack_destroy(channel_stack); in BM_IsolatedFilter()
559 gpr_free(channel_stack); in BM_IsolatedFilter()
/third_party/grpc/doc/
Dc-style-guide.md41 `src/core/lib/channel/channel_stack.h` →
/third_party/grpc/src/core/ext/filters/client_idle/
Dclient_idle_filter.cc288 channel_stack_(args->channel_stack), in ChannelData()
/third_party/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()
/third_party/grpc/
DgRPC-Core.podspec536 'src/core/lib/channel/channel_stack.cc',
537 'src/core/lib/channel/channel_stack.h',
1264 'src/core/lib/channel/channel_stack.h',
DgRPC-C++.podspec381 'src/core/lib/channel/channel_stack.h',
868 'src/core/lib/channel/channel_stack.h',
DBUILD661 "src/core/lib/channel/channel_stack.cc",
820 "src/core/lib/channel/channel_stack.h",
Dgrpc.gyp626 'src/core/lib/channel/channel_stack.cc',
1130 'src/core/lib/channel/channel_stack.cc',
DBUILD.gn757 "src/core/lib/channel/channel_stack.cc",
758 "src/core/lib/channel/channel_stack.h",
Dconfig.m4229 src/core/lib/channel/channel_stack.cc \
Dconfig.w32197 "src\\core\\lib\\channel\\channel_stack.cc " +
/third_party/grpc/tools/doxygen/
DDoxyfile.c++.internal1415 src/core/lib/channel/channel_stack.cc \
1416 src/core/lib/channel/channel_stack.h \
DDoxyfile.core.internal1231 src/core/lib/channel/channel_stack.cc \
1232 src/core/lib/channel/channel_stack.h \

12