hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [to #2024072000103865240] fix: response -9747 error packet and disconnect session when send piece protocol failed

Browse Source
This commit is contained in:
haohao022
2024-08-12 08:18:16 +00:00
committed by ob-robot
parent 8df78306db
commit 4e1728cb01
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/observer/mysql/obmp_stmt_send_piece_data.cpp
View File

@ -81,7 +81,7 @@ int ObMPStmtSendPieceData::before_process()
is_null_ = (1 == is_null);
ObMySQLUtil::get_int8(pos, buffer_len_);
if (stmt_id_ < 1 || buffer_len_ < 0) {
ret = OB_ERR_PARAM_INVALID;
ret = OB_ERR_MALFORMED_PS_PACKET;
LOG_WARN("send_piece receive unexpected params", K(ret), K(stmt_id_), K(buffer_len_));
} else if (param_id_ >= OB_PARAM_ID_OVERFLOW_RISK_THRESHOLD) {
LOG_WARN("param_id_ has the risk of overflow", K(ret), K(stmt_id_), K(param_id_));
@ -96,6 +96,13 @@ int ObMPStmtSendPieceData::before_process()
LOG_INFO("resolve send_piece protocol packet",
K(ret), K(stmt_id_), K(param_id_), K(buffer_len_), K(piece_mode_), K(is_null_));
}
if (OB_FAIL(ret)) {
send_error_packet(ret, nullptr);
force_disconnect();
LOG_WARN("force disconnect connection", K(ret));
}
return ret;
}