#NEWLINE# def notifyDone( self , relay ) : #NEWLINE# #INDENT# "A relaying SMTP client is disconnected.\n\n        unmark all pending messages under this relay's responsibility\n        as being relayed, and remove the relay.\n        " #NEWLINE# for message in self . manager . managed . get ( relay , ( ) ) : #NEWLINE# #INDENT# if self . manager . queue . noisy : #NEWLINE# #INDENT# log . msg ( ( ( 'Setting ' + d ) + ' waiting' ) ) #NEWLINE# #UNINDENT# self . manager . queue . setWaiting ( message ) #NEWLINE# #UNINDENT# try : #NEWLINE# #INDENT# del self . manager . managed [ relay ] #NEWLINE# #UNINDENT# except KeyError : #NEWLINE# #INDENT# pass #NEWLINE# #UNINDENT# notifications = self . _completionDeferreds #NEWLINE# self . _completionDeferreds = None #NEWLINE# for d in notifications : #NEWLINE# #INDENT# d . callback ( None )