Skip to content

Commit

Permalink
redpanda: run clang-format on application.cc
Browse files Browse the repository at this point in the history
  • Loading branch information
jcsp committed May 31, 2022
1 parent a7e6876 commit 6beebd9
Showing 1 changed file with 30 additions and 30 deletions.
60 changes: 30 additions & 30 deletions src/v/redpanda/application.cc
Original file line number Diff line number Diff line change
Expand Up @@ -342,33 +342,33 @@ void application::hydrate_config(const po::variables_map& cfg) {
}
};

ss::smp::invoke_on_all([&config, cfg_path] {
config::node().load(cfg_path, config);
}).get0();

auto node_config_errors = config::node().load(config);
for (const auto& i : node_config_errors) {
vlog(
_log.warn,
"Node property '{}' validation error: {}",
i.first,
i.second);
}
if (node_config_errors.size() > 0) {
throw std::invalid_argument("Validation errors in node config");
}
ss::smp::invoke_on_all([&config, cfg_path] {
config::node().load(cfg_path, config);
}).get0();

// This includes loading from local bootstrap file or legacy
// config file on first-start or upgrade cases.
_config_preload = cluster::config_manager::preload(config).get0();
auto node_config_errors = config::node().load(config);
for (const auto& i : node_config_errors) {
vlog(
_log.warn,
"Node property '{}' validation error: {}",
i.first,
i.second);
}
if (node_config_errors.size() > 0) {
throw std::invalid_argument("Validation errors in node config");
}

// This includes loading from local bootstrap file or legacy
// config file on first-start or upgrade cases.
_config_preload = cluster::config_manager::preload(config).get0();

vlog(_log.info, "Cluster configuration properties:");
vlog(_log.info, "(use `rpk cluster config edit` to change)");
config_printer("redpanda", config::shard_local_cfg());
vlog(_log.info, "Cluster configuration properties:");
vlog(_log.info, "(use `rpk cluster config edit` to change)");
config_printer("redpanda", config::shard_local_cfg());

vlog(_log.info, "Node configuration properties:");
vlog(_log.info, "(use `rpk config set <cfg> <value>` to change)");
config_printer("redpanda", config::node());
vlog(_log.info, "Node configuration properties:");
vlog(_log.info, "(use `rpk config set <cfg> <value>` to change)");
config_printer("redpanda", config::node());

if (config["pandaproxy"]) {
_proxy_config.emplace(config["pandaproxy"]);
Expand Down Expand Up @@ -401,9 +401,9 @@ void application::check_environment() {
syschecks::systemd_message("checking environment (CPU, Mem)").get();
syschecks::cpu();
syschecks::memory(config::node().developer_mode());
storage::directories::initialize(
config::node().data_directory().as_sstring())
.get();
storage::directories::initialize(
config::node().data_directory().as_sstring())
.get();
}

static admin_server_cfg
Expand Down Expand Up @@ -557,7 +557,7 @@ make_upload_controller_config(ss::scheduling_group sg) {

// add additional services in here
void application::wire_up_services() {
wire_up_redpanda_services();
wire_up_redpanda_services();
if (_proxy_config) {
construct_service(_proxy_client, to_yaml(*_proxy_client_config)).get();
construct_service(
Expand Down Expand Up @@ -1104,7 +1104,7 @@ application::set_proxy_client_config(ss::sstring name, std::any val) {
}

void application::start(::stop_signal& app_signal) {
start_redpanda(app_signal);
start_redpanda(app_signal);

if (_proxy_config) {
_proxy.invoke_on_all(&pandaproxy::rest::proxy::start).get();
Expand All @@ -1122,7 +1122,7 @@ void application::start(::stop_signal& app_signal) {
_schema_reg_config->schema_registry_api());
}

start_kafka(app_signal);
start_kafka(app_signal);

_admin.invoke_on_all([](admin_server& admin) { admin.set_ready(); }).get();

Expand Down

0 comments on commit 6beebd9

Please sign in to comment.