Searched refs:completionRegistry (Results 1 – 4 of 4) sorted by relevance
33 CompletionRegistry completionRegistry; field in Grpc.Core.Internal.CompletionQueueSafeHandle50 public static CompletionQueueSafeHandle CreateAsync(CompletionRegistry completionRegistry) in CreateAsync() argument53 cq.completionRegistry = completionRegistry; in CreateAsync()87 get { return completionRegistry; }
222 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in CreateCompletionQueueList()223 list.Add(CompletionQueueSafeHandle.CreateAsync(completionRegistry)); in CreateCompletionQueueList()
55 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in ThreadBody()56 var cq = CompletionQueueSafeHandle.CreateAsync(completionRegistry); in ThreadBody()67 var callback = completionRegistry.Extract(completionRegistry.LastRegisteredKey); in ThreadBody()
54 …var completionRegistry = optionalSharedRegistry ?? new CompletionRegistry(environment, () => throw… in ThreadBody()60 completionRegistry.Register(ctx.Handle, ctx); in ThreadBody()61 var callback = completionRegistry.Extract(ctx.Handle); in ThreadBody()