{"record":{"id":"ca2a0068e75608f0","repo":"sqlmapproject/sqlmap","slug":"cubrid-broker-rejected-the-connection-status-d","errorCode":null,"errorMessage":"CUBRID broker rejected the connection (status %d)","messagePattern":"CUBRID broker rejected the connection \\(status (.+?)\\)","errorType":"exception","errorClass":"OperationalError","httpStatus":null,"severity":"error","filePath":"extra/dbwire/cubrid.py","lineNumber":277,"sourceCode":"            if self._sock is not None:\n                self._sock.close()\n        except Exception:\n            pass\n        self._sock = None\n\n    def _recvn(self, n):\n        return recvn(self._sock, n)\n\n    def _open(self):\n        # broker handshake (may redirect to a dedicated CAS worker port), then cleartext OPEN_DATABASE login\n        try:\n            sock = socket.create_connection((self._host, self._port), timeout=self._timeout)\n            keepalive(sock)\n            sock.sendall(_MAGIC + struct.pack(\">BB\", _CLIENT_JDBC, _CAS_VERSION) + b\"\\x00\\x00\\x00\")\n            self._sock = sock\n            (port,) = struct.unpack(\">i\", self._recvn(4))\n            if port < 0:\n                raise OperationalError(\"CUBRID broker rejected the connection (status %d)\" % port)\n            if port > 0:  # redirected to a CAS worker: reconnect there, no second handshake\n                self._safe_close()\n                sock = socket.create_connection((self._host, port), timeout=self._timeout)\n                keepalive(sock)\n                self._sock = sock\n\n            login = self._fixed(self._database, 32) + self._fixed(self._user, 32) + self._fixed(self._password, 32)\n            login += b\"\\x00\" * 532  # 512 extended-info + 20 reserved\n            self._sock.sendall(login)\n            reader = self._read_response()\n            reader.int()             # response_code (>=0; errors already raised in _read_response)\n            broker = reader.raw(8)\n            self._protocol_version = bytearray(broker)[4] & 0x3f\n            # enable auto-commit so each statement is independent (avoids the CAS keep-connection handshake dance)\n            self._call(_Writer(_FC_SET_DB_PARAMETER).arg_int(_PARAM_AUTO_COMMIT).arg_int(1))\n        except (socket.error, socket.timeout) as ex:\n            self._safe_close()\n            raise OperationalError(\"could not connect to '%s:%s' (%s)\" % (self._host, self._port, ex))","sourceCodeStart":259,"sourceCodeEnd":295,"githubUrl":"https://github.com/sqlmapproject/sqlmap/blob/0a35b20e3953d341be6c7ac75ccb0b3362540c8d/extra/dbwire/cubrid.py#L259-L295","documentation":"Error \"CUBRID broker rejected the connection (status %d)\" thrown in sqlmapproject/sqlmap.","triggerScenarios":"Thrown at extra/dbwire/cubrid.py:277 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":[],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"0a35b20e3953d341be6c7ac75ccb0b3362540c8d","analyzedAt":"2026-08-26T23:02:52.002Z","schemaVersion":2},"datasetVersion":"2026-08-27T03:17:27.898Z"}