#NEWLINE# def recv_server_show_jobs( self , raw_text ) : #NEWLINE# #INDENT# 'Slowly assemble a show jobs message line by line' #NEWLINE# if ( job_dict == '.' ) : #NEWLINE# #INDENT# output_response = tuple ( self . _status_response ) #NEWLINE# self . _recv_responses . append ( output_response ) #NEWLINE# self . _status_response = [ ] #NEWLINE# return False #NEWLINE# #UNINDENT# split_tokens = raw_text . split ( '\t' ) #NEWLINE# if ( len ( split_tokens ) != self . JOB_FIELDS ) : #NEWLINE# #INDENT# raise ProtocolError ( ( 'Received %d tokens, expected %d tokens: %r' % ( len ( split_tokens ) , self . JOB_FIELDS , split_tokens ) ) ) #NEWLINE# #UNINDENT# ( handle , queued_count , canceled_count , enabled_count ) = split_tokens #NEWLINE# job_dict = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# job_dict [ 'handle' ] = handle #NEWLINE# job_dict [ 'queued' ] = int ( queued_count ) #NEWLINE# job_dict [ 'canceled' ] = int ( canceled_count ) #NEWLINE# job_dict [ 'enabled' ] = int ( enabled_count ) #NEWLINE# self . _status_response . append ( job_dict ) #NEWLINE# return True