{"record":{"id":"e56a55fab393d911","repo":"vllm-project/vllm","slug":"error-processing-message-e","errorCode":null,"errorMessage":"Error processing message: {e}","messagePattern":"Error processing message: (.+?)","errorType":"exception","errorClass":"HandshakeError","httpStatus":null,"severity":"error","filePath":"vllm/distributed/kv_transfer/kv_connector/v1/moriio/moriio_engine.py","lineNumber":719,"sourceCode":"    def async_wait_reqid(self):\n        assert self.notify_port is not None, \"Notify port cannot be None\"\n\n        if self.notify_thread is not None:\n            return\n\n        def _async_wait():\n            host = \"*\"\n            path = make_zmq_path(\"tcp\", host, self.notify_port)\n            logger.info(\"Node starting to listen notify from path = %s\", path)\n\n            with zmq_ctx(zmq.ROUTER, path) as sock:\n                while True:\n                    try:\n                        identity, msg = sock.recv_multipart()\n                        self._handle_message(msg)\n                    except Exception as e:\n                        logger.error(\"Error processing message: %s\", e)\n                        raise HandshakeError(f\"Error processing message: {e}\") from e\n\n        self.notify_thread = threading.Thread(\n            target=_async_wait, daemon=True, name=\"moriio-notify-listener\"\n        )\n        self.notify_thread.start()\n\n    def _handle_message(self, msg: bytes):\n        \"\"\"Handles incoming messages from remote nodes.\"\"\"\n        # Handles incoming remote messages:\n        # Prefill Role:\n        #   [write] mode: receives block information (allocation)\n        #   [read]  mode: receives block release messages from decode side\n        # Decode Role:\n        #   [write] mode: receives KV cache write completion notifications\n        msg_str = repr(msg)\n        handled = False\n        try:\n            data = msgpack.loads(msg)","sourceCodeStart":701,"sourceCodeEnd":737,"githubUrl":"https://github.com/vllm-project/vllm/blob/c794754062d49a8fdb63ab3c5215b488b865030c/vllm/distributed/kv_transfer/kv_connector/v1/moriio/moriio_engine.py#L701-L737","documentation":"Error \"Error processing message: {e}\" thrown in vllm-project/vllm.","triggerScenarios":"Raised at vllm/distributed/kv_transfer/kv_connector/v1/moriio/moriio_engine.py:719 when validation fails: Error processing message. Typically triggered by an incompatible or incomplete vLLM configuration, an unsupported platform/backend combination, or a runtime resource/dependency that is missing.","commonSituations":"Commonly encountered at vllm/distributed/kv_transfer/kv_connector/v1/moriio/moriio_engine.py:719 during vLLM startup/config validation or runtime setup when: (1) conflicting CLI flags or config fields are combined, (2) the current platform (CUDA/ROCm/CPU/XPU) or installed optional packages do not support the requested feature, or (3) a required value is absent or out of range. Resolve by correcting the configuration as described in the message, or by selecting a supported alternative.","solutions":["Inspect the wrapped error to diagnose the malformed or failed MoRIIO control message."],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"c794754062d49a8fdb63ab3c5215b488b865030c","analyzedAt":"2026-08-14T21:17:39.825Z","schemaVersion":2},"datasetVersion":"2026-08-15T17:31:12.345Z"}