Searched refs:newRpc (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 33 Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq); in HandleCall() argument
52 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
57 newRpc.Server); in HandleCall()
59 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
66 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
116 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
121 newRpc.Server); in HandleCall()
123 asyncCall.Initialize(newRpc.Call, cq); in HandleCall()
129 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
179 public async Task HandleCall(ServerRpcNew newRpc, CompletionQueueSafeHandle cq) in HandleCall() argument
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Server.cs | 337 …private async Task HandleCallAsync(ServerRpcNew newRpc, CompletionQueueSafeHandle cq, Action conti… in HandleCallAsync() argument
342 if (!callHandlers.TryGetValue(newRpc.Method, out callHandler)) in HandleCallAsync()
346 await callHandler.HandleCall(newRpc, cq).ConfigureAwait(false); in HandleCallAsync()
366 var newRpc = ctx.GetServerRpcNew(this); in HandleNewServerRpc()
369 if (!newRpc.Call.IsInvalid) in HandleNewServerRpc()
377 HandleCallAsync(newRpc, cq, () => AllowOneRpc(cq)); in HandleNewServerRpc()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | OpenLoopClient.java | 169 newRpc(stub); in call()
179 private void newRpc(BenchmarkServiceGrpc.BenchmarkServiceStub stub) { in newRpc() method in OpenLoopClient.LoadGenerationWorker
|