#NEWLINE# def __init__( self , addr , * args , **kwargs ) : #NEWLINE# #INDENT# fd = kwargs . get ( 'fd' ) #NEWLINE# if ( fd is None ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# os . remove ( addr ) #NEWLINE# #UNINDENT# except OSError : #NEWLINE# #INDENT# pass #NEWLINE# #UNINDENT# #UNINDENT# sock = socket . socket ( socket . AF_UNIX , socket . SOCK_STREAM ) #NEWLINE# sock . setsockopt ( socket . SOL_SOCKET , socket . SO_REUSEADDR , 1 ) #NEWLINE# if ( fd is None ) : #NEWLINE# #INDENT# sock . bind ( addr ) #NEWLINE# #UNINDENT# sock . setblocking ( 0 ) #NEWLINE# self . sock = sock #NEWLINE# self . fd = fd #NEWLINE# self . addr = addr #NEWLINE# self . backlog = kwargs . get ( 'backlog' , 128 ) #NEWLINE# self . timeout = socket . getdefaulttimeout ( ) #NEWLINE# self . sock . listen ( self . backlog )