Searched refs:WorkerServiceImpl (Results 1 – 6 of 6) sorted by relevance
99 class WorkerServiceImpl final : public WorkerService::Service { class101 WorkerServiceImpl(int server_port, QpsWorker* worker) in WorkerServiceImpl() function in grpc::testing::WorkerServiceImpl152 InstanceGuard(WorkerServiceImpl* impl) in InstanceGuard()163 WorkerServiceImpl* const impl_;273 impl_.reset(new WorkerServiceImpl(server_port, this)); in QpsWorker()
35 class WorkerServiceImpl; variable53 std::unique_ptr<WorkerServiceImpl> impl_;
34 class WorkerServiceImpl < Grpc::Testing::WorkerService::Service class115 worker_service = WorkerServiceImpl.new(s, options['server_port'].to_i)
33 public class WorkerServiceImpl : WorkerService.WorkerServiceBase class37 public WorkerServiceImpl(Action stopRequestHandler) in WorkerServiceImpl() method in Grpc.Testing.WorkerServiceImpl
70 … var workerServiceImpl = new WorkerServiceImpl(() => { Task.Run(() => tcs.SetResult(null)); }); in RunAsync()
55 .addService(new WorkerServiceImpl()) in LoadWorker()120 private class WorkerServiceImpl extends WorkerServiceGrpc.WorkerServiceImplBase { class in LoadWorker