Home
last modified time | relevance | path

Searched refs:CompletionRegistry (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DCallSafeHandle.cs73 …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 …]
DCompletionQueueSafeHandle.cs33 CompletionRegistry completionRegistry;
50 public static CompletionQueueSafeHandle CreateAsync(CompletionRegistry completionRegistry) in CreateAsync()
85 public CompletionRegistry CompletionRegistry property in Grpc.Core.Internal.CompletionQueueSafeHandle
DCompletionRegistry.cs34 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
DServerSafeHandle.cs69 … var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(callback, null); in ShutdownAndNotify()
78 … var ctx = completionQueue.CompletionRegistry.RegisterRequestCallCompletion(callback); in RequestCall()
DGrpcThreadPool.cs178 var callback = cq.CompletionRegistry.Extract(tag); in RunHandlerLoop()
222 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in CreateCompletionQueueList()
DChannelSafeHandle.cs69 var ctx = cq.CompletionRegistry.RegisterBatchCompletion(callback, callbackState); in WatchConnectivityState()
/external/grpc-grpc/src/csharp/Grpc.Microbenchmarks/
DCompletionRegistryBenchmark.cs46CompletionRegistry 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()
DProgram.cs32 CompletionRegistry, enumerator
59 case MicrobenchmarkType.CompletionRegistry: in Main()
DSendMessageBenchmark.cs55 …var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Le… in ThreadBody()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/
DCompletionQueueSafeHandleTest.cs43 …var cq = CompletionQueueSafeHandle.CreateAsync(new CompletionRegistry(env, () => BatchContextSafeH… in CreateAsyncAndShutdown()
/external/clang/unittests/ASTMatchers/Dynamic/
DParserTest.cpp279 TEST(ParserTest, CompletionRegistry) { in TEST() argument
/external/llvm-project/clang/unittests/ASTMatchers/Dynamic/
DParserTest.cpp505 TEST(ParserTest, CompletionRegistry) { in TEST() argument