Searched refs:completionQueue (Results 1 – 11 of 11) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | CallSafeHandle.cs | 53 CompletionQueueSafeHandle completionQueue; field in Grpc.Core.Internal.CallSafeHandle
59 public void Initialize(CompletionQueueSafeHandle completionQueue) in Initialize() argument
61 this.completionQueue = completionQueue; in Initialize()
71 using (completionQueue.NewScope()) in StartUnary()
73 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryRespo… in StartUnary()
87 using (completionQueue.NewScope()) in StartClientStreaming()
89 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IUnaryRespo… in StartClientStreaming()
96 using (completionQueue.NewScope()) in StartServerStreaming()
98 …var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(CompletionHandler_IReceivedSt… in StartServerStreaming()
105 using (completionQueue.NewScope()) in StartDuplexStreaming()
[all …]
|
| D | ServerSafeHandle.cs | 63 …void ShutdownAndNotify(BatchCompletionDelegate callback, CompletionQueueSafeHandle completionQueue) in ShutdownAndNotify() argument
65 using (completionQueue.NewScope()) in ShutdownAndNotify()
69 … var ctx = completionQueue.CompletionRegistry.RegisterBatchCompletion(callback, null); in ShutdownAndNotify()
70 Native.grpcsharp_server_shutdown_and_notify_callback(this, completionQueue, ctx); in ShutdownAndNotify()
74 …void RequestCall(RequestCallCompletionDelegate callback, CompletionQueueSafeHandle completionQueue) in RequestCall() argument
76 using (completionQueue.NewScope()) in RequestCall()
78 … var ctx = completionQueue.CompletionRegistry.RegisterRequestCallCompletion(callback); in RequestCall()
79 Native.grpcsharp_server_request_call(this, completionQueue, ctx).CheckOk(); in RequestCall()
|
| D | AsyncCallServer.cs | 45 public void Initialize(CallSafeHandle call, CompletionQueueSafeHandle completionQueue) in Initialize() argument
47 call.Initialize(completionQueue); in Initialize()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Channel.cs | 43 readonly CompletionQueueSafeHandle completionQueue; field in Grpc.Core.Channel
74 this.completionQueue = this.environment.PickCompletionQueue(); in Channel()
167 …handle.WatchConnectivityState(lastObservedState, deadlineTimespec, completionQueue, WatchConnectiv… in TryWaitForStateChangedAsync()
280 return this.completionQueue;
|
| /external/grpc-grpc/src/objective-c/GRPCClient/private/ |
| D | GRPCCompletionQueue.h | 38 + (instancetype)completionQueue;
|
| D | GRPCChannel.h | 67 completionQueue:(nonnull GRPCCompletionQueue *)queue;
|
| D | GRPCHost.h | 69 completionQueue:(GRPCCompletionQueue *)queue;
|
| D | GRPCHost.m | 122 completionQueue:(GRPCCompletionQueue *)queue {
137 completionQueue:queue];
302 // This is racing -[GRPCHost unmanagedCallWithPath:completionQueue:].
|
| D | GRPCWrappedCall.m | 257 _queue = [GRPCCompletionQueue completionQueue];
262 completionQueue:_queue];
|
| D | GRPCCompletionQueue.m | 28 + (instancetype)completionQueue { class
|
| D | GRPCChannel.m | 199 completionQueue:(GRPCCompletionQueue *)queue {
|