Skip to content
Snippets Groups Projects
Commit 52237e3a authored by Craig Tiller's avatar Craig Tiller
Browse files

clang-format

parent 63d24f1c
No related branches found
No related tags found
No related merge requests found
......@@ -86,7 +86,8 @@ class ChannelInterface {
}
/// Wait for this channel to be connected
template <typename T>bool WaitForConnected(T deadline) {
template <typename T>
bool WaitForConnected(T deadline) {
grpc_connectivity_state state;
while ((state = GetState(true)) != GRPC_CHANNEL_READY) {
if (!WaitForStateChange(state, deadline)) return false;
......
......@@ -38,10 +38,10 @@
#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>
#include <grpc++/channel.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
......@@ -317,7 +317,9 @@ class ClientImpl : public Client {
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))));
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(); }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment