aboutsummaryrefslogtreecommitdiffhomepage
path: root/test
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-05-14 13:27:02 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-05-14 13:27:02 -0700
commit1102faffca0727511214939b82139d72d54518cf (patch)
tree5f21a7360febf9a0e59617ea91eb10578fc46856 /test
parentb1d3b36e3d93d4b3d06d81ecc0ea9a156c70450a (diff)
parent52237e3a961e3b4a025399ec7a0abe57a16331d6 (diff)
Merge branch 'connect_first' into test_affine
Diffstat (limited to 'test')
-rw-r--r--test/cpp/qps/client.h5
1 files changed, 5 insertions, 0 deletions
diff --git a/test/cpp/qps/client.h b/test/cpp/qps/client.h
index 175529f01b..2a89eb8018 100644
--- a/test/cpp/qps/client.h
+++ b/test/cpp/qps/client.h
@@ -38,6 +38,7 @@
#include <mutex>
#include <vector>
+#include <grpc++/channel.h>
#include <grpc++/support/byte_buffer.h>
#include <grpc++/support/channel_arguments.h>
#include <grpc++/support/slice.h>
@@ -315,6 +316,10 @@ class ClientImpl : public Client {
target, config.security_params().server_host_override(),
config.has_security_params(), !config.security_params().use_test_ca(),
std::shared_ptr<CallCredentials>(), args);
+ gpr_log(GPR_INFO, "Connecting to %s", target.c_str());
+ GPR_ASSERT(channel_->WaitForConnected(
+ gpr_time_add(gpr_now(GPR_CLOCK_REALTIME),
+ gpr_time_from_seconds(30, GPR_TIMESPAN))));
stub_ = create_stub(channel_);
}
Channel* get_channel() { return channel_.get(); }