#NEWLINE# def __init__( self , destination ) : #NEWLINE# #INDENT# self . destination = destination #NEWLINE# self . destinationName = ( '%s:%d:%s' % destination ) . replace ( '.' , '_' ) #NEWLINE# ( self . host , self . port , self . carbon_instance ) = destination #NEWLINE# self . addr = ( self . host , self . port ) #NEWLINE# self . started = False #NEWLINE# self . queue = deque ( ) #NEWLINE# self . connectedProtocol = None #NEWLINE# self . queueEmpty = Deferred ( ) #NEWLINE# self . queueFull = Deferred ( ) #NEWLINE# self . queueFull . addCallback ( self . queueFullCallback ) #NEWLINE# self . queueHasSpace = Deferred ( ) #NEWLINE# self . queueHasSpace . addCallback ( self . queueSpaceCallback ) #NEWLINE# self . connectFailed = Deferred ( ) #NEWLINE# self . connectionMade = Deferred ( ) #NEWLINE# self . connectionLost = Deferred ( ) #NEWLINE# self . deferSendPending = None #NEWLINE# self . attemptedRelays = ( 'destinations.%s.attemptedRelays' % destination . destinationName ) #NEWLINE# self . fullQueueDrops = ( 'destinations.%s.fullQueueDrops' % self . destinationName ) #NEWLINE# self . queuedUntilConnected = ( 'destinations.%s.queuedUntilConnected' % self . destinationName ) #NEWLINE# self . relayMaxQueueLength = ( 'destinations.%s.relayMaxQueueLength' % self . destinationName )