Searched refs:num_cqs (Results 1 – 9 of 9) sorted by relevance
| /third_party/grpc/src/cpp/server/ |
| D | server_builder.cc | 162 sync_server_settings_.num_cqs = val; in SetSyncServerOption()
314 for (int i = 0; i < sync_server_settings_.num_cqs; i++) { in BuildAndStart()
328 sync_server_settings_.num_cqs, sync_server_settings_.min_pollers, in BuildAndStart()
|
| D | server_cc.cc | 1147 void Server::Start(grpc::ServerCompletionQueue** cqs, size_t num_cqs) { in Start() argument
1188 for (size_t i = 0; i < num_cqs; i++) { in Start()
1200 for (size_t i = 0; i < num_cqs; i++) { in Start()
|
| /third_party/grpc/include/grpcpp/ |
| D | server_builder_impl.h | 360 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()
363 int num_cqs; member
|
| D | server_builder.h | 365 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()
368 int num_cqs; member
|
| D | server.h | 195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
|
| D | server_impl.h | 201 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
|
| /third_party/grpc/test/cpp/qps/ |
| D | server_async.cc | 98 int num_cqs = (num_threads + tpc - 1) / tpc; // ceiling operator in AsyncQpsServerTest() local
99 for (int i = 0; i < num_cqs; i++) { in AsyncQpsServerTest()
120 for (int j = 0; j < num_cqs; j++) { in AsyncQpsServerTest()
|
| D | client_async.cc | 172 int num_cqs = (num_async_threads_ + tpc - 1) / tpc; // ceiling operator in AsyncClient() local
173 for (int i = 0; i < num_cqs; i++) { in AsyncClient()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 183 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
|