#NEWLINE# def sendDatapoint( self , metric , datapoint ) : #NEWLINE# #INDENT# instrumentation . increment ( self . attemptedRelays ) #NEWLINE# instrumentation . max ( self . relayMaxQueueLength , self . queueSize ) #NEWLINE# if ( self . queueSize >= settings . MAX_QUEUE_SIZE ) : #NEWLINE# #INDENT# if ( not self . queueFull . called ) : #NEWLINE# #INDENT# self . queueFull . callback ( self . queueSize ) #NEWLINE# #UNINDENT# instrumentation . increment ( metric . fullQueueDrops ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . enqueue ( metric , datapoint ) #NEWLINE# #UNINDENT# if self . connectedProtocol : #NEWLINE# #INDENT# self . scheduleSend ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# instrumentation . increment ( self . queuedUntilConnected )