From 0cd99e2ca681f350440168f84f2dc195d95a02b4 Mon Sep 17 00:00:00 2001
From: zhjc1124 <zhjc1124@gmail.com>
Date: Fri, 25 Oct 2024 13:46:52 +0000
Subject: [PATCH] fix phy_queue dec ref leak

---
 src/share/io/ob_io_define.cpp | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/share/io/ob_io_define.cpp b/src/share/io/ob_io_define.cpp
index da347d0257..ccc1a8109b 100644
--- a/src/share/io/ob_io_define.cpp
+++ b/src/share/io/ob_io_define.cpp
@@ -2436,7 +2436,7 @@ int ObMClockQueue::pop_phyqueue(ObIORequest *&req, int64_t &deadline_ts)
             if (OB_ISNULL(next_req)) {
               ret = OB_ERR_UNEXPECTED;
               LOG_WARN("get null next_req", KP(next_req));
-            } else if (OB_FAIL(io_clock->calc_phyqueue_clock(tmp_phy_queue, *next_req))) {
+            } else if (OB_SUCCESS != io_clock->calc_phyqueue_clock(tmp_phy_queue, *next_req)) {
               LOG_WARN("calc phyqueue clock failed", K(ret), KPC(next_req));
             } else if (FALSE_IT(time_guard.click("R_calc_clock"))) {
             }
@@ -2545,8 +2545,8 @@ int ObMClockQueue::pop_with_ready_queue(const int64_t current_ts, ObIORequest *&
               LOG_WARN("calc phyqueue clock failed", K(ret));
             } else if (OB_UNLIKELY(OB_SUCCESS != tmp_ret)) {
               LOG_WARN("adjust reservation clock failed", K(tmp_ret), KPC(next_req));
-	    }
-	  }
+          }
+        }
         }
       }
       int tmp_ret = push_phyqueue(tmp_phy_queue);