/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/ |
H A D | publisher_connection_test.cc | 43 google::pubsub::v1::PublishRequest const& request) { in TEST() 70 google::pubsub::v1::PublishRequest const& request) { in TEST() 101 google::pubsub::v1::PublishRequest const& request) { in TEST() 128 google::pubsub::v1::PublishRequest const& request) { in TEST() 154 google::pubsub::v1::PublishRequest const&) { in TEST() 201 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 223 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 245 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 251 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 253 google::pubsub::v1::PublishRequest const& request) { in TEST()
|
H A D | subscriber_connection_test.cc | 55 [&](google::cloud::CompletionQueue&, in TEST() 67 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 69 google::pubsub::v1::ModifyAckDeadlineRequest const&) { in TEST() 127 .WillRepeatedly([&](google::cloud::CompletionQueue&, in TEST() 138 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 145 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 147 google::pubsub::v1::ModifyAckDeadlineRequest const&) { in TEST() 205 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 212 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 214 google::pubsub::v1::ModifyAckDeadlineRequest const&) { in TEST()
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/ |
H A D | subscription_lease_management_test.cc | 59 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 68 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 77 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 85 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 93 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 95 google::pubsub::v1::ModifyAckDeadlineRequest const& r) { in TEST() 161 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 163 google::pubsub::v1::PullRequest const& r) { in TEST()
|
H A D | subscription_session_test.cc | 66 [&](google::cloud::CompletionQueue&, in TEST() 79 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 149 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 160 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 169 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 178 .WillRepeatedly([](google::cloud::CompletionQueue&, in TEST() 180 google::pubsub::v1::AcknowledgeRequest const&) { in TEST() 241 google::pubsub::v1::AcknowledgeRequest const&) { in TEST() 291 google::pubsub::v1::ModifyAckDeadlineRequest const& r) { in TEST() 372 google::pubsub::v1::ModifyAckDeadlineRequest const&) { in TEST() [all …]
|
H A D | batching_publisher_connection_test.cc | 42 google::pubsub::v1::PublishRequest const& request) { in TEST() 100 google::pubsub::v1::PublishRequest const& request) { in TEST() 150 google::pubsub::v1::PublishRequest const& request) { in TEST() 208 google::pubsub::v1::PublishRequest const& request) { in TEST() 272 .WillRepeatedly([&](google::cloud::CompletionQueue&, in TEST() 274 google::pubsub::v1::PublishRequest const& request) { in TEST() 337 google::pubsub::v1::PublishRequest const&) { in TEST() 372 google::pubsub::v1::PublishRequest const&) { in TEST()
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/internal/ |
H A D | async_retry_loop_test.cc | 71 [&](google::cloud::CompletionQueue&, in TEST() 91 [&](google::cloud::CompletionQueue&, in TEST() 92 std::unique_ptr<grpc::ClientContext>, int) { in TEST() 142 [](google::cloud::CompletionQueue&, in TEST() 161 [](google::cloud::CompletionQueue&, in TEST() 179 [](google::cloud::CompletionQueue&, in TEST() 201 [](google::cloud::CompletionQueue&, in TEST() 202 std::unique_ptr<grpc::ClientContext>, int) { in TEST()
|
H A D | async_retry_unary_rpc_test.cc | 98 grpc::CompletionQueue*) { in TEST() 147 grpc::CompletionQueue*) { in TEST() 195 grpc::CompletionQueue*) { in TEST() 251 grpc::CompletionQueue*) { in TEST() 258 grpc::CompletionQueue*) { in TEST() 265 grpc::CompletionQueue*) { in TEST() 327 grpc::CompletionQueue*) { in TEST()
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/ |
H A D | publisher_connection_test.cc | 43 google::pubsub::v1::PublishRequest const& request) { in TEST() 70 google::pubsub::v1::PublishRequest const& request) { in TEST() 101 google::pubsub::v1::PublishRequest const& request) { in TEST() 128 google::pubsub::v1::PublishRequest const& request) { in TEST() 172 google::pubsub::v1::PublishRequest const&) { in TEST() 219 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 241 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 264 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 270 .WillOnce([&](google::cloud::CompletionQueue&, in TEST() 272 google::pubsub::v1::PublishRequest const& request) { in TEST()
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/ |
H A D | async_list_app_profiles_test.cc | 111 grpc::CompletionQueue*) { in TEST_F() 141 grpc::CompletionQueue*) { in TEST_F() 153 grpc::CompletionQueue*) { in TEST_F() 165 grpc::CompletionQueue*) { in TEST_F() 214 grpc::CompletionQueue*) { in TEST_F() 226 grpc::CompletionQueue*) { in TEST_F() 238 grpc::CompletionQueue*) { in TEST_F()
|
H A D | async_list_instances_test.cc | 113 grpc::CompletionQueue*) { in TEST_F() 146 grpc::CompletionQueue*) { in TEST_F() 159 grpc::CompletionQueue*) { in TEST_F() 172 grpc::CompletionQueue*) { in TEST_F() 229 grpc::CompletionQueue*) { in TEST_F() 242 grpc::CompletionQueue*) { in TEST_F() 255 grpc::CompletionQueue*) { in TEST_F()
|
H A D | async_list_clusters_test.cc | 117 grpc::CompletionQueue*) { in TEST_F() 150 grpc::CompletionQueue*) { in TEST_F() 163 grpc::CompletionQueue*) { in TEST_F() 176 grpc::CompletionQueue*) { in TEST_F() 233 grpc::CompletionQueue*) { in TEST_F() 246 grpc::CompletionQueue*) { in TEST_F() 259 grpc::CompletionQueue*) { in TEST_F()
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/bigtable/ |
H A D | async_list_app_profiles_test.cc | 111 grpc::CompletionQueue*) { in TEST_F() 141 grpc::CompletionQueue*) { in TEST_F() 153 grpc::CompletionQueue*) { in TEST_F() 165 grpc::CompletionQueue*) { in TEST_F() 214 grpc::CompletionQueue*) { in TEST_F() 226 grpc::CompletionQueue*) { in TEST_F() 238 grpc::CompletionQueue*) { in TEST_F()
|
H A D | async_list_clusters_test.cc | 117 grpc::CompletionQueue*) { in TEST_F() 150 grpc::CompletionQueue*) { in TEST_F() 163 grpc::CompletionQueue*) { in TEST_F() 176 grpc::CompletionQueue*) { in TEST_F() 233 grpc::CompletionQueue*) { in TEST_F() 246 grpc::CompletionQueue*) { in TEST_F() 259 grpc::CompletionQueue*) { in TEST_F()
|
H A D | async_list_instances_test.cc | 113 grpc::CompletionQueue*) { in TEST_F() 146 grpc::CompletionQueue*) { in TEST_F() 159 grpc::CompletionQueue*) { in TEST_F() 172 grpc::CompletionQueue*) { in TEST_F() 229 grpc::CompletionQueue*) { in TEST_F() 242 grpc::CompletionQueue*) { in TEST_F() 255 grpc::CompletionQueue*) { in TEST_F()
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/internal/ |
H A D | async_retry_loop_test.cc | 117 [&](google::cloud::CompletionQueue&, in TEST() 137 [&](google::cloud::CompletionQueue&, in TEST() 190 [](google::cloud::CompletionQueue&, in TEST() 210 [](google::cloud::CompletionQueue&, in TEST() 229 [](google::cloud::CompletionQueue&, in TEST() 251 [](google::cloud::CompletionQueue&, in TEST() 252 std::unique_ptr<grpc::ClientContext>, int) { in TEST() 278 int x) { return SimulateRequest(x); }, in TEST_F() 310 int x) { return SimulateRequest(x); }, in TEST_F() 343 int x) { return SimulateRequest(x); }, in TEST_F() [all …]
|
H A D | async_retry_unary_rpc_test.cc | 98 grpc::CompletionQueue*) { in TEST() 147 grpc::CompletionQueue*) { in TEST() 195 grpc::CompletionQueue*) { in TEST() 251 grpc::CompletionQueue*) { in TEST() 258 grpc::CompletionQueue*) { in TEST() 265 grpc::CompletionQueue*) { in TEST() 327 grpc::CompletionQueue*) { in TEST()
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/internal/ |
H A D | async_bulk_apply_test.cc | 92 grpc::CompletionQueue*) { in TEST_F() 163 grpc::CompletionQueue*) { in TEST_F() 170 grpc::CompletionQueue*) { in TEST_F() 252 grpc::CompletionQueue*) { in TEST_F() 259 grpc::CompletionQueue*) { in TEST_F()
|
H A D | async_poll_op_test.cc | 84 grpc::CompletionQueue*) { in TEST_F() 122 grpc::CompletionQueue*) { in TEST_F() 166 grpc::CompletionQueue*) { in TEST_F()
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/grpc_utils/ |
H A D | completion_queue.h | 26 using CompletionQueue = ::google::cloud::CompletionQueue; variable
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/grpc_utils/ |
H A D | completion_queue.h | 26 using CompletionQueue = ::google::cloud::CompletionQueue; variable
|
/dports/devel/grpc130/grpc-1.30.2/include/grpcpp/impl/codegen/ |
H A D | completion_queue.h | 26 typedef ::grpc_impl::CompletionQueue CompletionQueue; typedef
|
H A D | channel_interface.h | 29 class CompletionQueue; variable 160 ::grpc_impl::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/include/grpcpp/impl/codegen/ |
H A D | completion_queue.h | 26 typedef ::grpc_impl::CompletionQueue CompletionQueue; typedef
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/ |
H A D | completion_queue.h | 30 class CompletionQueue; variable 43 explicit CompletionQueue(std::shared_ptr<internal::CompletionQueueImpl> impl) in CompletionQueue() function
|
H A D | completion_queue.cc | 22 CompletionQueue::CompletionQueue() in CompletionQueue() function in google::cloud::GOOGLE_CLOUD_CPP_NS::CompletionQueue
|