Searched refs:num_cqs (Results 1 – 7 of 7) sorted by relevance
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()
555 void Server::Start(ServerCompletionQueue** cqs, size_t num_cqs) { in Start() argument581 for (size_t i = 0; i < num_cqs; i++) { in Start()
259 : num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {} in SyncServerSettings()262 int num_cqs; member
160 void Start(ServerCompletionQueue** cqs, size_t num_cqs) override;
99 int num_cqs = (num_threads + tpc - 1) / tpc; // ceiling operator in AsyncQpsServerTest() local100 for (int i = 0; i < num_cqs; i++) { in AsyncQpsServerTest()116 for (int j = 0; j < num_cqs; j++) { in AsyncQpsServerTest()
172 int num_cqs = (num_async_threads_ + tpc - 1) / tpc; // ceiling operator in AsyncClient() local173 for (int i = 0; i < num_cqs; i++) { in AsyncClient()
136 virtual void Start(ServerCompletionQueue** cqs, size_t num_cqs) = 0;