Searched refs:CompletionRegistry (Results 1 – 12 of 12) sorted by relevance
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
D | CallSafeHandle.cs | 73 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryRespo… in StartUnary() 89 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryRespo… in StartClientStreaming() 98 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedSt… in StartServerStreaming() 107 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedSt… in StartDuplexStreaming() 116 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_ISendComple… in StartSendMessage() 125 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_ISendComple… in StartSendCloseFromClient() 135 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_ISendStatus… in StartSendStatusFromServer() 147 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedMe… in StartReceiveMessage() 156 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedRe… in StartReceiveInitialMetadata() 165 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedCl… in StartServerSide() [all …]
|
D | CompletionQueueSafeHandle.cs | 33 CompletionRegistry completionRegistry; 50 public static CompletionQueueSafeHandle CreateAsync(CompletionRegistry completionRegistry) in CreateAsync() 85 public CompletionRegistry CompletionRegistry property in Grpc.Core.Internal.CompletionQueueSafeHandle
|
D | CompletionRegistry.cs | 34 internal class CompletionRegistry class 36 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<CompletionRegistry>(); 45 …public CompletionRegistry(GrpcEnvironment environment, Func<BatchContextSafeHandle> batchContextFa… in CompletionRegistry() method in Grpc.Core.Internal.CompletionRegistry
|
D | ServerSafeHandle.cs | 69 … var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(callback, null); in ShutdownAndNotify() 78 … var ctx = completionQueue.CompletionRegistry.RegisterRequestCallCompletion(callback); in RequestCall()
|
D | GrpcThreadPool.cs | 178 var callback = cq.CompletionRegistry.Extract(tag); in RunHandlerLoop() 222 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in CreateCompletionQueueList()
|
D | ChannelSafeHandle.cs | 69 var ctx = cq.CompletionRegistry.RegisterBatchCompletion(callback, callbackState); in WatchConnectivityState()
|
/external/grpc-grpc/src/csharp/Grpc.Microbenchmarks/ |
D | CompletionRegistryBenchmark.cs | 46 …CompletionRegistry sharedRegistry = useSharedRegistry ? new CompletionRegistry(environment, () => … in Run() 52 private void ThreadBody(int iterations, CompletionRegistry optionalSharedRegistry) in ThreadBody() 54 …var completionRegistry = optionalSharedRegistry ?? new CompletionRegistry(environment, () => throw… in ThreadBody()
|
D | Program.cs | 32 CompletionRegistry, enumerator 59 case MicrobenchmarkType.CompletionRegistry: in Main()
|
D | SendMessageBenchmark.cs | 55 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in ThreadBody()
|
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
D | CompletionQueueSafeHandleTest.cs | 43 …var cq = CompletionQueueSafeHandle.CreateAsync(new CompletionRegistry(env, () => BatchContextSafeH… in CreateAsyncAndShutdown()
|
/external/clang/unittests/ASTMatchers/Dynamic/ |
D | ParserTest.cpp | 279 TEST(ParserTest, CompletionRegistry) { in TEST() argument
|
/external/llvm-project/clang/unittests/ASTMatchers/Dynamic/ |
D | ParserTest.cpp | 505 TEST(ParserTest, CompletionRegistry) { in TEST() argument
|