hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e...@apache.org
Subject hbase git commit: HBASE-18576. [C++] Add ping for RPC test
Date Fri, 11 Aug 2017 23:42:17 GMT
Repository: hbase
Updated Branches:
  refs/heads/HBASE-14850 e2a1cad3e -> aff0336ec


HBASE-18576. [C++] Add ping for RPC test

Signed-off-by: Enis Soztutar <enis@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/aff0336e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/aff0336e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/aff0336e

Branch: refs/heads/HBASE-14850
Commit: aff0336ec339d6b8b61d6bfbdff4df68ed7668e9
Parents: e2a1cad
Author: Xiaobing Zhou <xzhou@hortonworks.com>
Authored: Fri Aug 11 15:02:58 2017 -0700
Committer: Enis Soztutar <enis@apache.org>
Committed: Fri Aug 11 16:38:26 2017 -0700

----------------------------------------------------------------------
 .../connection/rpc-test-server.cc               |  3 ++
 hbase-native-client/connection/rpc-test.cc      | 30 ++++++++++++++++++++
 2 files changed, 33 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/aff0336e/hbase-native-client/connection/rpc-test-server.cc
----------------------------------------------------------------------
diff --git a/hbase-native-client/connection/rpc-test-server.cc b/hbase-native-client/connection/rpc-test-server.cc
index f350d6a..6132fbb 100644
--- a/hbase-native-client/connection/rpc-test-server.cc
+++ b/hbase-native-client/connection/rpc-test-server.cc
@@ -68,6 +68,9 @@ Future<std::unique_ptr<Response>> RpcTestService::operator()(std::unique_ptr<Req
   if (method_name == "ping") {
     auto pb_resp_msg = std::make_shared<EmptyResponseProto>();
     response->set_resp_msg(pb_resp_msg);
+    VLOG(1) << "RPC server:"
+            << " ping called.";
+
   } else if (method_name == "echo") {
     auto pb_resp_msg = std::make_shared<EchoResponseProto>();
     /* get msg from client */

http://git-wip-us.apache.org/repos/asf/hbase/blob/aff0336e/hbase-native-client/connection/rpc-test.cc
----------------------------------------------------------------------
diff --git a/hbase-native-client/connection/rpc-test.cc b/hbase-native-client/connection/rpc-test.cc
index e7f678d..4688950 100644
--- a/hbase-native-client/connection/rpc-test.cc
+++ b/hbase-native-client/connection/rpc-test.cc
@@ -88,6 +88,36 @@ std::shared_ptr<RpcClient> CreateRpcClient(std::shared_ptr<Configuration>
conf,
 }
 
 /**
+* test ping
+*/
+TEST_F(RpcTest, Ping) {
+  auto conf = CreateConf();
+  auto server = CreateRpcServer();
+  auto server_addr = GetRpcServerAddress(server);
+  auto client = CreateRpcClient(conf);
+
+  auto method = "ping";
+  auto request = std::make_unique<Request>(std::make_shared<EmptyRequestProto>(),
+                                           std::make_shared<EmptyResponseProto>(),
method);
+
+  /* sending out request */
+  client
+      ->AsyncCall(server_addr->getAddressStr(), server_addr->getPort(), std::move(request),
+                  hbase::security::User::defaultUser())
+      .then([&](std::unique_ptr<Response> response) {
+        auto pb_resp = std::static_pointer_cast<EmptyResponseProto>(response->resp_msg());
+        EXPECT_TRUE(pb_resp != nullptr);
+        VLOG(1) << folly::sformat(FLAGS_result_format, method, "");
+      })
+      .onError([&](const folly::exception_wrapper& ew) {
+        FAIL() << folly::sformat(FLAGS_fail_format, method);
+      });
+
+  server->stop();
+  server->join();
+}
+
+/**
  * test echo
  */
 TEST_F(RpcTest, Echo) {


Mime
View raw message