Searched refs:shutdown_tag (Results 1 – 7 of 7) sorted by relevance
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 99 ShutdownTag shutdown_tag; in ~FullstackFixture() local
101 &shutdown_tag); in ~FullstackFixture()
228 ShutdownTag shutdown_tag; in ~EndpointPairFixture() local
230 &shutdown_tag); in ~EndpointPairFixture()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _read_some_but_not_all_responses_test.py | 28 def __init__(self, completion_queue, shutdown_tag): argument
31 self._shutdown_tag = shutdown_tag
|
| D | cygrpc_test.py | 86 shutdown_tag = object()
87 server.shutdown(completion_queue, shutdown_tag)
91 self.assertIs(shutdown_tag, event.tag)
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 109 typedef struct shutdown_tag { struct
113 } shutdown_tag; typedef
215 shutdown_tag* shutdown_tags;
1221 shutdown_tag* sdt; in grpc_server_shutdown_and_notify()
1244 server->shutdown_tags = static_cast<shutdown_tag*>( in grpc_server_shutdown_and_notify()
1246 sizeof(shutdown_tag) * (server->num_shutdown_tags + 1))); in grpc_server_shutdown_and_notify()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 607 ShutdownTag shutdown_tag; // Dummy shutdown tag in ShutdownInternal() local
608 grpc_server_shutdown_and_notify(server_, shutdown_cq.cq(), &shutdown_tag); in ShutdownInternal()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | server.cc | 736 for (auto& shutdown_tag : shutdown_tags_) { in MaybeFinishShutdown() local
738 grpc_cq_end_op(shutdown_tag.cq, shutdown_tag.tag, GRPC_ERROR_NONE, in MaybeFinishShutdown()
739 DoneShutdownEvent, this, &shutdown_tag.completion); in MaybeFinishShutdown()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 1228 grpc::ShutdownTag shutdown_tag; // Dummy shutdown tag in ShutdownInternal() local
1229 grpc_server_shutdown_and_notify(server_, shutdown_cq.cq(), &shutdown_tag); in ShutdownInternal()
|