/external/grpc-grpc/test/core/end2end/tests/ |
payload.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
ping_pong_streaming.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry_cancellation.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry_exceeds_buffer_size_in_subsequent_batch.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry_server_pushback_delay.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry_server_pushback_disabled.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
retry_too_many_attempts.cc | 71 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 72 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 93 grpc_completion_queue_destroy(f->shutdown_cq);
|
simple_cacheable_request.cc | 63 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 64 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 85 grpc_completion_queue_destroy(f->shutdown_cq);
|
simple_metadata.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
simple_request.cc | 64 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 65 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 86 grpc_completion_queue_destroy(f->shutdown_cq);
|
stream_compression_payload.cc | 64 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 65 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 86 grpc_completion_queue_destroy(f->shutdown_cq);
|
stream_compression_ping_pong_streaming.cc | 65 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 66 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 87 grpc_completion_queue_destroy(f->shutdown_cq);
|
streaming_error_response.cc | 66 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 67 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 88 grpc_completion_queue_destroy(f->shutdown_cq);
|
trailing_metadata.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
write_buffering.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
write_buffering_at_end.cc | 61 grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000)); 62 GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000), 83 grpc_completion_queue_destroy(f->shutdown_cq);
|
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
completion_queue.pyx.pxi | 72 def __cinit__(self, shutdown_cq=False): 75 if shutdown_cq:
|
/external/grpc-grpc/test/core/end2end/fixtures/ |
h2_census.cc | 54 f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
|
h2_compress.cc | 58 f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
|
h2_fd.cc | 62 f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
|
h2_full+trace.cc | 59 f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
|
h2_full+workarounds.cc | 58 f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
|