Go to the source code of this file.
Classes | |
| class | worker_servicer._SubWorker |
| class | worker_servicer.WorkerServicer |
Namespaces | |
| worker_servicer | |
Functions | |
| benchmark_client.BenchmarkClient | worker_servicer._create_client (str server, control_pb2.ClientConfig config, histogram.Histogram qps_data) |
| Tuple[aio.Server, int] | worker_servicer._create_server (control_pb2.ServerConfig config) |
| _SubWorker | worker_servicer._create_sub_worker () |
| control_pb2.ClientStatus | worker_servicer._get_client_status (float start_time, float end_time, histogram.Histogram qps_data) |
| control_pb2.ServerStatus | worker_servicer._get_server_status (float start_time, float end_time, int port) |
| int | worker_servicer._pick_an_unused_port () |
Variables | |
| worker_servicer._LOGGER = logging.getLogger(__name__) | |
| worker_servicer._NUM_CORES = multiprocessing.cpu_count() | |
| worker_servicer._WORKER_ENTRY_FILE | |