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

fix io req core when req is pushed to queue but req is cleared

Browse Source
This commit is contained in:
obdev 2024-09-25 20:49:45 +00:00 committed by ob-robot
parent eaa9822c46
commit e7bd5eab11
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/share/io/ob_io_struct.cpp
View File

@ -1200,7 +1200,7 @@ int ObIOSender::enqueue_request(ObIORequest &req)
//phy_queue from idle to active
int tmp_ret = OB_SUCCESS;
tmp_ret = io_clock->try_sync_tenant_clock(io_clock);
if (OB_FAIL(io_clock->calc_phyqueue_clock(tmp_phy_queue, req))) {
if (OB_TMP_FAIL(io_clock->calc_phyqueue_clock(tmp_phy_queue, req))) {
LOG_WARN("calc phyqueue clock failed", K(ret), K(tmp_phy_queue->queue_index_));
} else if (OB_UNLIKELY(OB_SUCCESS != tmp_ret)) {
LOG_WARN("sync tenant clock failed", K(tmp_ret));
@ -1462,7 +1462,10 @@ int ObIOSender::inc_queue_count(const ObIORequest &req) {
int ObIOSender::dec_queue_count(const ObIORequest &req) {
int ret = OB_SUCCESS;
ATOMIC_DEC(&sender_req_count_);
if (req.fd_.device_handle_->is_object_device()) {
if (OB_ISNULL(req.fd_.device_handle_)) {
ret = OB_INVALID_ARGUMENT;
LOG_ERROR("req is cleared", K(ret), K(req), K(req.fd_));
} else if (req.fd_.device_handle_->is_object_device()) {
if (req.get_mode() == ObIOMode::READ) {
ATOMIC_DEC(&sender_req_remote_r_count_);
} else if (req.get_mode() == ObIOMode::WRITE) {