[LOG] add log for read during transfer

src/storage/memtable/mvcc/ob_mvcc_iterator.cpp

@@ -56,13 +56,22 @@ int ObMvccValueIterator::init(ObMvccAccessCtx &ctx,
     }
   }
 
-  TRANS_LOG(TRACE, "value_iter.init", K(ret),
-            KPC(value),
-            KPC_(version_iter),
-            K(query_flag.is_read_latest()),
-            KPC(key),
-            K(ctx),
-            K(lbt()));
+  if (ctx_->get_tx_table_guards().during_transfer()) {
+    TRANS_LOG(INFO, "value_iter.init", K(ret),
+              KPC(value),
+              KPC_(version_iter),
+              K(query_flag),
+              KPC(key),
+              K(ctx));
+  } else {
+    TRANS_LOG(TRACE, "value_iter.init", K(ret),
+              KPC(value),
+              KPC_(version_iter),
+              K(query_flag.is_read_latest()),
+              KPC(key),
+              K(ctx),
+              K(lbt()));
+  }
   return ret;
 }
 

src/storage/tx_table/ob_tx_table_guards.cpp

@@ -320,6 +320,11 @@ bool ObTxTableGuards::is_need_read_src(const share::SCN scn) const
   return is_need;
 }
 
+bool ObTxTableGuards::during_transfer() const
+{
+  return src_tx_table_guard_.is_valid()
+    && transfer_start_scn_.is_valid();
+}
 
 } // end namespace oceanbase
 }

src/storage/tx_table/ob_tx_table_guards.h

@@ -140,6 +140,7 @@ public:
       const bool need_row_latch);
   bool check_ls_offline();
   bool is_need_read_src(const share::SCN scn) const;
+  bool during_transfer() const;
   TO_STRING_KV(K_(tx_table_guard), K_(src_tx_table_guard), K_(transfer_start_scn));
 public:
   storage::ObTxTableGuard tx_table_guard_;