#NEWLINE# def communicate( self , * args , **kwargs ) : #NEWLINE# #INDENT# sent = False #NEWLINE# if self . bulk : #NEWLINE# #INDENT# while self . port . fifo . can_read ( self . peer_id ) : #NEWLINE# #INDENT# sent = True #NEWLINE# self . _send_one_token ( ) #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# if ( self . port . fifo . can_read ( self . peer_id ) and ( self . port . fifo . tentative_read_pos [ self . peer_id ] == self . port . fifo . read_pos [ self . peer_id ] ) and ( time . time ( ) >= self . time_cont ) ) : #NEWLINE# #INDENT# self . _send_one_token ( ) #NEWLINE# sent = True #NEWLINE# self . time_cont = ( time . time ( ) + self . backoff ) #NEWLINE# self . trigger_loop ( self . backoff ) #NEWLINE# #UNINDENT# #UNINDENT# return sent