worker_servicer Namespace Reference

Classes
class	_SubWorker
class	WorkerServicer

Functions
benchmark_client.BenchmarkClient	_create_client (str server, control_pb2.ClientConfig config, histogram.Histogram qps_data)
Tuple[aio.Server, int]	_create_server (control_pb2.ServerConfig config)
_SubWorker	_create_sub_worker ()
control_pb2.ClientStatus	_get_client_status (float start_time, float end_time, histogram.Histogram qps_data)
control_pb2.ServerStatus	_get_server_status (float start_time, float end_time, int port)
int	_pick_an_unused_port ()

Variables
	_LOGGER = logging.getLogger(__name__)
	_NUM_CORES = multiprocessing.cpu_count()
	_WORKER_ENTRY_FILE

Function Documentation

_create_client()

benchmark_client.BenchmarkClient worker_servicer._create_client ( str  server, control_pb2.ClientConfig  config, histogram.Histogram  qps_data  )

private

Creates a client object according to the ClientConfig.

Definition at line 126 of file worker_servicer.py.

_create_server()

Tuple[aio.Server, int] worker_servicer._create_server ( control_pb2.ServerConfig  config )

private

Creates a server object according to the ServerConfig.

Definition at line 71 of file worker_servicer.py.

_create_sub_worker()

_SubWorker worker_servicer._create_sub_worker ( )

private

Creates a child qps worker as a subprocess.

Definition at line 158 of file worker_servicer.py.

_get_client_status()

control_pb2.ClientStatus worker_servicer._get_client_status ( float  start_time, float  end_time, histogram.Histogram  qps_data  )

private

Creates ClientStatus proto message.

Definition at line 111 of file worker_servicer.py.

_get_server_status()

control_pb2.ServerStatus worker_servicer._get_server_status ( float  start_time, float  end_time, int  port  )

private

Creates ServerStatus proto message.

Definition at line 59 of file worker_servicer.py.

_pick_an_unused_port()

int worker_servicer._pick_an_unused_port ( )

private

Picks an unused TCP port.

Definition at line 151 of file worker_servicer.py.

Variable Documentation

_LOGGER

worker_servicer._LOGGER = logging.getLogger(__name__)

private

Definition at line 41 of file worker_servicer.py.

_NUM_CORES

worker_servicer._NUM_CORES = multiprocessing.cpu_count()

private

Definition at line 37 of file worker_servicer.py.

_WORKER_ENTRY_FILE

worker_servicer._WORKER_ENTRY_FILE

private

Initial value:

=  os.path.join(
    os.path.split(os.path.abspath(__file__))[0], 'worker.py')

Definition at line 38 of file worker_servicer.py.