Method _run

masfactory/visualizer/runtime.py:651–799

(self)

        return self._subscribed

    def _run(self) -> None:
        last_hb = 0.0
        reconnect_delay = 0.25

        while not self._stop.is_set():
            try:
                with self._lock:
                    host = self._host
                    port = self._port
                    mode = self._mode
                    graph_name = self._graph_name or "unknown"
                sock = socket.create_connection((host, port), timeout=3)
                try:
                    ws_handshake(sock, host, port)
                    sock.settimeout(0.05)
                    with self._lock:
                        self._connected = True

                    ws_send_text(
                        sock,
                        json.dumps(
                            {"type": "HELLO", "pid": self._pid, "graphName": graph_name, "mode": mode}
                        ),
                    )

                    buf = b""
                    last_hb = 0.0
                    self._subscribed = False
                    reconnect_delay = 0.25

                    while not self._stop.is_set():
                        now = time.time()

                        # Heartbeat (always)
                        if now - last_hb >= 0.5:
                            with self._lock:
                                graph_name = self._graph_name or "unknown"
                                mode = self._mode
                            ws_send_text(
                                sock,
                                json.dumps(
                                    {
                                        "type": "HEARTBEAT",
                                        "pid": self._pid,
                                        "graphName": graph_name,
                                        "mode": mode,
                                    }
                                ),
                            )
                            last_hb = now

                        # Send queued messages
                        for msg in self._drain_outq():
                            ws_send_text(sock, json.dumps(msg, ensure_ascii=False, default=str))

                        # Send graph lazily (run mode on subscribe; debug mode always)
                        with self._lock:
                            gv = self._graph_version