#NEWLINE# def test_client_status( ) : #NEWLINE# #INDENT# global PORT #NEWLINE# PORT += 1 #NEWLINE# n = 10 #NEWLINE# p_server = mp . Process ( target = start_server , args = ( n , False , 0 ) ) #NEWLINE# p_server . start ( ) #NEWLINE# time . sleep ( 1 ) #NEWLINE# class Client_With_Status ( jobmanager . JobManager_Client ) : #NEWLINE# #INDENT# def func( self , args , const_args , c , m ) : #NEWLINE# #INDENT# m . value = 100 #NEWLINE# for i in range ( m . value ) : #NEWLINE# #INDENT# c . value = ( i + 1 ) #NEWLINE# time . sleep ( 0.05 ) #NEWLINE# #UNINDENT# return os . getpid ( ) #NEWLINE# #UNINDENT# #UNINDENT# client = Client_With_Status ( server = SERVER , authkey = AUTHKEY , port = PORT , nproc = 4 , verbose = 1 ) #NEWLINE# client . start ( ) #NEWLINE# p_server . join ( )