Searched refs:newRpc (Results 1 – 2 of 2) sorted by relevance
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 33 Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq); in HandleCall() argument
51 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
56 newRpc.Server); in HandleCall()
58 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
65 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
110 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
115 newRpc.Server); in HandleCall()
117 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
123 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
168 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | Server.cs | 345 …private async Task HandleCallAsync(ServerRpcNew newRpc, CompletionQueueSafeHandle cq, Action<Serve… in HandleCallAsync() argument
350 if (!callHandlers.TryGetValue(newRpc.Method, out callHandler)) in HandleCallAsync()
354 await callHandler.HandleCall(newRpc, cq).ConfigureAwait(false); in HandleCallAsync()
374 var newRpc = ctx.GetServerRpcNew(this); in HandleNewServerRpc()
377 if (!newRpc.Call.IsInvalid) in HandleNewServerRpc()
385 HandleCallAsync(newRpc, cq, (server, state) => server.AllowOneRpc(state)); in HandleNewServerRpc()
|