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

fix pointer print issue

Browse Source 
when response_result fail, it will try to print row value. When the failure is caused by ctrl+c, neteasy memory is released in response_result function and row memory is invalid.
This commit is contained in:
xc
2021-06-16 14:26:40 +08:00
committed by MizuhaHimuraki
parent 4a0238e2da
commit ad8465b5ce
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/mysql/ob_sync_cmd_driver.cpp
View File

@ -256,7 +256,7 @@ int ObSyncCmdDriver::response_query_result(ObMySQLResultSet& result)
ctx_.schema_guard_, ctx_.schema_guard_,
tmp_session->get_effective_tenant_id())); tmp_session->get_effective_tenant_id()));
if (OB_FAIL(sender_.response_packet(rp))) { if (OB_FAIL(sender_.response_packet(rp))) {
LOG_WARN("response packet fail", K(ret), K(*row)); LOG_WARN("response packet fail", K(ret), KP(row));
} }
} }
} }

2
src/observer/mysql/ob_sync_plan_driver.cpp
View File

@ -264,7 +264,7 @@ int ObSyncPlanDriver::response_query_result(
ctx_.schema_guard_, ctx_.schema_guard_,
session_.get_effective_tenant_id())); session_.get_effective_tenant_id()));
if (OB_FAIL(sender_.response_packet(rp))) { if (OB_FAIL(sender_.response_packet(rp))) {
LOG_WARN("response packet fail", K(ret), K(*row), K(row_num), K(can_retry)); LOG_WARN("response packet fail", K(ret), KP(row), K(row_num), K(can_retry));
// break; // break;
} else { } else {
// LOG_DEBUG("response row succ", K(*row)); // LOG_DEBUG("response row succ", K(*row));