|
|
@ -52,10 +52,7 @@ namespace Grpc.Microbenchmarks |
|
|
|
|
|
|
|
|
|
|
|
private void ThreadBody(int iterations, int payloadSize) |
|
|
|
private void ThreadBody(int iterations, int payloadSize) |
|
|
|
{ |
|
|
|
{ |
|
|
|
// TODO(jtattermusch): parametrize by number of pending completions. |
|
|
|
var completionRegistry = new CompletionRegistry(environment, () => environment.BatchContextPool.Lease()); |
|
|
|
// TODO(jtattermusch): parametrize by cached/non-cached BatchContextSafeHandle |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var completionRegistry = new CompletionRegistry(environment); |
|
|
|
|
|
|
|
var cq = CompletionQueueSafeHandle.CreateAsync(completionRegistry); |
|
|
|
var cq = CompletionQueueSafeHandle.CreateAsync(completionRegistry); |
|
|
|
var call = CreateFakeCall(cq); |
|
|
|
var call = CreateFakeCall(cq); |
|
|
|
|
|
|
|
|
|
|
|