MCPcopy Create free account
hub / github.com/alibaba/euler / NextCompletionQueue

Method NextCompletionQueue

euler/client/completion_queue_pool.h:41–45  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

39 void operator=(CompletionQueuePool const&) = delete;
40
41 grpc::CompletionQueue *NextCompletionQueue() {
42 std::lock_guard<std::mutex> lock(mu_);
43 return threads_[next_round_robin_assignment_++ %
44 threads_.size()].completion_queue();
45 }
46
47 private:
48 explicit CompletionQueuePool(size_t thread_count)

Callers 1

GrpcChannelMethod · 0.80

Calls 2

completion_queueMethod · 0.80
sizeMethod · 0.45

Tested by

no test coverage detected