(incubator-resilientdb) branch fix_test updated: ft

[junchao]

This is an automated email from the ASF dual-hosted git repository.

junchao pushed a commit to branch fix_test
in repository https://gitbox.apache.org/repos/asf/incubator-resilientdb.git


The following commit(s) were added to refs/heads/fix_test by this push:
     new 142a2238 ft
142a2238 is described below

commit 142a22381ec454a02f8b7f5438c5831ff1d8a8e2
Author: Ubuntu <ubuntu@ip-172-31-45-3.ec2.internal>
AuthorDate: Wed Jan 3 12:19:47 2024 +0000

    ft
---
 interface/common/resdb_txn_accessor.cpp | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/interface/common/resdb_txn_accessor.cpp 
b/interface/common/resdb_txn_accessor.cpp
index 55ef23b4..f83490f8 100644
--- a/interface/common/resdb_txn_accessor.cpp
+++ b/interface/common/resdb_txn_accessor.cpp
@@ -50,6 +50,7 @@ ResDBTxnAccessor::GetTxn(uint64_t min_seq, uint64_t max_seq) {
   std::condition_variable resp_cv;
   bool success = false;
   std::map<std::string, int> recv_count;
+  LOG(ERROR)<<"?????";
   for (const auto& replica : replicas_) {
     std::unique_ptr<NetChannel> client =
         GetNetChannel(replica.ip(), replica.port());
@@ -81,6 +82,7 @@ ResDBTxnAccessor::GetTxn(uint64_t min_seq, uint64_t max_seq) {
         client_ptr));
   }
 
+  LOG(ERROR)<<"?????";
   {
     std::unique_lock<std::mutex> lck(mtx);
     resp_cv.wait_for(lck, std::chrono::seconds(recv_timeout_));
@@ -89,6 +91,7 @@ ResDBTxnAccessor::GetTxn(uint64_t min_seq, uint64_t max_seq) {
       client->Close();
     }
   }
+  LOG(ERROR)<<"?????";
 
   // wait for all theads done.
   for (auto& th : ths) {
@@ -97,19 +100,23 @@ ResDBTxnAccessor::GetTxn(uint64_t min_seq, uint64_t 
max_seq) {
     }
   }
 
+  LOG(ERROR)<<"?????";
   std::vector<std::pair<uint64_t, std::string>> txn_resp;
   QueryResponse resp;
   if (success && final_str.empty()) {
     return txn_resp;
   }
 
+  LOG(ERROR)<<"?????";
   if (final_str.empty() || !resp.ParseFromString(final_str)) {
     LOG(ERROR) << "parse fail len:" << final_str.size();
     return absl::InternalError("recv data fail.");
   }
+  LOG(ERROR)<<"?????";
   for (auto& transaction : resp.transactions()) {
     txn_resp.push_back(std::make_pair(transaction.seq(), transaction.data()));
   }
+  LOG(ERROR)<<"?????";
   return txn_resp;
 }