Go to the documentation of this file.
35 GPR_ASSERT(0 == strcmp(
args->channel_args->args[0].key,
"test_key"));
39 *
static_cast<int*
>(
elem->channel_data) = 0;
45 ++*
static_cast<int*
>(
elem->channel_data);
46 *
static_cast<int*
>(
elem->call_data) = 0;
55 ++*
static_cast<int*
>(
elem->channel_data);
60 ++*
static_cast<int*
>(
elem->call_data);
65 ++*
static_cast<int*
>(
elem->channel_data);
106 arg.key =
const_cast<char*
>(
"test_key");
115 "grpc_channel_stack_init",
117 &chan_args,
"test", channel_stack)));
130 gpr_get_cycle_counter(),
155 int main(
int argc,
char** argv) {
static grpc_error_handle channel_init_func(grpc_channel_element *elem, grpc_channel_element_args *args)
static void channel_func(grpc_channel_element *elem, grpc_transport_op *)
grpc_channel_element * grpc_channel_stack_element(grpc_channel_stack *channel_stack, size_t index)
struct connected_channel_call_data call_data
#define GRPC_CHANNEL_STACK_UNREF(channel_stack, reason)
GPRAPI void gpr_free(void *ptr)
GPRAPI void * gpr_malloc(size_t size)
grpc_error_handle grpc_call_stack_init(grpc_channel_stack *channel_stack, int initial_refs, grpc_iomgr_cb_func destroy, void *destroy_arg, const grpc_call_element_args *elem_args)
#define GRPC_LOG_IF_ERROR(what, error)
void grpc_call_stack_ignore_set_pollset_or_pollset_set(grpc_call_element *, grpc_polling_entity *)
grpc_call_element * grpc_call_stack_element(grpc_call_stack *call_stack, size_t index)
void grpc_channel_stack_destroy(grpc_channel_stack *stack)
#define GRPC_CALL_STACK_UNREF(call_stack, reason)
static void free_call(void *arg, grpc_error_handle)
void grpc_channel_stack_no_post_init(grpc_channel_stack *, grpc_channel_element *)
const grpc_channel_filter * filter
const grpc_channel_filter * filter
void grpc_channel_next_get_info(grpc_channel_element *elem, const grpc_channel_info *channel_info)
static void free_channel(void *arg, grpc_error_handle)
GPRAPI grpc_slice grpc_slice_from_static_string(const char *source)
void grpc_call_stack_destroy(grpc_call_stack *stack, const grpc_call_final_info *final_info, grpc_closure *then_schedule_closure)
int main(int argc, char **argv)
static void call_destroy_func(grpc_call_element *elem, const grpc_call_final_info *, grpc_closure *)
size_t grpc_channel_stack_size(const grpc_channel_filter **filters, size_t filter_count)
static void call_func(grpc_call_element *elem, grpc_transport_stream_op_batch *)
grpc_core::ExecCtx exec_ctx
struct connected_channel_channel_data channel_data
grpc_error_handle grpc_channel_stack_init(int initial_refs, grpc_iomgr_cb_func destroy, void *destroy_arg, const grpc_channel_filter **filters, size_t filter_count, const grpc_channel_args *channel_args, const char *name, grpc_channel_stack *stack)
static void test_create_channel_stack(void)
static constexpr Timestamp InfFuture()
static grpc_error_handle call_init_func(grpc_call_element *elem, const grpc_call_element_args *)
GRPCAPI void grpc_init(void)
GRPCAPI void grpc_shutdown(void)
void grpc_slice_unref_internal(const grpc_slice &slice)
#define GRPC_ERROR_IS_NONE(err)
static void channel_destroy_func(grpc_channel_element *)
grpc
Author(s):
autogenerated on Thu Mar 13 2025 02:58:44