Public Member Functions | Private Member Functions | Private Attributes | List of all members
tests.qps.worker_server.WorkerServer Class Reference
Inheritance diagram for tests.qps.worker_server.WorkerServer:
Inheritance graph
[legend]

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
 

Detailed Description

Python Worker Server implementation.

Definition at line 35 of file worker_server.py.

Constructor & Destructor Documentation

◆ __init__()

def tests.qps.worker_server.WorkerServer.__init__ (   self,
  server_port = None 
)

Definition at line 38 of file worker_server.py.

Member Function Documentation

◆ _create_client_runner()

def tests.qps.worker_server.WorkerServer._create_client_runner (   self,
  server,
  config,
  qps_data 
)
private

Definition at line 150 of file worker_server.py.

◆ _create_server()

def tests.qps.worker_server.WorkerServer._create_server (   self,
  config 
)
private

Definition at line 66 of file worker_server.py.

◆ _get_client_status()

def tests.qps.worker_server.WorkerServer._get_client_status (   self,
  start_time,
  end_time,
  qps_data 
)
private

Definition at line 140 of file worker_server.py.

◆ _get_server_status()

def tests.qps.worker_server.WorkerServer._get_server_status (   self,
  start_time,
  end_time,
  port,
  cores 
)
private

Definition at line 58 of file worker_server.py.

◆ CoreCount()

def tests.qps.worker_server.WorkerServer.CoreCount (   self,
  request,
  context 
)

Definition at line 189 of file worker_server.py.

◆ QuitWorker()

def tests.qps.worker_server.WorkerServer.QuitWorker (   self,
  request,
  context 
)

Definition at line 192 of file worker_server.py.

◆ RunClient()

def tests.qps.worker_server.WorkerServer.RunClient (   self,
  request_iterator,
  context 
)

Definition at line 110 of file worker_server.py.

◆ RunServer()

def tests.qps.worker_server.WorkerServer.RunServer (   self,
  request_iterator,
  context 
)

Definition at line 42 of file worker_server.py.

◆ wait_for_quit()

def tests.qps.worker_server.WorkerServer.wait_for_quit (   self)

Definition at line 196 of file worker_server.py.

Member Data Documentation

◆ _quit_event

tests.qps.worker_server.WorkerServer._quit_event
private

Definition at line 39 of file worker_server.py.

◆ _server_port

tests.qps.worker_server.WorkerServer._server_port
private

Definition at line 40 of file worker_server.py.


The documentation for this class was generated from the following file:


grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:52