#NEWLINE# def test_multiple_status( self ) : #NEWLINE# #INDENT# self . send_server_command ( GEARMAN_SERVER_COMMAND_STATUS ) #NEWLINE# self . recv_server_response ( '\t' . join ( [ 'test_function' , '1' , '5' , '17' ] ) ) #NEWLINE# self . recv_server_response ( '\t' . join ( [ 'another_function' , '2' , '4' , '23' ] ) ) #NEWLINE# self . recv_server_response ( '.' ) #NEWLINE# server_response = self . pop_response ( GEARMAN_SERVER_COMMAND_STATUS ) #NEWLINE# self . assertEquals ( len ( server_response ) , 2 ) #NEWLINE# ( test_response , another_response ) = server_response #NEWLINE# self . assertEquals ( test_response [ 'task' ] , 'test_function' ) #NEWLINE# self . assertEquals ( test_response [ 'queued' ] , 1 ) #NEWLINE# self . assertEquals ( test_response [ 'running' ] , 5 ) #NEWLINE# self . assertEquals ( test_response [ 'workers' ] , 17 ) #NEWLINE# self . assertEquals ( test_response [ 'task' ] , 'another_function' ) #NEWLINE# self . assertEquals ( another_response [ 'queued' ] , 2 ) #NEWLINE# self . assertEquals ( another_response [ 'running' ] , 4 ) #NEWLINE# self . assertEquals ( another_response [ 'workers' ] , 23 )