Searched refs:num_cqs (Results 1 – 15 of 15) sorted by relevance
| /external/grpc-grpc/include/grpcpp/ |
| D | server_builder.h | 259 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()
262 int num_cqs; member
|
| D | server.h | 160 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_builder.cc | 113 sync_server_settings_.num_cqs = val; in SetSyncServerOption()
258 for (int i = 0; i < sync_server_settings_.num_cqs; i++) { in BuildAndStart()
273 sync_server_settings_.num_cqs, sync_server_settings_.min_pollers, in BuildAndStart()
|
| D | server_cc.cc | 555 void Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) { in Start() argument
581 for (size_t i = 0; i < num_cqs; i++) { in Start()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_builder.cc | 156 sync_server_settings_.num_cqs = val; in SetSyncServerOption()
308 for (int i = 0; i < sync_server_settings_.num_cqs; i++) { in BuildAndStart()
322 sync_server_settings_.num_cqs, sync_server_settings_.min_pollers, in BuildAndStart()
|
| D | server_cc.cc | 1130 void Server::Start(grpc::ServerCompletionQueue** cqs, size_t num_cqs) { in Start() argument
1171 for (size_t i = 0; i < num_cqs; i++) { in Start()
1183 for (size_t i = 0; i < num_cqs; i++) { in Start()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | server_builder.h | 360 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()
363 int num_cqs; member
|
| D | server.h | 195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | server_builder.h | 360 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()
363 int num_cqs; member
|
| D | server.h | 195 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 99 int num_cqs = (num_threads + tpc - 1) / tpc; // ceiling operator in AsyncQpsServerTest() local
100 for (int i = 0; i < num_cqs; i++) { in AsyncQpsServerTest()
116 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()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 136 virtual void Start(ServerCompletionQueue** cqs, size_t num_cqs) = 0;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 181 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_interface.h | 181 virtual void Start(::grpc::ServerCompletionQueue** cqs, size_t num_cqs) = 0;
|