ipmroute: convert to output JSON

Should be no change for non-json case except putting color
on address if desired.

Signed-off-by: Stephen Hemminger <stephen@networkplumber.org>
Signed-off-by: David Ahern <dsahern@gmail.com>
This commit is contained in:
Stephen Hemminger 2018-03-08 18:02:18 -08:00 committed by David Ahern
parent 311dca0aa0
commit 0f1475c268
1 changed files with 70 additions and 35 deletions

View File

@ -29,6 +29,7 @@
#include <rt_names.h> #include <rt_names.h>
#include "utils.h" #include "utils.h"
#include "ip_common.h" #include "ip_common.h"
#include "json_print.h"
static void usage(void) __attribute__((noreturn)); static void usage(void) __attribute__((noreturn));
@ -53,13 +54,12 @@ struct rtfilter {
int print_mroute(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg) int print_mroute(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
{ {
FILE *fp = (FILE *)arg;
struct rtmsg *r = NLMSG_DATA(n); struct rtmsg *r = NLMSG_DATA(n);
int len = n->nlmsg_len; int len = n->nlmsg_len;
struct rtattr *tb[RTA_MAX+1]; struct rtattr *tb[RTA_MAX+1];
char obuf[256]; const char *src, *dst;
SPRINT_BUF(b1); SPRINT_BUF(b1);
SPRINT_BUF(b2);
__u32 table; __u32 table;
int iif = 0; int iif = 0;
int family; int family;
@ -103,30 +103,44 @@ int print_mroute(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
family = get_real_family(r->rtm_type, r->rtm_family); family = get_real_family(r->rtm_type, r->rtm_family);
open_json_object(NULL);
if (n->nlmsg_type == RTM_DELROUTE) if (n->nlmsg_type == RTM_DELROUTE)
fprintf(fp, "Deleted "); print_bool(PRINT_ANY, "deleted", "Deleted ", true);
if (tb[RTA_SRC]) if (tb[RTA_SRC])
len = snprintf(obuf, sizeof(obuf), src = rt_addr_n2a_r(family, RTA_PAYLOAD(tb[RTA_SRC]),
"(%s, ", rt_addr_n2a_rta(family, tb[RTA_SRC])); RTA_DATA(tb[RTA_SRC]), b1, sizeof(b1));
else else
len = sprintf(obuf, "(unknown, "); src = "unknown";
if (tb[RTA_DST])
snprintf(obuf + len, sizeof(obuf) - len,
"%s)", rt_addr_n2a_rta(family, tb[RTA_DST]));
else
snprintf(obuf + len, sizeof(obuf) - len, "unknown) ");
fprintf(fp, "%-32s Iif: ", obuf); if (tb[RTA_DST])
if (iif) dst = rt_addr_n2a_r(family, RTA_PAYLOAD(tb[RTA_DST]),
fprintf(fp, "%-10s ", ll_index_to_name(iif)); RTA_DATA(tb[RTA_DST]), b2, sizeof(b2));
else else
fprintf(fp, "unresolved "); dst = "unknown";
if (is_json_context()) {
print_string(PRINT_JSON, "src", NULL, src);
print_string(PRINT_JSON, "dst", NULL, dst);
} else {
char obuf[256];
snprintf(obuf, sizeof(obuf), "(%s,%s)", src, dst);
print_string(PRINT_FP, NULL,
"%-32s Iif: ", obuf);
}
if (iif)
print_color_string(PRINT_ANY, COLOR_IFNAME,
"iif", "%-10s ", ll_index_to_name(iif));
else
print_string(PRINT_ANY,"iif", "%s ", "unresolved");
if (tb[RTA_MULTIPATH]) { if (tb[RTA_MULTIPATH]) {
struct rtnexthop *nh = RTA_DATA(tb[RTA_MULTIPATH]); struct rtnexthop *nh = RTA_DATA(tb[RTA_MULTIPATH]);
int first = 1; int first = 1;
open_json_array(PRINT_JSON, "multipath");
len = RTA_PAYLOAD(tb[RTA_MULTIPATH]); len = RTA_PAYLOAD(tb[RTA_MULTIPATH]);
for (;;) { for (;;) {
@ -135,47 +149,65 @@ int print_mroute(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
if (nh->rtnh_len > len) if (nh->rtnh_len > len)
break; break;
open_json_object(NULL);
if (first) { if (first) {
fprintf(fp, "Oifs: "); print_string(PRINT_FP, NULL, "Oifs: ", NULL);
first = 0; first = 0;
} }
fprintf(fp, "%s", ll_index_to_name(nh->rtnh_ifindex));
print_color_string(PRINT_ANY, COLOR_IFNAME,
"oif", "%s", ll_index_to_name(nh->rtnh_ifindex));
if (nh->rtnh_hops > 1) if (nh->rtnh_hops > 1)
fprintf(fp, "(ttl %d) ", nh->rtnh_hops); print_uint(PRINT_ANY,
"ttl", "(ttl %u) ", nh->rtnh_hops);
else else
fprintf(fp, " "); print_string(PRINT_FP, NULL, " ", NULL);
close_json_object();
len -= NLMSG_ALIGN(nh->rtnh_len); len -= NLMSG_ALIGN(nh->rtnh_len);
nh = RTNH_NEXT(nh); nh = RTNH_NEXT(nh);
} }
close_json_array(PRINT_JSON, NULL);
} }
fprintf(fp, " State: %s",
r->rtm_flags & RTNH_F_UNRESOLVED ? "unresolved" : "resolved"); print_string(PRINT_ANY, "state", " State: %s",
(r->rtm_flags & RTNH_F_UNRESOLVED) ? "unresolved" : "resolved");
if (r->rtm_flags & RTNH_F_OFFLOAD) if (r->rtm_flags & RTNH_F_OFFLOAD)
fprintf(fp, " offload"); print_null(PRINT_ANY, "offload", " offload", NULL);
if (show_stats && tb[RTA_MFC_STATS]) { if (show_stats && tb[RTA_MFC_STATS]) {
struct rta_mfc_stats *mfcs = RTA_DATA(tb[RTA_MFC_STATS]); struct rta_mfc_stats *mfcs = RTA_DATA(tb[RTA_MFC_STATS]);
fprintf(fp, "%s %"PRIu64" packets, %"PRIu64" bytes", _SL_, print_string(PRINT_FP, NULL, "%s", _SL_);
(uint64_t)mfcs->mfcs_packets, print_uint(PRINT_ANY, "packets", " %"PRIu64" packets,",
(uint64_t)mfcs->mfcs_bytes); mfcs->mfcs_packets);
print_uint(PRINT_ANY, "bytes", " %"PRIu64" bytes", mfcs->mfcs_bytes);
if (mfcs->mfcs_wrong_if) if (mfcs->mfcs_wrong_if)
fprintf(fp, ", %"PRIu64" arrived on wrong iif.", print_uint(PRINT_ANY, "wrong_if",
(uint64_t)mfcs->mfcs_wrong_if); ", %"PRIu64" arrived on wrong iif.",
mfcs->mfcs_wrong_if);
} }
if (show_stats && tb[RTA_EXPIRES]) { if (show_stats && tb[RTA_EXPIRES]) {
struct timeval tv; struct timeval tv;
double age;
__jiffies_to_tv(&tv, rta_getattr_u64(tb[RTA_EXPIRES])); __jiffies_to_tv(&tv, rta_getattr_u64(tb[RTA_EXPIRES]));
fprintf(fp, ", Age %4i.%.2i", (int)tv.tv_sec, age = tv.tv_sec;
(int)tv.tv_usec/10000); age += tv.tv_usec / 1000000.;
print_float(PRINT_ANY, "expires",
", Age %.2f", age);
} }
if (table && (table != RT_TABLE_MAIN || show_details > 0) && !filter.tb) if (table && (table != RT_TABLE_MAIN || show_details > 0) && !filter.tb)
fprintf(fp, " Table: %s", print_string(PRINT_ANY, "table", " Table: %s",
rtnl_rttable_n2a(table, b1, sizeof(b1))); rtnl_rttable_n2a(table, b1, sizeof(b1)));
fprintf(fp, "\n"); print_string(PRINT_FP, NULL, "\n", NULL);
fflush(fp); close_json_object();
return 0; return 0;
} }
@ -255,12 +287,15 @@ static int mroute_list(int argc, char **argv)
return 1; return 1;
} }
new_json_obj(json);
if (rtnl_dump_filter(&rth, print_mroute, stdout) < 0) { if (rtnl_dump_filter(&rth, print_mroute, stdout) < 0) {
delete_json_obj();
fprintf(stderr, "Dump terminated\n"); fprintf(stderr, "Dump terminated\n");
exit(1); exit(1);
} }
delete_json_obj();
exit(0); return 0;
} }
int do_multiroute(int argc, char **argv) int do_multiroute(int argc, char **argv)