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

fix get_req_receive_mts_ core dump

Browse Source
This commit is contained in:
obdev
2023-02-07 18:54:52 +08:00
committed by ob-robot
parent 2555a03217
commit 106814e594
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/tx/ob_trans_service_v4.cpp
View File

@ -1405,6 +1405,7 @@ int ObTransService::wait_follower_readable_(ObLS &ls,
MonotonicTs ObTransService::get_req_receive_mts_() MonotonicTs ObTransService::get_req_receive_mts_()
{ {
/*
MonotonicTs mts; MonotonicTs mts;
const rpc::ObRequest *req = THIS_WORKER.get_cur_request(); const rpc::ObRequest *req = THIS_WORKER.get_cur_request();
if (NULL != req && req->get_receive_mts().is_valid()) { if (NULL != req && req->get_receive_mts().is_valid()) {
@ -1413,6 +1414,8 @@ MonotonicTs ObTransService::get_req_receive_mts_()
mts = MonotonicTs::current_time(); mts = MonotonicTs::current_time();
} }
return mts; return mts;
*/
return MonotonicTs::current_time();
} }
/* /*
@ -1532,7 +1535,7 @@ int ObTransService::acquire_global_snapshot__(const int64_t expire_ts,
const MonotonicTs now0 = get_req_receive_mts_(); const MonotonicTs now0 = get_req_receive_mts_();
const MonotonicTs now = now0 - MonotonicTs(gts_ahead); const MonotonicTs now = now0 - MonotonicTs(gts_ahead);
int retry_times = 0; int retry_times = 0;
const int MAX_RETRY_TIMES = 10; const int MAX_RETRY_TIMES = 100;
do { do {
int64_t n = ObClockGenerator::getClock(); int64_t n = ObClockGenerator::getClock();
MonotonicTs rts(0); MonotonicTs rts(0);