Modify test_memindex, fix lock-order-inversion

Author: qinling0210

python/restart_test/test_memidx.py

@@ -539,7 +539,7 @@ def part1(infinity_obj):
             table_obj2.insert([{"c1": 4, "c2": [0.2, 0.1, 0.3, 0.4]} for i in range(6)])
 
             # wait for mem index dump
-            time.sleep(3)
+            time.sleep(10)
 
             # 2 chunk indexes for each index
             db1_dir = data_dir + "/db_2"
@@ -554,7 +554,7 @@ def part1(infinity_obj):
         @decorator2
         def part2(infinity_obj):
             # wait for optimize
-            time.sleep(3)
+            time.sleep(20)
 
             # new chunk index is generated after optimize for each index
             db1_dir = data_dir + "/db_2"

src/storage/catalog/meta/block_meta_impl.cpp

@@ -268,19 +268,24 @@ std::string BlockMeta::GetBlockTag(const std::string &tag) const {
 }
 
 std::tuple<size_t, Status> BlockMeta::GetRowCnt1() {
-    std::lock_guard<std::mutex> lock(mtx_);
-    if (row_cnt_) {
-        return {*row_cnt_, Status::OK()};
+    {
+        std::lock_guard<std::mutex> lock(mtx_);
+        if (row_cnt_) {
+            return {*row_cnt_, Status::OK()};
+        }
     }
 #if 1
     TableMeeta &table_meta = segment_meta_.table_meta();
-    row_cnt_ = infinity::GetBlockRowCount(&kv_instance_,
-                                          table_meta.db_id_str(),
-                                          table_meta.table_id_str(),
-                                          segment_meta_.segment_id(),
-                                          block_id_,
-                                          begin_ts_,
-                                          commit_ts_);
+    auto row_cnt = infinity::GetBlockRowCount(&kv_instance_,
+                                              table_meta.db_id_str(),
+                                              table_meta.table_id_str(),
+                                              segment_meta_.segment_id(),
+                                              block_id_,
+                                              begin_ts_,
+                                              commit_ts_);
+
+    std::lock_guard<std::mutex> lock(mtx_);
+    row_cnt_ = row_cnt;
     return {*row_cnt_, Status::OK()};
 #else
     Status status;