Searched refs:cq_count (Results 1 – 3 of 3) sorted by relevance
39 cq_count: usize, field49 cq_count: unsafe { grpc_sys::gpr_cpu_num_cores() as usize }, in new()62 pub fn cq_count(mut self, count: usize) -> EnvBuilder { in cq_count() method64 self.cq_count = count; in cq_count()91 let mut cqs = Vec::with_capacity(self.cq_count); in build()92 let mut handles = Vec::with_capacity(self.cq_count); in build()94 for i in 0..self.cq_count { in build()115 for _ in 0..self.cq_count { in build()142 pub fn new(cq_count: usize) -> Environment { in new()143 assert!(cq_count > 0); in new()[all …]
189 size_t cq_count; member316 gpr_malloc(sizeof(*rm->requests_per_cq) * server->cq_count)); in request_matcher_init()317 for (size_t i = 0; i < server->cq_count; i++) { in request_matcher_init()323 for (size_t i = 0; i < rm->server->cq_count; i++) { in request_matcher_destroy()352 for (size_t i = 0; i < server->cq_count; i++) { in request_matcher_kill_requests()389 for (i = 0; i < server->cq_count; i++) { in server_delete()498 for (size_t i = 0; i < server->cq_count; i++) { in publish_new_rpc()499 size_t cq_idx = (chand->cq_idx + i) % server->cq_count; in publish_new_rpc()520 for (size_t i = 0; i < server->cq_count; i++) { in publish_new_rpc()521 size_t cq_idx = (chand->cq_idx + i) % server->cq_count; in publish_new_rpc()[all …]
1288 __u16 cq_count; member