in src/client/replication_ddl_client.cpp [298:473]
dsn::error_code replication_ddl_client::list_apps(const dsn::app_status::type status,
bool show_all,
bool detailed,
bool json,
const std::string &file_name)
{
std::vector<::dsn::app_info> apps;
auto r = list_apps(status, apps);
if (r != dsn::ERR_OK) {
return r;
}
// print configuration_list_apps_response
std::streambuf *buf;
std::ofstream of;
if (!file_name.empty()) {
of.open(file_name);
buf = of.rdbuf();
} else {
buf = std::cout.rdbuf();
}
std::ostream out(buf);
size_t max_app_name_size = 20;
for (int i = 0; i < apps.size(); i++) {
dsn::app_info info = apps[i];
if (!show_all && info.status != app_status::AS_AVAILABLE) {
continue;
}
max_app_name_size = std::max(max_app_name_size, info.app_name.size() + 2);
}
dsn::utils::multi_table_printer mtp;
dsn::utils::table_printer tp_general("general_info");
tp_general.add_title("app_id");
tp_general.add_column("status");
tp_general.add_column("app_name");
tp_general.add_column("app_type");
tp_general.add_column("partition_count");
tp_general.add_column("replica_count");
tp_general.add_column("is_stateful");
tp_general.add_column("create_time");
tp_general.add_column("drop_time");
tp_general.add_column("drop_expire");
tp_general.add_column("envs_count");
int available_app_count = 0;
for (int i = 0; i < apps.size(); i++) {
dsn::app_info info = apps[i];
if (!show_all && info.status != app_status::AS_AVAILABLE) {
continue;
}
std::string status_str = enum_to_string(info.status);
status_str = status_str.substr(status_str.find("AS_") + 3);
std::string create_time = "-";
if (info.create_second > 0) {
char buf[20];
dsn::utils::time_ms_to_date_time((uint64_t)info.create_second * 1000, buf, 20);
buf[10] = '_';
create_time = buf;
}
std::string drop_time = "-";
std::string drop_expire_time = "-";
if (info.status == app_status::AS_AVAILABLE) {
available_app_count++;
} else if (info.status == app_status::AS_DROPPED && info.expire_second > 0) {
if (info.drop_second > 0) {
char buf[20];
dsn::utils::time_ms_to_date_time((uint64_t)info.drop_second * 1000, buf, 20);
buf[10] = '_';
drop_time = buf;
}
if (info.expire_second > 0) {
char buf[20];
dsn::utils::time_ms_to_date_time((uint64_t)info.expire_second * 1000, buf, 20);
buf[10] = '_';
drop_expire_time = buf;
}
}
tp_general.add_row(info.app_id);
tp_general.append_data(status_str);
tp_general.append_data(info.app_name);
tp_general.append_data(info.app_type);
tp_general.append_data(info.partition_count);
tp_general.append_data(info.max_replica_count);
tp_general.append_data(info.is_stateful);
tp_general.append_data(create_time);
tp_general.append_data(drop_time);
tp_general.append_data(drop_expire_time);
tp_general.append_data(info.envs.size());
}
mtp.add(std::move(tp_general));
int total_fully_healthy_app_count = 0;
int total_unhealthy_app_count = 0;
int total_write_unhealthy_app_count = 0;
int total_read_unhealthy_app_count = 0;
if (detailed && available_app_count > 0) {
dsn::utils::table_printer tp_health("healthy_info");
tp_health.add_title("app_id");
tp_health.add_column("app_name");
tp_health.add_column("partition_count");
tp_health.add_column("fully_healthy");
tp_health.add_column("unhealthy");
tp_health.add_column("write_unhealthy");
tp_health.add_column("read_unhealthy");
for (auto &info : apps) {
if (info.status != app_status::AS_AVAILABLE) {
continue;
}
int32_t app_id;
int32_t partition_count;
std::vector<partition_configuration> partitions;
r = list_app(info.app_name, app_id, partition_count, partitions);
if (r != dsn::ERR_OK) {
LOG_ERROR("list app({}) failed, err = {}", info.app_name, r);
return r;
}
CHECK_EQ(info.app_id, app_id);
CHECK_EQ(info.partition_count, partition_count);
int fully_healthy = 0;
int write_unhealthy = 0;
int read_unhealthy = 0;
for (int i = 0; i < partitions.size(); i++) {
const dsn::partition_configuration &p = partitions[i];
int replica_count = 0;
if (!p.primary.is_invalid()) {
replica_count++;
}
replica_count += p.secondaries.size();
if (!p.primary.is_invalid()) {
if (replica_count >= p.max_replica_count)
fully_healthy++;
else if (replica_count < 2)
write_unhealthy++;
} else {
write_unhealthy++;
read_unhealthy++;
}
}
tp_health.add_row(info.app_id);
tp_health.append_data(info.app_name);
tp_health.append_data(info.partition_count);
tp_health.append_data(fully_healthy);
tp_health.append_data(info.partition_count - fully_healthy);
tp_health.append_data(write_unhealthy);
tp_health.append_data(read_unhealthy);
if (fully_healthy == info.partition_count)
total_fully_healthy_app_count++;
else
total_unhealthy_app_count++;
if (write_unhealthy > 0)
total_write_unhealthy_app_count++;
if (read_unhealthy > 0)
total_read_unhealthy_app_count++;
}
mtp.add(std::move(tp_health));
}
dsn::utils::table_printer tp_count("summary");
tp_count.add_row_name_and_data("total_app_count", available_app_count);
if (detailed && available_app_count > 0) {
tp_count.add_row_name_and_data("fully_healthy_app_count", total_fully_healthy_app_count);
tp_count.add_row_name_and_data("unhealthy_app_count", total_unhealthy_app_count);
tp_count.add_row_name_and_data("write_unhealthy_app_count",
total_write_unhealthy_app_count);
tp_count.add_row_name_and_data("read_unhealthy_app_count", total_read_unhealthy_app_count);
}
mtp.add(std::move(tp_count));
mtp.output(out, json ? tp_output_format::kJsonPretty : tp_output_format::kTabular);
return dsn::ERR_OK;
}