Home
last modified time | relevance | path

Searched refs:grpc_completion_queue_next (Results 1 – 25 of 74) sorted by relevance

123

/aosp_15_r20/external/grpc-grpc/test/core/transport/chttp2/
H A Dstream_leak_with_queued_flow_control_update_test.cc62 grpc_event event = grpc_completion_queue_next( in ~TestServer()
83 grpc_event event = grpc_completion_queue_next( in HandleRpc()
115 event = grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in HandleRpc()
145 grpc_event event = grpc_completion_queue_next( in StartCallAndCloseWrites()
183 grpc_event event = grpc_completion_queue_next( in FinishCall()
244 GPR_ASSERT(grpc_completion_queue_next( in EnsureConnectionsArentLeaked()
275 GPR_ASSERT(grpc_completion_queue_next( in EnsureConnectionsArentLeaked()
317 GPR_ASSERT(grpc_completion_queue_next( in TEST()
335 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
H A Dremove_stream_from_stalled_lists_test.cc92 grpc_event event = grpc_completion_queue_next( in StartCall()
136 grpc_event event = grpc_completion_queue_next( in FinishCall()
173 while (grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in ShutdownAndGetNumCallsHandled()
205 grpc_event event = grpc_completion_queue_next( in AcceptThread()
263 while (grpc_completion_queue_next( in HandleOneRpc()
329 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
H A Dtoo_many_pings_test.cc229 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
318 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in ServerShutdownAndDestroy()
331 grpc_completion_queue_next(cq, grpc_timeout_seconds_to_deadline(5), in VerifyChannelReady()
342 grpc_event ev = grpc_completion_queue_next( in VerifyChannelDisconnected()
427 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST_F()
516 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST_F()
580 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST_F()
791 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
854 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
/aosp_15_r20/external/grpc-grpc/test/core/bad_connection/
H A Dclose_fd_test.cc163 event = grpc_completion_queue_next(cq, grpc_timeout_seconds_to_deadline(1), in drain_cq()
295 event = grpc_completion_queue_next( in _test_close_before_server_recv()
329 event = grpc_completion_queue_next( in _test_close_before_server_recv()
341 event = grpc_completion_queue_next( in _test_close_before_server_recv()
470 event = grpc_completion_queue_next( in _test_close_before_server_send()
492 event = grpc_completion_queue_next( in _test_close_before_server_send()
536 event = grpc_completion_queue_next( in _test_close_before_server_send()
542 event = grpc_completion_queue_next( in _test_close_before_server_send()
676 event = grpc_completion_queue_next( in _test_close_before_client_send()
684 event = grpc_completion_queue_next( in _test_close_before_client_send()
[all …]
/aosp_15_r20/external/grpc-grpc/test/core/end2end/
H A Dmultiple_server_queues_test.cc61 grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
67 grpc_completion_queue_next(cq1, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
68 grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
69 grpc_completion_queue_next(cq3, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
H A Dh2_ssl_session_reuse_test.cc228 ev = grpc_completion_queue_next(cq, five_seconds_time(), nullptr); in drain_cq()
248 GPR_ASSERT(grpc_completion_queue_next( in TEST()
255 ev = grpc_completion_queue_next(cq, grpc_timeout_seconds_to_deadline(5), in TEST()
H A Dh2_tls_peer_property_external_verifier_test.cc262 ev = grpc_completion_queue_next(cq, five_seconds_time(), nullptr); in drain_cq()
280 GPR_ASSERT(grpc_completion_queue_next( in TEST()
287 ev = grpc_completion_queue_next(cq, grpc_timeout_seconds_to_deadline(5), in TEST()
/aosp_15_r20/external/grpc-grpc/test/core/memory_usage/
H A Dclient.cc97 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in init_ping_pong_request()
117 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in finish_ping_pong_request()
161 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in send_snapshot_request()
204 event = grpc_completion_queue_next( in run_test_loop()
217 event = grpc_completion_queue_next( in run_test_loop()
284 event = grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
/aosp_15_r20/external/grpc-grpc/test/core/surface/
H A Dcompletion_queue_test.cc51 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in shutdown_and_destroy()
133 grpc_completion_queue_next(cc, gpr_now(GPR_CLOCK_REALTIME), nullptr); in TEST()
165 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in TEST()
201 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in TEST()
210 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in TEST()
260 event = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in TEST()
283 event = grpc_completion_queue_next(cc, gpr_inf_future(GPR_CLOCK_REALTIME), in TEST()
H A Dnum_external_connectivity_watchers_test.cc62 grpc_event ev = grpc_completion_queue_next( in channel_idle_poll_for_timeout()
111 ASSERT_EQ(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_timeouts_test()
144 grpc_event ev = grpc_completion_queue_next( in run_channel_shutdown_before_timeout_test()
151 ASSERT_EQ(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_channel_shutdown_before_timeout_test()
H A Dsequential_connectivity_test.cc63 grpc_event ev = grpc_completion_queue_next( in server_thread_func()
125 grpc_event ev = grpc_completion_queue_next( in run_test()
139 while (grpc_completion_queue_next(server_cq, in run_test()
143 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_test()
H A Dserver_test.cc103 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
104 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
132 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_to_addr()
H A Dconcurrent_connectivity_test.cc94 ASSERT_EQ(grpc_completion_queue_next(cq, poll_time, nullptr).type, in create_loop_destroy()
119 ev = grpc_completion_queue_next(args->cq, deadline, nullptr); in server_thread()
290 grpc_event ev = grpc_completion_queue_next(cq, poll_time, nullptr); in watches_with_short_timeouts()
H A Dcompletion_queue_threading_test.cc54 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in shutdown_and_destroy()
201 ev = grpc_completion_queue_next( in consumer_thread()
/aosp_15_r20/external/grpc-grpc/test/core/transport/binder/end2end/fuzzers/
H A Dserver_fuzzer.cc73 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
109 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
119 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
H A Dclient_fuzzer.cc117 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
136 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
142 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in DEFINE_PROTO_FUZZER()
/aosp_15_r20/external/grpc-grpc/doc/core/
H A Dgrpc-cq.md13 … - GRPC_CQ_NEXT: grpc_completion_queue_next() can be called (but not grpc_completion_queue_pluck())
14 …- GRPC_CQ_PLUCK: grpc_completion_queue_pluck() can be called (but not grpc_completion_queue_next())
32 grpc_completion_queue_next(cq, deadline)/pluck(cq, deadline, tag) {
/aosp_15_r20/external/grpc-grpc/test/core/handshake/
H A Dverify_peer_options.cc86 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
96 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
167 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in verify_peer_options_test()
H A Dserver_ssl_common.cc149 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
158 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
/aosp_15_r20/external/grpc-grpc/test/core/tsi/alts/handshaker/
H A Dalts_concurrent_connectivity_test.cc68 ev = grpc_completion_queue_next( in drain_cq()
167 grpc_event ev = grpc_completion_queue_next( in PollUntilShutdown()
231 grpc_completion_queue_next(cq, in ConnectLoop()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/
Dcompletion_queue_cc.cc72 auto ev = grpc_completion_queue_next( in Ref()
146 auto ev = grpc_completion_queue_next(cq_, deadline, nullptr); in AsyncNextInternal()
/aosp_15_r20/external/grpc-grpc/src/cpp/common/
H A Dcompletion_queue_cc.cc72 auto ev = grpc_completion_queue_next( in Ref()
146 auto ev = grpc_completion_queue_next(cq_, deadline, nullptr); in AsyncNextInternal()
/aosp_15_r20/external/grpc-grpc/test/cpp/microbenchmarks/
H A Dbm_cq_multiple_threads.cc132 while (grpc_completion_queue_next(g_cq, deadline, nullptr).type != in teardown()
179 GPR_ASSERT(grpc_completion_queue_next(g_cq, deadline, nullptr).type == in BM_Cq_Throughput()
H A Dbm_cq.cc110 grpc_completion_queue_next(cq, deadline, nullptr); in BM_Pass1Core()
138 grpc_completion_queue_next(cq, deadline, nullptr); in BM_EmptyCore()
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
H A Dcompletion_queue.pyx.pxi35 c_event = grpc_completion_queue_next(c_completion_queue, c_timeout, NULL)
135 event = grpc_completion_queue_next(

123