Lines Matching refs:new
47 static readonly BlockingCollection<BasicProfiler> profilers = new BlockingCollection<BasicProfiler>();
77 return new ClientRunnerImpl(channels,
93 var channelOptions = new List<ChannelOption>();
96 channelOptions.Add(new ChannelOption(ChannelOptions.SslTargetNameOverride, securityParams.ServerHostOverride));
103 var result = new List<Channel>();
107 var channel = new Channel(target, credentials, channelOptions);
133 readonly CancellationTokenSource stoppedCts = new CancellationTokenSource();
134 readonly TimeStats timeStats = new TimeStats();
135 readonly AtomicCounter statsResetCount = new AtomicCounter();
141 this.channels = new List<Channel>(channels);
145 this.cachedByteBufferRequest = new Lazy<byte[]>(() => new byte[payloadConfig.BytebufParams.ReqSize]);
146 this.threadLocalHistogram = new ThreadLocal<Histogram>(() => new Histogram(histogramParams.Resolution, histogramParams.MaxPossible), true);
148 this.runnerTasks = new List<Task>();
162 var histogramData = new HistogramData();
178 return new ClientStats
209 var client = new BenchmarkService.BenchmarkServiceClient(channel);
211 var stopwatch = new Stopwatch();
235 var client = new BenchmarkService.BenchmarkServiceClient(channel);
237 var stopwatch = new Stopwatch();
254 var client = new BenchmarkService.BenchmarkServiceClient(channel);
256 var stopwatch = new Stopwatch();
282 var stopwatch = new Stopwatch();
284 var callDetails = new CallInvocationDetails<byte[], byte[]>(channel, GenericService.StreamingCallMethod, new CallOptions());
333 throw new ArgumentException("Unsupported configuration.");
339 return new SimpleRequest
348 return new Payload { Body = ByteString.CopyFrom(new byte[size]) };
356 return new ClosedLoopInterarrivalTimer();
358 return new PoissonInterarrivalTimer(loadParams.Poisson.OfferedLoad * loadMultiplier);
360 throw new ArgumentException("Unknown load type");
