Worker This is a subclass of thread that submits commands to the server and stores the result in a thread-safe queue. More...

Inheritance diagram for cmsPerfClient.Worker:

Public Member Functions
def	__init__ (self, host, port, perfcmds, queue)

def	run (self)

Private Attributes
	__host

	__perfcmds

	__port

	__queue

Detailed Description

Worker This is a subclass of thread that submits commands to the server and stores the result in a thread-safe queue.

Definition at line 248 of file cmsPerfClient.py.

Constructor & Destructor Documentation

def cmsPerfClient.Worker.__init__	(	self,
		host,
		port,
		perfcmds,
		queue
	)

Definition at line 250 of file cmsPerfClient.py.

     def __init__(self, host, port, perfcmds, queue):
         self.__perfcmds = perfcmds
         self.__host  = host
         self.__port  = port
         self.__queue = queue
         threading.Thread.__init__(self)
 

Member Function Documentation

def cmsPerfClient.Worker.run ( self )

Definition at line 257 of file cmsPerfClient.py.

References cmsPerfClient.Worker.__host, cmsPerfClient.Worker.__perfcmds, cmsPerfClient.Worker.__port, edm.print(), and cmsPerfClient.request_benchmark().

     def run(self):
         try:
             data = request_benchmark(self.__perfcmds, self.__host, self.__port)
             #Debugging
             print("data is %s"%data)
             print("Puttin it in the queue as (%s,%s)"%(self.__host,data))
             self.__queue.put((self.__host, data))
         except (exceptions.Exception, xmlrpclib.Fault) as detail:
             print("Exception was thrown when receiving/submitting job information to host", self.__host, ". Exception information:")
             print(detail)
             sys.stdout.flush()
 