def __init__(self, address, reply_handler=None):
    self.pending_vars = {}
    self.address = address
    self._scene = None
    self._cached_scene = None
    self.reply_handler = reply_handler
    if os.path.exists(address):
        os.remove(address)
    SYSTEMD_SOCK_FD = 3
    self.server = socket.fromfd(SYSTEMD_SOCK_FD, socket.AF_UNIX, socket.SOCK_STREAM)
    self.socket = None
    self._is_batch = False
    self._batch_scene_updated = False
    self._batch_vars = None
    hotrefresh.init(self)
def __init__(self, address, reply_handler=None):
    self.pending_vars = {}
    self.address = address
    self._scene = None
    self._cached_scene = None
    self.reply_handler = reply_handler
    if os.path.exists(address):
        os.remove(address)
    SYSTEMD_SOCK_FD = 3
    self.server = socket.fromfd(SYSTEMD_SOCK_FD, socket.AF_UNIX, socket.SOCK_STREAM)
    self.socket = None
    self._is_batch = False
    self._batch_scene_updated = False
    self._batch_vars = None
    hotrefresh.init(self)