aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/channel
diff options
context:
space:
mode:
authorGravatar Noah Eisen <ncteisen@google.com>2018-06-07 13:02:48 -0700
committerGravatar Noah Eisen <ncteisen@google.com>2018-06-07 13:02:48 -0700
commitea424b88fa8ed07df27cb51d07b8dafc9110a9ec (patch)
tree6b2d19a62edcfeaae4be3c880513b58cbf1c59cf /src/core/lib/channel
parentd23739eda3081a274fad4f3a6af400fbca39dee1 (diff)
clang fmt
Diffstat (limited to 'src/core/lib/channel')
-rw-r--r--src/core/lib/channel/channel_trace.h1
-rw-r--r--src/core/lib/channel/channelz.cc23
-rw-r--r--src/core/lib/channel/channelz.h2
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> {