dbus_mqtt.py 文件源码

def _refresh_keep_alive(self):
        if self._keep_alive_interval is None:
            return
        restart = False
        if self._keep_alive_timer is None:
            logging.info('[KeepAlive] Received request, publishing restarted')
            restart = True
        else:
            gobject.source_remove(self._keep_alive_timer)
        self._keep_alive_timer = gobject.timeout_add_seconds(
            self._keep_alive_interval, exit_on_error, self._on_keep_alive_timeout)
        if restart:
            # Do this after self._keep_alive_timer is set, because self._publish used it check if it should
            # publish
            self._publish_all()