Home
last modified time | relevance | path

Searched refs:abort_channel_polling (Results 1 – 1 of 1) sorted by relevance

/external/grpc-grpc/src/ruby/ext/grpc/
Drb_channel.c107 static int abort_channel_polling = 0; variable
275 GPR_ASSERT(abort_channel_polling || channel_polling_thread_started); in get_state_without_gil()
332 if (abort_channel_polling || stack->bg_wrapped->channel_destroyed) { in wait_for_watch_state_op_complete_without_gvl()
568 GPR_ASSERT(channel_polling_thread_started || abort_channel_polling); in grpc_rb_channel_try_register_connection_polling()
576 if (bg->channel_destroyed || abort_channel_polling) { in grpc_rb_channel_try_register_connection_polling()
655 if (abort_channel_polling) { in run_poll_channels_loop_unblocking_func()
659 abort_channel_polling = 1; in run_poll_channels_loop_unblocking_func()
695 while (!channel_polling_thread_started && !abort_channel_polling && in wait_until_channel_polling_thread_started_no_gil()
719 abort_channel_polling = 1; in set_abort_channel_polling_without_gil()
738 GPR_ASSERT(!abort_channel_polling); in grpc_rb_channel_polling_thread_start()