Lines Matching refs:wrapper

101   grpc_rb_channel* wrapper;  member
192 grpc_rb_channel* wrapper = ALLOC(grpc_rb_channel); in grpc_rb_channel_alloc() local
193 wrapper->bg_wrapped = NULL; in grpc_rb_channel_alloc()
194 wrapper->credentials = Qnil; in grpc_rb_channel_alloc()
195 return TypedData_Wrap_Struct(cls, &grpc_channel_data_type, wrapper); in grpc_rb_channel_alloc()
210 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_init() local
230 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_init()
241 wrapper->credentials = credentials; in grpc_rb_channel_init()
248 stack.wrapper = wrapper; in grpc_rb_channel_init()
299 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_get_connectivity_state() local
305 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_get_connectivity_state()
306 if (wrapper->bg_wrapped == NULL) { in grpc_rb_channel_get_connectivity_state()
311 stack.bg = wrapper->bg_wrapped; in grpc_rb_channel_get_connectivity_state()
374 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_watch_connectivity_state() local
379 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_watch_connectivity_state()
381 if (wrapper->bg_wrapped == NULL) { in grpc_rb_channel_watch_connectivity_state()
393 stack.bg_wrapped = wrapper->bg_wrapped; in grpc_rb_channel_watch_connectivity_state()
399 wait_for_watch_state_op_complete_unblocking_func, wrapper->bg_wrapped); in grpc_rb_channel_watch_connectivity_state()
410 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_create_call() local
433 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_create_call()
434 if (wrapper->bg_wrapped == NULL) { in grpc_rb_channel_create_call()
442 call = grpc_channel_create_call(wrapper->bg_wrapped->channel, parent_call, in grpc_rb_channel_create_call()
471 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_destroy() local
473 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_destroy()
474 if (wrapper->bg_wrapped != NULL) { in grpc_rb_channel_destroy()
476 wrapper->bg_wrapped, NULL, NULL); in grpc_rb_channel_destroy()
477 wrapper->bg_wrapped = NULL; in grpc_rb_channel_destroy()
485 grpc_rb_channel* wrapper = NULL; in grpc_rb_channel_get_target() local
489 TypedData_Get_Struct(self, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_channel_get_target()
490 target = grpc_channel_get_target(wrapper->bg_wrapped->channel); in grpc_rb_channel_get_target()
555 stack->wrapper->bg_wrapped = in channel_init_try_register_connection_polling_without_gil()
557 grpc_rb_channel_try_register_connection_polling(stack->wrapper->bg_wrapped); in channel_init_try_register_connection_polling_without_gil()
828 grpc_rb_channel* wrapper = NULL; in grpc_rb_get_wrapped_channel() local
829 TypedData_Get_Struct(v, grpc_rb_channel, &grpc_channel_data_type, wrapper); in grpc_rb_get_wrapped_channel()
830 return wrapper->bg_wrapped->channel; in grpc_rb_get_wrapped_channel()