Home
last modified time | relevance | path

Searched defs:CompletionQueue (Results 1 – 25 of 159) sorted by relevance

1234567

/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/
H A Dpublisher_connection_test.cc43 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 Dsubscriber_connection_test.cc55 [&](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 Dsubscription_lease_management_test.cc59 .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 Dsubscription_session_test.cc66 [&](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 Dbatching_publisher_connection_test.cc42 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 Dasync_retry_loop_test.cc71 [&](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 Dasync_retry_unary_rpc_test.cc98 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 Dpublisher_connection_test.cc43 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 Dasync_list_app_profiles_test.cc111 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 Dasync_list_instances_test.cc113 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 Dasync_list_clusters_test.cc117 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 Dasync_list_app_profiles_test.cc111 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 Dasync_list_clusters_test.cc117 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 Dasync_list_instances_test.cc113 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 Dasync_retry_loop_test.cc117 [&](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 Dasync_retry_unary_rpc_test.cc98 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 Dasync_bulk_apply_test.cc92 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 Dasync_poll_op_test.cc84 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 Dcompletion_queue.h26 using CompletionQueue = ::google::cloud::CompletionQueue; variable
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/grpc_utils/
H A Dcompletion_queue.h26 using CompletionQueue = ::google::cloud::CompletionQueue; variable
/dports/devel/grpc130/grpc-1.30.2/include/grpcpp/impl/codegen/
H A Dcompletion_queue.h26 typedef ::grpc_impl::CompletionQueue CompletionQueue; typedef
H A Dchannel_interface.h29 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 Dcompletion_queue.h26 typedef ::grpc_impl::CompletionQueue CompletionQueue; typedef
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/
H A Dcompletion_queue.h30 class CompletionQueue; variable
43 explicit CompletionQueue(std::shared_ptr<internal::CompletionQueueImpl> impl) in CompletionQueue() function
H A Dcompletion_queue.cc22 CompletionQueue::CompletionQueue() in CompletionQueue() function in google::cloud::GOOGLE_CLOUD_CPP_NS::CompletionQueue

1234567