diff options
author | Craig Tiller <ctiller@google.com> | 2016-05-14 13:27:02 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-05-14 13:27:02 -0700 |
commit | 1102faffca0727511214939b82139d72d54518cf (patch) | |
tree | 5f21a7360febf9a0e59617ea91eb10578fc46856 /test/cpp | |
parent | b1d3b36e3d93d4b3d06d81ecc0ea9a156c70450a (diff) | |
parent | 52237e3a961e3b4a025399ec7a0abe57a16331d6 (diff) |
Merge branch 'connect_first' into test_affine
Diffstat (limited to 'test/cpp')
-rw-r--r-- | test/cpp/qps/client.h | 5 |
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(); } |