def __init__(self, addr, *args, **kwargs):
        fd = kwargs.get('fd')
        if fd is None:
            try:
                os.remove(addr)
            except __HOLE__:
                pass

        sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
        sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

        if fd is None:
            sock.bind(addr)
        sock.setblocking(0)

        self.sock = sock
        self.fd = fd
        self.addr = addr
        self.backlog = kwargs.get('backlog', 128)
        self.timeout = socket.getdefaulttimeout()

        # start to listen
        self.sock.listen(self.backlog)
dataset/ETHPy150Open benoitc/flower/flower/net/sock.py/PipeSockListen.__init__