fix ci

vesoft-inc · Nov 22, 2021 · 7c243aa · 7c243aa
1 parent 061be2f
commit 7c243aa
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 6 deletions.
diff --git a/.github/workflows/pull_request.yml b/.github/workflows/pull_request.yml
@@ -132,6 +132,7 @@ jobs:
           echo '127.0.0.1 graphd' >> /etc/hosts
           echo '127.0.0.1 graphd1' >> /etc/hosts
           echo '127.0.0.1 graphd2' >> /etc/hosts
+          echo '127.0.0.1 server' >> /etc/hosts
       - name: CTest
         env:
           ASAN_OPTIONS: fast_unwind_on_malloc=1

diff --git a/src/mclient/MetaClient.cpp b/src/mclient/MetaClient.cpp
@@ -27,7 +27,15 @@ MetaClient::MetaClient(const std::vector<std::string>& metaAddrs) {
   ioExecutor_ = std::make_shared<folly::IOThreadPoolExecutor>(std::thread::hardware_concurrency());
   clientsMan_ =
       std::make_shared<thrift::ThriftClientManager<meta::cpp2::MetaServiceAsyncClient>>(false);
-  loadData();  // load data into cache
+  bool b = loadData();  // load data into cache
+  if (!b) {
+    LOG(INFO) << "load data failed";
+  } else {
+    LOG(INFO) << "load data succecced";
+    LOG(INFO) << spaceIndexByName_.size();
+    LOG(INFO) << spaceEdgeIndexByName_.size();
+    LOG(INFO) << spacePartLeaderMap_.size();
+  }
 }
 
 MetaClient::~MetaClient() = default;

diff --git a/src/mclient/tests/MetaClientTest.cpp b/src/mclient/tests/MetaClientTest.cpp
@@ -19,7 +19,7 @@
 
 // Require a nebula server could access
 
-#define kServerHost "127.0.0.1"
+#define kServerHost "server"
 
 class MetaClientTest : public ClientTest {
  protected:
@@ -58,13 +58,16 @@ class MetaClientTest : public ClientTest {
 
     auto ret4 = c.getPartLeaderFromCache(spaceId, 1);
     ASSERT_TRUE(ret4.first);
-    EXPECT_EQ(ret4.second, nebula::HostAddr("127.0.0.1", 9779));
+    EXPECT_EQ(ret4.second, nebula::HostAddr(kServerHost, 9779));
   }
 };
 
 TEST_F(MetaClientTest, Basic) {
-  nebula::MetaClient c({kServerHost ":9559"});
+  LOG(INFO) << "Prepare data.";
   prepare();
+
+  LOG(INFO) << "Run once.";
+  nebula::MetaClient c({kServerHost ":9559"});
   runOnce(c);
 }
 

diff --git a/src/sclient/ScanEdgeIter.cpp b/src/sclient/ScanEdgeIter.cpp
@@ -29,6 +29,7 @@ DataSet ScanEdgeIter::next() {
     auto partCursorMapReq = req_->get_parts();
     DCHECK_EQ(partCursorMapReq.size(), 1);
     partCursorMapReq.begin()->second.set_next_cursor(nextCursor_);
+    LOG(INFO) << "nextCursor of req: " << partCursorMapReq.begin()->second.get_next_cursor();
     req_->set_parts(partCursorMapReq);
   }
   auto r = client_->doScanEdge(*req_);

diff --git a/src/sclient/tests/StorageClientTest.cpp b/src/sclient/tests/StorageClientTest.cpp
@@ -19,7 +19,7 @@
 
 // Require a nebula server could access
 
-#define kServerHost "127.0.0.1"
+#define kServerHost "server"
 
 class StorageClientTest : public ClientTest {
  protected:
@@ -107,8 +107,9 @@ class StorageClientTest : public ClientTest {
 };
 
 TEST_F(StorageClientTest, Basic) {
-  nebula::StorageClient c({kServerHost ":9559"});
+  LOG(INFO) << "Prepare data.";
   prepare();
+  nebula::StorageClient c({kServerHost ":9559"});
   LOG(INFO) << "Testing run get parts.";
   runGetParts(c);
   LOG(INFO) << "Testing run scan edge with part.";