diff options
author | 2018-06-07 13:02:48 -0700 | |
---|---|---|
committer | 2018-06-07 13:02:48 -0700 | |
commit | ea424b88fa8ed07df27cb51d07b8dafc9110a9ec (patch) | |
tree | 6b2d19a62edcfeaae4be3c880513b58cbf1c59cf /src/core/lib/channel | |
parent | d23739eda3081a274fad4f3a6af400fbca39dee1 (diff) |
clang fmt
Diffstat (limited to 'src/core/lib/channel')
-rw-r--r-- | src/core/lib/channel/channel_trace.h | 1 | ||||
-rw-r--r-- | src/core/lib/channel/channelz.cc | 23 | ||||
-rw-r--r-- | src/core/lib/channel/channelz.h | 2 |
3 files changed, 15 insertions, 11 deletions
diff --git a/src/core/lib/channel/channel_trace.h b/src/core/lib/channel/channel_trace.h index 499cebd721..f6021c3224 100644 --- a/src/core/lib/channel/channel_trace.h +++ b/src/core/lib/channel/channel_trace.h @@ -27,7 +27,6 @@ #include "src/core/lib/iomgr/error.h" #include "src/core/lib/json/json.h" - namespace grpc_core { namespace channelz { diff --git a/src/core/lib/channel/channelz.cc b/src/core/lib/channel/channelz.cc index 06e2c0e13c..17c3fc35d9 100644 --- a/src/core/lib/channel/channelz.cc +++ b/src/core/lib/channel/channelz.cc @@ -90,9 +90,12 @@ grpc_json* add_num_str(grpc_json* parent, grpc_json* it, const char* name, } // namespace Channel::Channel(grpc_channel* channel, size_t channel_tracer_max_nodes) - : channel_(channel), target_(UniquePtr<char>(grpc_channel_get_target(channel_))), channel_uuid_(ChannelzRegistry::Register(this)) { + : channel_(channel), + target_(UniquePtr<char>(grpc_channel_get_target(channel_))), + channel_uuid_(ChannelzRegistry::Register(this)) { trace_.Init(channel_tracer_max_nodes); - gpr_atm_no_barrier_store(&last_call_started_millis_, (gpr_atm)ExecCtx::Get()->Now()); + gpr_atm_no_barrier_store(&last_call_started_millis_, + (gpr_atm)ExecCtx::Get()->Now()); } Channel::~Channel() { @@ -102,7 +105,8 @@ Channel::~Channel() { void Channel::RecordCallStarted() { gpr_atm_no_barrier_fetch_add(&calls_started_, (gpr_atm)1); - gpr_atm_no_barrier_store(&last_call_started_millis_, (gpr_atm)ExecCtx::Get()->Now()); + gpr_atm_no_barrier_store(&last_call_started_millis_, + (gpr_atm)ExecCtx::Get()->Now()); } grpc_connectivity_state Channel::GetConnectivityState() { @@ -142,8 +146,8 @@ char* Channel::RenderJSON() { GRPC_JSON_STRING, false); // reset the parent to be the data object. json = data; - json_iterator = grpc_json_create_child(json_iterator, json, "target", target_.get(), - GRPC_JSON_STRING, false); + json_iterator = grpc_json_create_child( + json_iterator, json, "target", target_.get(), GRPC_JSON_STRING, false); // fill in the channel trace if applicable grpc_json* trace = trace_->RenderJSON(); if (trace != nullptr) { @@ -166,10 +170,11 @@ char* Channel::RenderJSON() { calls_succeeded_ ? calls_succeeded_ : -1); json_iterator = add_num_str(json, json_iterator, "callsFailed", calls_failed_ ? calls_failed_ : -1); - gpr_timespec ts = grpc_millis_to_timespec(last_call_started_millis_, GPR_CLOCK_REALTIME); - json_iterator = grpc_json_create_child( - json_iterator, json, "lastCallStartedTimestamp", - fmt_time(ts), GRPC_JSON_STRING, true); + gpr_timespec ts = + grpc_millis_to_timespec(last_call_started_millis_, GPR_CLOCK_REALTIME); + json_iterator = + grpc_json_create_child(json_iterator, json, "lastCallStartedTimestamp", + fmt_time(ts), GRPC_JSON_STRING, true); // render and return the over json object char* json_str = grpc_json_dump_to_string(top_level_json, 0); grpc_json_destroy(top_level_json); diff --git a/src/core/lib/channel/channelz.h b/src/core/lib/channel/channelz.h index 863447a5a4..68b7c8d26b 100644 --- a/src/core/lib/channel/channelz.h +++ b/src/core/lib/channel/channelz.h @@ -35,7 +35,7 @@ namespace grpc_core { namespace channelz { namespace testing { - class ChannelPeer; +class ChannelPeer; } class Channel : public RefCounted<Channel> { |