| /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);
|