Public Member Functions | |
def | __init__ (self, server_port=None) |
def | CoreCount (self, request, context) |
def | QuitWorker (self, request, context) |
def | RunClient (self, request_iterator, context) |
def | RunServer (self, request_iterator, context) |
def | wait_for_quit (self) |
Private Member Functions | |
def | _create_client_runner (self, server, config, qps_data) |
def | _create_server (self, config) |
def | _get_client_status (self, start_time, end_time, qps_data) |
def | _get_server_status (self, start_time, end_time, port, cores) |
Private Attributes | |
_quit_event | |
_server_port | |
Python Worker Server implementation.
Definition at line 35 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.__init__ | ( | self, | |
server_port = None |
|||
) |
Definition at line 38 of file worker_server.py.
|
private |
Definition at line 150 of file worker_server.py.
|
private |
Definition at line 66 of file worker_server.py.
|
private |
Definition at line 140 of file worker_server.py.
|
private |
Definition at line 58 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.CoreCount | ( | self, | |
request, | |||
context | |||
) |
Definition at line 189 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.QuitWorker | ( | self, | |
request, | |||
context | |||
) |
Definition at line 192 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.RunClient | ( | self, | |
request_iterator, | |||
context | |||
) |
Definition at line 110 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.RunServer | ( | self, | |
request_iterator, | |||
context | |||
) |
Definition at line 42 of file worker_server.py.
def tests.qps.worker_server.WorkerServer.wait_for_quit | ( | self | ) |
Definition at line 196 of file worker_server.py.
|
private |
Definition at line 39 of file worker_server.py.
|
private |
Definition at line 40 of file worker_server.py.