aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/channel/channelz_test.cc
diff options
context:
space:
mode:
authorGravatar ncteisen <ncteisen@gmail.com>2018-06-08 09:30:12 -0700
committerGravatar ncteisen <ncteisen@gmail.com>2018-06-08 09:30:12 -0700
commit6c987cbf0911b6d97eeec2e14bff2e8fc5bc40e5 (patch)
tree69a0a8189319b5eb3e4f0423d13a514679ffb040 /test/core/channel/channelz_test.cc
parentb8a52e0cf3e271f80b32f16783c76c065f5c2167 (diff)
Rename channelz Channel to ChannelNode
Diffstat (limited to 'test/core/channel/channelz_test.cc')
-rw-r--r--test/core/channel/channelz_test.cc18
1 files changed, 9 insertions, 9 deletions
diff --git a/test/core/channel/channelz_test.cc b/test/core/channel/channelz_test.cc
index 262ca38ee0..8ef91c3b09 100644
--- a/test/core/channel/channelz_test.cc
+++ b/test/core/channel/channelz_test.cc
@@ -44,16 +44,16 @@ namespace channelz {
namespace testing {
// testing peer to access channel internals
-class ChannelPeer {
+class ChannelNodePeer {
public:
- ChannelPeer(Channel* channel) : channel_(channel) {}
+ ChannelNodePeer(ChannelNode* channel) : channel_(channel) {}
grpc_millis last_call_started_millis() {
return (grpc_millis)gpr_atm_no_barrier_load(
&channel_->last_call_started_millis_);
}
private:
- Channel* channel_;
+ ChannelNode* channel_;
};
namespace {
@@ -111,15 +111,15 @@ void ValidateCounters(char* json_str, validate_channel_data_args args) {
grpc_json_destroy(json);
}
-void ValidateChannel(Channel* channel, validate_channel_data_args args) {
+void ValidateChannel(ChannelNode* channel, validate_channel_data_args args) {
char* json_str = channel->RenderJSON();
grpc::testing::ValidateChannelProtoJsonTranslation(json_str);
ValidateCounters(json_str, args);
gpr_free(json_str);
}
-grpc_millis GetLastCallStartedMillis(Channel* channel) {
- ChannelPeer peer(channel);
+grpc_millis GetLastCallStartedMillis(ChannelNode* channel) {
+ ChannelNodePeer peer(channel);
return peer.last_call_started_millis();
}
@@ -137,7 +137,7 @@ TEST_P(ChannelzChannelTest, BasicChannel) {
grpc_core::ExecCtx exec_ctx;
ChannelFixture channel(GetParam());
intptr_t uuid = grpc_channel_get_uuid(channel.channel());
- Channel* channelz_channel = ChannelzRegistry::Get<Channel>(uuid);
+ ChannelNode* channelz_channel = ChannelzRegistry::Get<ChannelNode>(uuid);
char* json_str = channelz_channel->RenderJSON();
ValidateCounters(json_str, {0, 0, 0});
gpr_free(json_str);
@@ -147,7 +147,7 @@ TEST_P(ChannelzChannelTest, BasicChannelAPIFunctionality) {
grpc_core::ExecCtx exec_ctx;
ChannelFixture channel(GetParam());
intptr_t uuid = grpc_channel_get_uuid(channel.channel());
- Channel* channelz_channel = ChannelzRegistry::Get<Channel>(uuid);
+ ChannelNode* channelz_channel = ChannelzRegistry::Get<ChannelNode>(uuid);
channelz_channel->RecordCallStarted();
channelz_channel->RecordCallFailed();
channelz_channel->RecordCallSucceeded();
@@ -165,7 +165,7 @@ TEST_P(ChannelzChannelTest, LastCallStartedMillis) {
grpc_core::ExecCtx exec_ctx;
ChannelFixture channel(GetParam());
intptr_t uuid = grpc_channel_get_uuid(channel.channel());
- Channel* channelz_channel = ChannelzRegistry::Get<Channel>(uuid);
+ ChannelNode* channelz_channel = ChannelzRegistry::Get<ChannelNode>(uuid);
// start a call to set the last call started timestamp
channelz_channel->RecordCallStarted();
grpc_millis millis1 = GetLastCallStartedMillis(channelz_channel);