Searched refs:cq_idx (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 67 size_t cq_idx; member
98 size_t cq_idx; member
233 static void fail_call(grpc_server* server, size_t cq_idx, requested_call* rc,
448 static void publish_call(grpc_server* server, call_data* calld, size_t cq_idx, in publish_call() argument
453 calld->cq_new = server->cqs[cq_idx]; in publish_call()
499 size_t cq_idx = (chand->cq_idx + i) % server->cq_count; in publish_new_rpc() local
501 gpr_locked_mpscq_try_pop(&rm->requests_per_cq[cq_idx])); in publish_new_rpc()
507 publish_call(server, calld, cq_idx, rc); in publish_new_rpc()
521 size_t cq_idx = (chand->cq_idx + i) % server->cq_count; in publish_new_rpc() local
523 gpr_locked_mpscq_pop(&rm->requests_per_cq[cq_idx])); in publish_new_rpc()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | server.cc | 269 size_t cq_idx = (start_request_queue_index + i) % requests_per_cq_.size(); in MatchOrQueue() local
271 reinterpret_cast<RequestedCall*>(requests_per_cq_[cq_idx].TryPop()); in MatchOrQueue()
275 calld->Publish(cq_idx, rc); in MatchOrQueue()
286 size_t cq_idx = 0; in MatchOrQueue() local
291 cq_idx = in MatchOrQueue()
293 rc = reinterpret_cast<RequestedCall*>(requests_per_cq_[cq_idx].Pop()); in MatchOrQueue()
306 calld->Publish(cq_idx, rc); in MatchOrQueue()
353 size_t cq_idx() const { return cq_idx_; } in cq_idx() function in grpc_core::Server::AllocatingRequestMatcherBase
381 calld->Publish(cq_idx(), rc); in MatchOrQueue()
411 calld->Publish(cq_idx(), rc); in MatchOrQueue()
[all …]
|
| D | server.h | 188 size_t cq_idx, grpc_transport* transport,
193 size_t cq_idx() const { return cq_idx_; } in cq_idx() function
255 void Publish(size_t cq_idx, RequestedCall* rc);
343 void FailCall(size_t cq_idx, RequestedCall* rc, grpc_error* error);
344 grpc_call_error QueueRequestedCall(size_t cq_idx, RequestedCall* rc);
354 size_t* cq_idx, grpc_completion_queue* cq_for_notification, void* tag,
|
| /external/kernel-headers/original/uapi/rdma/ |
| D | efa-abi.h | 67 __u16 cq_idx; member
|