Searched refs:optionalProfiler (Results 1 – 2 of 2) sorted by relevance
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | GrpcThreadPool.cs | 84 var optionalProfiler = i < threadProfilers.Count ? threadProfilers[i] : null; in Start()
85 threads.Add(CreateAndStartThread(i, optionalProfiler)); in Start()
145 private Thread CreateAndStartThread(int threadIndex, IProfiler optionalProfiler) in CreateAndStartThread() argument
150 var thread = new Thread(new ThreadStart(() => RunHandlerLoop(cq, optionalProfiler))); in CreateAndStartThread()
161 private void RunHandlerLoop(CompletionQueueSafeHandle cq, IProfiler optionalProfiler) in RunHandlerLoop() argument
163 if (optionalProfiler != null) in RunHandlerLoop()
165 Profilers.SetForCurrentThread(optionalProfiler); in RunHandlerLoop()
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | ClientRunners.cs | 154 var optionalProfiler = profilerFactory(); in ClientRunnerImpl()
155 this.runnerTasks.Add(RunClientAsync(channel, timer, optionalProfiler)); in ClientRunnerImpl()
200 … private void RunUnary(Channel channel, IInterarrivalTimer timer, BasicProfiler optionalProfiler) in RunUnary() argument
202 if (optionalProfiler != null) in RunUnary()
204 Profilers.SetForCurrentThread(optionalProfiler); in RunUnary()
216 if (optionalProfiler != null && !profilerReset && statsResetCount.Count > 0) in RunUnary()
218 optionalProfiler.Reset(); in RunUnary()
307 …vate Task RunClientAsync(Channel channel, IInterarrivalTimer timer, BasicProfiler optionalProfiler) in RunClientAsync() argument
321 …return Task.Factory.StartNew(() => RunUnary(channel, timer, optionalProfiler), TaskCreationOptions… in RunClientAsync()
|