#NEWLINE# def tell( self , anActor , msg ) : #NEWLINE# #INDENT# attemptLimit = ExpiryTime ( MAX_TELL_PERIOD ) #NEWLINE# import socket #NEWLINE# for attempt in range ( 5000 ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# self . transport . scheduleTransmit ( None , TransmitIntent ( anActor , msg , onError = self . _tellFailed ) ) #NEWLINE# while ( not attemptLimit . expired ( ) ) : #NEWLINE# #INDENT# if ( not self . transport . run ( TransmitOnly , attemptLimit . remaining ( ) ) ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# #UNINDENT# return #NEWLINE# #UNINDENT# except socket . error as ex : #NEWLINE# #INDENT# import errno #NEWLINE# if ( errno . EMFILE == ex . errno ) : #NEWLINE# #INDENT# import time #NEWLINE# time . sleep ( 0.1 ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise