From 03d92af1189e1dc0f39f3e2961db6fce62eb1739 Mon Sep 17 00:00:00 2001 From: Xiaobing Zhou Date: Fri, 11 Aug 2017 15:02:58 -0700 Subject: [PATCH] HBASE-18576. [C++] Add ping for RPC test --- hbase-native-client/connection/rpc-test-server.cc | 3 +++ hbase-native-client/connection/rpc-test.cc | 30 +++++++++++++++++++++++ 2 files changed, 33 insertions(+) diff --git a/hbase-native-client/connection/rpc-test-server.cc b/hbase-native-client/connection/rpc-test-server.cc index f350d6a5b8..6132fbb978 100644 --- a/hbase-native-client/connection/rpc-test-server.cc +++ b/hbase-native-client/connection/rpc-test-server.cc @@ -68,6 +68,9 @@ Future> RpcTestService::operator()(std::unique_ptr(); 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(); /* get msg from client */ diff --git a/hbase-native-client/connection/rpc-test.cc b/hbase-native-client/connection/rpc-test.cc index e7f678dd14..46889507a7 100644 --- a/hbase-native-client/connection/rpc-test.cc +++ b/hbase-native-client/connection/rpc-test.cc @@ -88,6 +88,36 @@ std::shared_ptr CreateRpcClient(std::shared_ptr 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(std::make_shared(), + std::make_shared(), method); + + /* sending out request */ + client + ->AsyncCall(server_addr->getAddressStr(), server_addr->getPort(), std::move(request), + hbase::security::User::defaultUser()) + .then([&](std::unique_ptr response) { + auto pb_resp = std::static_pointer_cast(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) { -- 2.11.0 (Apple Git-81)