itest ut

apache · Jan 2, 2024 · 7e30701 · 7e30701
1 parent cd349b0
commit 7e30701
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/interface/common/resdb_state_accessor.cpp b/interface/common/resdb_state_accessor.cpp
@@ -43,13 +43,15 @@ ResDBStateAccessor::GetReplicaStates() {
   std::unique_ptr<NetChannel> client =
       GetNetChannel(client_info.ip(), client_info.port());
   client->SetRecvTimeout(1000000);  // 1s for recv timeout.
-
+
+  LOG(ERROR)<<"send request";
   int ret = client->SendRequest(request, Request::TYPE_REPLICA_STATE);
   if (ret) {
     return absl::InternalError("send data fail.");
   }
 
   std::unique_ptr<ReplicaState> state = std::make_unique<ReplicaState>();
+  LOG(ERROR)<<"recv request";
   ret = client->RecvRawMessage(state.get());
   if (ret < 0) {
     return absl::InternalError("recv data fail.");

diff --git a/interface/common/resdb_state_accessor_test.cpp b/interface/common/resdb_state_accessor_test.cpp
@@ -98,6 +98,7 @@ TEST_F(StateClientTest, GetAllReplicaState) {
       }));
   auto ret = client.GetReplicaStates();
   EXPECT_TRUE(ret.ok());
+  LOG(ERROR)<<"get ok";
   std::set<int> results;
   for (auto& state : *ret) {
     auto it = std::find_if(
@@ -107,6 +108,7 @@ TEST_F(StateClientTest, GetAllReplicaState) {
     EXPECT_TRUE(it != replicas_.end());
     results.insert(it - replicas_.begin());
   }
+  LOG(ERROR)<<"get result ok";
   EXPECT_EQ(results.size(), 4);
 }