Searched refs:GRPC_QUEUE_SHUTDOWN (Results 1 – 25 of 124) sorted by relevance
12345
88 case GRPC_QUEUE_SHUTDOWN: in LLVMFuzzerTestOneInput()131 } while (ev.type != GRPC_QUEUE_SHUTDOWN && in LLVMFuzzerTestOneInput()133 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in LLVMFuzzerTestOneInput()
129 case GRPC_QUEUE_SHUTDOWN: in LLVMFuzzerTestOneInput()150 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in LLVMFuzzerTestOneInput()
54 elif c_event.type == GRPC_QUEUE_SHUTDOWN:56 return None, ConnectivityEvent(GRPC_QUEUE_SHUTDOWN, False, None)88 if event.completion_type == GRPC_QUEUE_SHUTDOWN:105 while self.poll().type != GRPC_QUEUE_SHUTDOWN:
45 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()51 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()253 GPR_ASSERT(event.type == GRPC_QUEUE_SHUTDOWN); in test_shutdown_then_next_polling()276 GPR_ASSERT(event.type == GRPC_QUEUE_SHUTDOWN); in test_shutdown_then_next_with_timeout()355 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in test_pluck_after_shutdown()
103 .type != GRPC_QUEUE_SHUTDOWN) in run_test()107 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
110 .type == GRPC_QUEUE_SHUTDOWN); in run_timeouts_test()153 .type == GRPC_QUEUE_SHUTDOWN); in run_channel_shutdown_before_timeout_test()
59 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()197 case GRPC_QUEUE_SHUTDOWN: in consumer_thread()
68 case GRPC_QUEUE_SHUTDOWN:81 // This makes the completion queue produce a GRPC_QUEUE_SHUTDOWN event *after*
51 case GRPC_QUEUE_SHUTDOWN: in grpc_event_string()
55 case GRPC_QUEUE_SHUTDOWN: in grpc_event_string()
58 case GRPC_QUEUE_SHUTDOWN: in AsyncNextInternal()
60 case GRPC_QUEUE_SHUTDOWN: in AsyncNextInternal()
39 if (event.type == GRPC_QUEUE_SHUTDOWN) { in thread_worker()
92 case GRPC_QUEUE_SHUTDOWN: in bad_ssl_run()
56 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
61 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
58 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
59 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
196 case GRPC_QUEUE_SHUTDOWN: in expectation_to_strvec()240 case GRPC_QUEUE_SHUTDOWN: in verify_matches()
99 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
126 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
124 GRPC_QUEUE_SHUTDOWN) { in teardown()
451 GRPC_QUEUE_SHUTDOWN, enumerator