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

log both user error code and internal error code while sending error packet

Browse Source
This commit is contained in:
hnwyllmm
2022-04-25 14:18:22 +08:00
committed by wangzelin.wzl
parent d915c6dd26
commit 209802bc49
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/observer/mysql/obmp_base.cpp
View File

@ -1232,8 +1232,11 @@ int ObMPBase::send_error_packet(
OMPKError epacket; OMPKError epacket;
// TODO Negotiate a err for rerouting sql // TODO Negotiate a err for rerouting sql
epacket.set_errcode(static_cast<uint16_t>(ob_errpkt_errno(err, lib::is_oracle_mode()))); const int user_error_code = ob_errpkt_errno(err, lib::is_oracle_mode());
ret = epacket.set_sqlstate(ob_sqlstate(err)); const char *sql_state = ob_sqlstate(err);
LOG_INFO("send error package.", K(user_error_code), K(err), K(sql_state), K(message));
epacket.set_errcode(static_cast<uint16_t>(user_error_code));
ret = epacket.set_sqlstate(sql_state);
if (OB_SUCC(ret) && OB_SUCC(epacket.set_message(message))) { if (OB_SUCC(ret) && OB_SUCC(epacket.set_message(message))) {
comp_context_.update_last_pkt_pos(ez_buf_->last); comp_context_.update_last_pkt_pos(ez_buf_->last);
if (OB_FAIL(response_packet(epacket))) { if (OB_FAIL(response_packet(epacket))) {