Searched refs:CompletionQueues (Results 1 – 4 of 4) sorted by relevance
33 Assert.IsTrue(env.CompletionQueues.Count > 0); in InitializeAndShutdownGrpcEnvironment()34 for (int i = 0; i < env.CompletionQueues.Count; i++) in InitializeAndShutdownGrpcEnvironment()36 Assert.IsNotNull(env.CompletionQueues.ElementAt(i)); in InitializeAndShutdownGrpcEnvironment()
312 internal IReadOnlyCollection<CompletionQueueSafeHandle> CompletionQueues property in Grpc.Core.GrpcEnvironment316 return this.threadPool.CompletionQueues;338 … var cqIndex = (int) ((cqPickerCounter.Increment() - 1) % this.threadPool.CompletionQueues.Count); in PickCompletionQueue()339 return this.threadPool.CompletionQueues.ElementAt(cqIndex); in PickCompletionQueue()
79 foreach (var cq in environment.CompletionQueues) in Server()159 foreach (var cq in environment.CompletionQueues) in Start()219 var cq = environment.CompletionQueues.First(); // any cq will do in ShutdownInternalAsync()
137 internal IReadOnlyCollection<CompletionQueueSafeHandle> CompletionQueues property in Grpc.Core.Internal.GrpcThreadPool