Skip to content

Commit

Permalink
Fix format
Browse files Browse the repository at this point in the history
Signed-off-by: Henry Yang <[email protected]>
  • Loading branch information
HenryYYang committed Sep 11, 2019
1 parent a656dfa commit 92cd158
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 9 deletions.
5 changes: 2 additions & 3 deletions source/extensions/filters/network/common/redis/client_impl.cc
Original file line number Diff line number Diff line change
Expand Up @@ -297,9 +297,8 @@ ClientPtr ClientFactoryImpl::create(Upstream::HostConstSharedPtr host,
Event::Dispatcher& dispatcher, const Config& config,
const RedisCommandStatsSharedPtr& redis_command_stats,
Stats::Scope& scope, const std::string& auth_password) {
ClientPtr client =
ClientImpl::create(host, dispatcher, EncoderPtr{new EncoderImpl()}, decoder_factory_,
config, redis_command_stats, scope);
ClientPtr client = ClientImpl::create(host, dispatcher, EncoderPtr{new EncoderImpl()},
decoder_factory_, config, redis_command_stats, scope);
client->initialize(auth_password);
return client;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -190,8 +190,9 @@ InstanceImpl::ThreadLocalPool::threadLocalActiveClient(Upstream::HostConstShared
if (!client) {
client = std::make_unique<ThreadLocalActiveClient>(*this);
client->host_ = host;
client->redis_client_ = parent_.client_factory_.create(
host, dispatcher_, parent_.config_, parent_.redis_command_stats_, *parent_.stats_scope_, auth_password_);
client->redis_client_ = parent_.client_factory_.create(host, dispatcher_, parent_.config_,
parent_.redis_command_stats_,
*parent_.stats_scope_, auth_password_);
client->redis_client_->addConnectionCallbacks(*client);
}
return client;
Expand Down
6 changes: 3 additions & 3 deletions source/extensions/health_checkers/redis/redis.cc
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,9 @@ void RedisHealthChecker::RedisActiveHealthCheckSession::onEvent(Network::Connect

void RedisHealthChecker::RedisActiveHealthCheckSession::onInterval() {
if (!client_) {
client_ =
parent_.client_factory_.create(host_, parent_.dispatcher_, *this, redis_command_stats_,
parent_.cluster_.info()->statsScope(), parent_.auth_password_);
client_ = parent_.client_factory_.create(
host_, parent_.dispatcher_, *this, redis_command_stats_,
parent_.cluster_.info()->statsScope(), parent_.auth_password_);
client_->addConnectionCallbacks(*this);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -951,7 +951,8 @@ TEST(RedisClientFactoryImplTest, Basic) {
auto redis_command_stats =
Common::Redis::RedisCommandStats::createRedisCommandStats(stats_.symbolTable());
const std::string auth_password;
ClientPtr client = factory.create(host, dispatcher, config, redis_command_stats, stats_, auth_password);
ClientPtr client =
factory.create(host, dispatcher, config, redis_command_stats, stats_, auth_password);
client->close();
}
} // namespace Client
Expand Down

0 comments on commit 92cd158

Please sign in to comment.