#include <sys/socket.h>
#include <arpa/inet.h>
#include <endian.h>
#include <err.h>
#include <math.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "bgpd.h"
#include "session.h"
#include "rde.h"
#include "bgpctl.h"
#include "parser.h"
static void
show_head(struct parse_result *res)
{
switch (res->action) {
case SHOW:
case SHOW_SUMMARY:
printf("%-20s %8s %10s %10s %5s %-8s %s\n", "Neighbor", "AS",
"MsgRcvd", "MsgSent", "OutQ", "Up/Down", "State/PrfRcvd");
break;
case SHOW_FIB:
printf("flags: B = BGP, C = Connected, S = Static\n");
printf(" N = BGP Nexthop reachable via this route\n");
printf(" r = reject route, b = blackhole route\n\n");
printf("%-5s %-4s %-32s %-32s\n", "flags", "prio",
"destination", "gateway");
break;
case SHOW_FIB_TABLES:
printf("%-5s %-20s %-8s\n", "Table", "Description", "State");
break;
case SHOW_NEXTHOP:
printf("Flags: * = nexthop valid\n");
printf("\n %-15s %-19s%-4s %-15s %-20s\n", "Nexthop", "Route",
"Prio", "Gateway", "Iface");
break;
case SHOW_INTERFACE:
printf("%-15s%-9s%-9s%-7s%s\n", "Interface", "rdomain",
"Nexthop", "Flags", "Link state");
break;
case SHOW_RIB:
if (res->flags & F_CTL_DETAIL)
break;
printf("flags: "
"* = Valid, > = Selected, I = via IBGP, A = Announced,\n"
" S = Stale, E = Error, F = Filtered, L = Leaked\n");
printf("origin validation state: "
"N = not-found, V = valid, ! = invalid\n");
printf("aspa validation state: "
"? = unknown, V = valid, ! = invalid\n");
printf("origin: i = IGP, e = EGP, ? = Incomplete\n\n");
printf("%-5s %3s %-20s %-15s %5s %5s %s\n",
"flags", "vs", "destination", "gateway", "lpref", "med",
"aspath origin");
break;
case SHOW_SET:
printf("%-6s %-34s %7s %7s %6s %11s\n", "Type", "Name",
"#IPv4", "#IPv6", "#ASnum", "Last Change");
break;
case NETWORK_SHOW:
printf("flags: S = Static\n");
printf("%-5s %-4s %-32s %-32s\n", "flags", "prio",
"destination", "gateway");
break;
case FLOWSPEC_SHOW:
printf("flags: S = Static\n");
default:
break;
}
}
static void
show_summary(struct peer *p)
{
char *s;
const char *a;
size_t alen;
s = fmt_peer(p->conf.descr, &p->conf.remote_addr,
p->conf.remote_masklen);
a = log_as(p->conf.remote_as);
alen = strlen(a);
if (alen < 28) {
if (strlen(s) > 28 - alen)
s[28 - alen] = '\0';
} else
alen = 0;
printf("%-*s %s %10llu %10llu %5u %-8s ",
(28 - (int)alen), s, a,
p->stats.msg_rcvd_open + p->stats.msg_rcvd_notification +
p->stats.msg_rcvd_update + p->stats.msg_rcvd_keepalive +
p->stats.msg_rcvd_rrefresh,
p->stats.msg_sent_open + p->stats.msg_sent_notification +
p->stats.msg_sent_update + p->stats.msg_sent_keepalive +
p->stats.msg_sent_rrefresh,
p->stats.msg_queue_len,
fmt_monotime(p->stats.last_updown));
if (p->state == STATE_ESTABLISHED) {
printf("%6u", p->stats.prefix_cnt);
if (p->conf.max_prefix != 0)
printf("/%u", p->conf.max_prefix);
} else if (p->conf.template)
printf("Template");
else
printf("%s", statenames[p->state]);
printf("\n");
free(s);
}
static void
show_neighbor_capa_mp(struct capabilities *capa)
{
int comma;
uint8_t i;
printf(" Multiprotocol extensions: ");
for (i = AID_MIN, comma = 0; i < AID_MAX; i++)
if (capa->mp[i]) {
printf("%s%s", comma ? ", " : "", aid2str(i));
comma = 1;
}
printf("\n");
}
static void
show_neighbor_capa_add_path(struct capabilities *capa)
{
const char *mode;
int comma;
uint8_t i;
printf(" Add-path: ");
for (i = AID_MIN, comma = 0; i < AID_MAX; i++) {
switch (capa->add_path[i]) {
case 0:
default:
continue;
case CAPA_AP_RECV:
mode = "recv";
break;
case CAPA_AP_SEND:
mode = "send";
break;
case CAPA_AP_BIDIR:
mode = "bidir";
}
printf("%s%s %s", comma ? ", " : "", aid2str(i), mode);
comma = 1;
}
printf("\n");
}
static void
show_neighbor_capa_restart(struct capabilities *capa)
{
int comma;
uint8_t i;
printf(" Graceful Restart: ");
if (capa->grestart.timeout)
printf("timeout: %d, ", capa->grestart.timeout);
if (capa->grestart.grnotification)
printf("graceful notification, ");
for (i = AID_MIN, comma = 0; i < AID_MAX; i++)
if (capa->grestart.flags[i] & CAPA_GR_PRESENT) {
if (!comma &&
capa->grestart.flags[i] & CAPA_GR_RESTART)
printf("restarted, ");
if (comma)
printf(", ");
printf("%s", aid2str(i));
if (capa->grestart.flags[i] & CAPA_GR_FORWARD)
printf(" (preserved)");
comma = 1;
}
printf("\n");
}
static void
show_neighbor_msgstats(struct peer *p)
{
printf(" Message statistics:\n");
printf(" %-15s %-10s %-10s\n", "", "Sent", "Received");
printf(" %-15s %10llu %10llu\n", "Opens",
p->stats.msg_sent_open, p->stats.msg_rcvd_open);
printf(" %-15s %10llu %10llu\n", "Notifications",
p->stats.msg_sent_notification, p->stats.msg_rcvd_notification);
printf(" %-15s %10llu %10llu\n", "Updates",
p->stats.msg_sent_update, p->stats.msg_rcvd_update);
printf(" %-15s %10llu %10llu\n", "Keepalives",
p->stats.msg_sent_keepalive, p->stats.msg_rcvd_keepalive);
printf(" %-15s %10llu %10llu\n", "Route Refresh",
p->stats.msg_sent_rrefresh, p->stats.msg_rcvd_rrefresh);
printf(" %-15s %10llu %10llu\n\n", "Total",
p->stats.msg_sent_open + p->stats.msg_sent_notification +
p->stats.msg_sent_update + p->stats.msg_sent_keepalive +
p->stats.msg_sent_rrefresh,
p->stats.msg_rcvd_open + p->stats.msg_rcvd_notification +
p->stats.msg_rcvd_update + p->stats.msg_rcvd_keepalive +
p->stats.msg_rcvd_rrefresh);
printf(" Update statistics:\n");
printf(" %-15s %-10s %-10s %-10s\n", "", "Sent", "Received",
"Pending");
printf(" %-15s %10u %10u\n", "Prefixes",
p->stats.prefix_out_cnt, p->stats.prefix_cnt);
printf(" %-15s %10llu %10llu %10u\n", "Updates",
p->stats.prefix_sent_update, p->stats.prefix_rcvd_update,
p->stats.pending_update);
printf(" %-15s %10llu %10llu %10u\n", "Withdraws",
p->stats.prefix_sent_withdraw, p->stats.prefix_rcvd_withdraw,
p->stats.pending_withdraw);
printf(" %-15s %10llu %10llu\n", "End-of-Rib",
p->stats.prefix_sent_eor, p->stats.prefix_rcvd_eor);
printf(" Route Refresh statistics:\n");
printf(" %-15s %10llu %10llu\n", "Request",
p->stats.refresh_sent_req, p->stats.refresh_rcvd_req);
printf(" %-15s %10llu %10llu\n", "Begin-of-RR",
p->stats.refresh_sent_borr, p->stats.refresh_rcvd_borr);
printf(" %-15s %10llu %10llu\n\n", "End-of-RR",
p->stats.refresh_sent_eorr, p->stats.refresh_rcvd_eorr);
printf(" Queue statistics:\n");
printf(" %-15s %-10s %-10s\n", "", "Count", "Size");
printf(" %-15s %10llu %10llu\n", "ibuf queue",
p->stats.ibufq_msg_count, p->stats.ibufq_payload_size);
printf(" %-15s %10llu %10s\n", "rib queue",
p->stats.rib_entry_count, "-");
}
static void
show_neighbor_full(struct peer *p, struct parse_result *res)
{
const char *errstr;
struct in_addr ina;
char *s;
int hascapamp, hascapaap;
uint8_t i;
if ((p->conf.remote_addr.aid == AID_INET &&
p->conf.remote_masklen != 32) ||
(p->conf.remote_addr.aid == AID_INET6 &&
p->conf.remote_masklen != 128)) {
if (asprintf(&s, "%s/%u",
log_addr(&p->conf.remote_addr),
p->conf.remote_masklen) == -1)
err(1, NULL);
} else if ((s = strdup(log_addr(&p->conf.remote_addr))) == NULL)
err(1, "strdup");
printf("BGP neighbor is %s, ", s);
free(s);
if (p->conf.remote_as == 0 && p->conf.template)
printf("remote AS: accept any");
else
printf("remote AS %s", log_as(p->conf.remote_as));
if (p->conf.template)
printf(", Template");
if (p->template)
printf(", Cloned");
if (p->conf.passive)
printf(", Passive");
if (p->conf.ebgp && p->conf.distance > 1)
printf(", Multihop (%u)", (int)p->conf.distance);
printf("\n");
if (p->conf.descr[0])
printf(" Description: %s\n", p->conf.descr);
if (p->conf.ebgp && p->conf.role != ROLE_NONE)
printf(" Role: %s\n", log_policy(p->conf.role));
if (p->conf.max_prefix) {
printf(" Max-prefix: %u", p->conf.max_prefix);
if (p->conf.max_prefix_restart)
printf(" (restart %u)",
p->conf.max_prefix_restart);
}
if (p->conf.max_out_prefix) {
printf(" Max-prefix out: %u", p->conf.max_out_prefix);
if (p->conf.max_out_prefix_restart)
printf(" (restart %u)",
p->conf.max_out_prefix_restart);
}
if (p->conf.max_prefix || p->conf.max_out_prefix)
printf("\n");
if (p->state == STATE_ESTABLISHED) {
ina.s_addr = htonl(p->remote_bgpid);
printf(" BGP version 4, remote router-id %s",
inet_ntoa(ina));
printf("%s\n", fmt_auth_method(p->auth_conf.method));
}
printf(" BGP state = %s", statenames[p->state]);
if (p->conf.down) {
printf(", marked down");
}
if (p->conf.reason[0]) {
printf(" with shutdown reason \"%s\"",
log_reason(p->conf.reason));
}
if (monotime_valid(p->stats.last_updown))
printf(", %s for %s",
p->state == STATE_ESTABLISHED ? "up" : "down",
fmt_monotime(p->stats.last_updown));
printf("\n");
printf(" Last read %s, holdtime %us, keepalive interval %us\n",
fmt_monotime(p->stats.last_read),
p->holdtime, p->holdtime/3);
printf(" Last write %s\n", fmt_monotime(p->stats.last_write));
hascapamp = 0;
hascapaap = 0;
for (i = AID_MIN; i < AID_MAX; i++) {
if (p->capa.peer.mp[i])
hascapamp = 1;
if (p->capa.peer.add_path[i])
hascapaap = 1;
}
if (hascapamp || hascapaap || p->capa.peer.grestart.restart ||
p->capa.peer.refresh || p->capa.peer.enhanced_rr ||
p->capa.peer.as4byte || p->capa.peer.policy) {
printf(" Neighbor capabilities:\n");
if (hascapamp)
show_neighbor_capa_mp(&p->capa.peer);
if (p->capa.peer.as4byte)
printf(" 4-byte AS numbers\n");
if (p->capa.peer.refresh)
printf(" Route Refresh\n");
if (p->capa.peer.enhanced_rr)
printf(" Enhanced Route Refresh\n");
if (p->capa.peer.ext_msg)
printf(" Extended message\n");
if (p->capa.peer.grestart.restart)
show_neighbor_capa_restart(&p->capa.peer);
if (hascapaap)
show_neighbor_capa_add_path(&p->capa.peer);
if (p->capa.peer.policy)
printf(" Open Policy role %s (local %s)\n",
log_policy(p->remote_role),
log_policy(p->conf.role));
}
hascapamp = 0;
hascapaap = 0;
for (i = AID_MIN; i < AID_MAX; i++) {
if (p->capa.neg.mp[i])
hascapamp = 1;
if (p->capa.neg.add_path[i])
hascapaap = 1;
}
if (hascapamp || hascapaap || p->capa.neg.grestart.restart ||
p->capa.neg.refresh || p->capa.neg.enhanced_rr ||
p->capa.neg.as4byte || p->capa.neg.policy) {
printf(" Negotiated capabilities:\n");
if (hascapamp)
show_neighbor_capa_mp(&p->capa.neg);
if (p->capa.neg.as4byte)
printf(" 4-byte AS numbers\n");
if (p->capa.neg.refresh)
printf(" Route Refresh\n");
if (p->capa.neg.enhanced_rr)
printf(" Enhanced Route Refresh\n");
if (p->capa.neg.ext_msg)
printf(" Extended message\n");
if (p->capa.neg.grestart.restart)
show_neighbor_capa_restart(&p->capa.neg);
if (hascapaap)
show_neighbor_capa_add_path(&p->capa.neg);
if (p->capa.neg.policy)
printf(" Open Policy role %s (local %s)\n",
log_policy(p->remote_role),
log_policy(p->conf.role));
}
printf("\n");
if (res->action == SHOW_NEIGHBOR_TIMERS)
return;
show_neighbor_msgstats(p);
printf("\n");
errstr = fmt_errstr(p->stats.last_sent_errcode,
p->stats.last_sent_suberr);
if (errstr)
printf(" Last error sent: %s\n", errstr);
errstr = fmt_errstr(p->stats.last_rcvd_errcode,
p->stats.last_rcvd_suberr);
if (errstr)
printf(" Last error received: %s\n", errstr);
if (p->stats.last_reason[0]) {
printf(" Last received shutdown reason: \"%s\"\n",
log_reason(p->stats.last_reason));
}
if (p->state >= STATE_OPENSENT) {
printf(" Local host: %20s, Local port: %5u\n",
log_addr(&p->local), p->local_port);
printf(" Remote host: %20s, Remote port: %5u\n",
log_addr(&p->remote), p->remote_port);
printf("\n");
}
}
static void
show_neighbor(struct peer *p, struct parse_result *res)
{
char *s;
switch (res->action) {
case SHOW:
case SHOW_SUMMARY:
show_summary(p);
break;
case SHOW_SUMMARY_TERSE:
s = fmt_peer(p->conf.descr, &p->conf.remote_addr,
p->conf.remote_masklen);
printf("%s %s %s\n", s, log_as(p->conf.remote_as),
p->conf.template ? "Template" : statenames[p->state]);
free(s);
break;
case SHOW_NEIGHBOR:
case SHOW_NEIGHBOR_TIMERS:
show_neighbor_full(p, res);
break;
case SHOW_NEIGHBOR_TERSE:
s = fmt_peer(NULL, &p->conf.remote_addr,
p->conf.remote_masklen);
printf("%llu %llu %llu %llu %llu %llu %llu %llu %llu "
"%llu %u %u %llu %llu %llu %llu %s %s \"%s\"\n",
p->stats.msg_sent_open, p->stats.msg_rcvd_open,
p->stats.msg_sent_notification,
p->stats.msg_rcvd_notification,
p->stats.msg_sent_update, p->stats.msg_rcvd_update,
p->stats.msg_sent_keepalive, p->stats.msg_rcvd_keepalive,
p->stats.msg_sent_rrefresh, p->stats.msg_rcvd_rrefresh,
p->stats.prefix_cnt, p->conf.max_prefix,
p->stats.prefix_sent_update, p->stats.prefix_rcvd_update,
p->stats.prefix_sent_withdraw,
p->stats.prefix_rcvd_withdraw, s,
log_as(p->conf.remote_as), p->conf.descr);
free(s);
break;
default:
break;
}
}
static void
show_timer(struct ctl_timer *t)
{
printf(" %-20s ", timernames[t->type]);
if (get_rel_monotime(t->val) >= 0)
printf("%s\n", "due");
else
printf("%s\n", fmt_monotime(t->val));
}
static void
show_fib(struct kroute_full *kf)
{
char *p;
if (asprintf(&p, "%s/%u", log_addr(&kf->prefix), kf->prefixlen) == -1)
err(1, NULL);
printf("%-5s %4i %-32s ", fmt_fib_flags(kf->flags), kf->priority, p);
free(p);
if (kf->flags & F_CONNECTED)
printf("link#%u", kf->ifindex);
else
printf("%s", log_addr(&kf->nexthop));
if (kf->flags & F_MPLS)
printf(" mpls %d", ntohl(kf->mplslabel) >> MPLS_LABEL_OFFSET);
printf("\n");
}
static void
show_fib_table(struct ktable *kt)
{
printf("%5i %-20s %-8s%s\n", kt->rtableid, kt->descr,
kt->fib_sync ? "coupled" : "decoupled",
kt->fib_sync != kt->fib_conf ? "*" : "");
}
static void
print_flowspec_list(struct flowspec *f, int type, int is_v6)
{
const uint8_t *comp;
const char *fmt;
int complen, off = 0;
if (flowspec_get_component(f->data, f->len, type, is_v6,
&comp, &complen) != 1)
return;
printf("%s ", flowspec_fmt_label(type));
fmt = flowspec_fmt_num_op(comp, complen, &off);
if (off == -1) {
printf("%s ", fmt);
} else {
printf("{ %s ", fmt);
do {
fmt = flowspec_fmt_num_op(comp, complen, &off);
printf("%s ", fmt);
} while (off != -1);
printf("} ");
}
}
static void
print_flowspec_flags(struct flowspec *f, int type, int is_v6)
{
const uint8_t *comp;
const char *fmt, *flags;
int complen, off = 0;
switch (type) {
case FLOWSPEC_TYPE_TCP_FLAGS:
flags = FLOWSPEC_TCP_FLAG_STRING;
break;
case FLOWSPEC_TYPE_FRAG:
if (!is_v6)
flags = FLOWSPEC_FRAG_STRING4;
else
flags = FLOWSPEC_FRAG_STRING6;
break;
default:
printf("??? ");
return;
}
if (flowspec_get_component(f->data, f->len, type, is_v6,
&comp, &complen) != 1)
return;
printf("%s ", flowspec_fmt_label(type));
fmt = flowspec_fmt_bin_op(comp, complen, &off, flags);
if (off == -1) {
printf("%s ", fmt);
} else {
printf("{ %s ", fmt);
do {
fmt = flowspec_fmt_bin_op(comp, complen, &off, flags);
printf("%s ", fmt);
} while (off != -1);
printf("} ");
}
}
static void
print_flowspec_addr(struct flowspec *f, int type, int is_v6)
{
struct bgpd_addr addr;
uint8_t plen;
flowspec_get_addr(f->data, f->len, type, is_v6, &addr, &plen, NULL);
if (plen == 0)
printf("%s any ", flowspec_fmt_label(type));
else
printf("%s %s/%u ", flowspec_fmt_label(type),
log_addr(&addr), plen);
}
static void
show_flowspec(struct flowspec *f)
{
int is_v6 = (f->aid == AID_FLOWSPECv6);
printf("%-5s ", fmt_fib_flags(f->flags));
print_flowspec_list(f, FLOWSPEC_TYPE_PROTO, is_v6);
print_flowspec_addr(f, FLOWSPEC_TYPE_SOURCE, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_SRC_PORT, is_v6);
print_flowspec_addr(f, FLOWSPEC_TYPE_DEST, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_DST_PORT, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_DSCP, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_PKT_LEN, is_v6);
print_flowspec_flags(f, FLOWSPEC_TYPE_TCP_FLAGS, is_v6);
print_flowspec_flags(f, FLOWSPEC_TYPE_FRAG, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_ICMP_TYPE, is_v6);
print_flowspec_list(f, FLOWSPEC_TYPE_ICMP_CODE, is_v6);
printf("\n");
}
static void
show_nexthop(struct ctl_show_nexthop *nh)
{
char *s;
printf("%s %-15s ", nh->valid ? "*" : " ", log_addr(&nh->addr));
if (!nh->krvalid) {
printf("\n");
return;
}
if (asprintf(&s, "%s/%u", log_addr(&nh->kr.prefix),
nh->kr.prefixlen) == -1)
err(1, NULL);
printf("%-20s", s);
free(s);
printf("%3i %-15s ", nh->kr.priority,
nh->kr.flags & F_CONNECTED ? "connected" :
log_addr(&nh->kr.nexthop));
if (nh->iface.ifname[0]) {
printf("%s (%s, %s)", nh->iface.ifname,
nh->iface.is_up ? "UP" : "DOWN",
nh->iface.baudrate ?
get_baudrate(nh->iface.baudrate, "bps") :
nh->iface.linkstate);
}
printf("\n");
}
static void
show_interface(struct ctl_show_interface *iface)
{
printf("%-15s", iface->ifname);
printf("%-9u", iface->rdomain);
printf("%-9s", iface->nh_reachable ? "ok" : "invalid");
printf("%-7s", iface->is_up ? "UP" : "");
if (iface->media[0])
printf("%s, ", iface->media);
printf("%s", iface->linkstate);
if (iface->baudrate > 0)
printf(", %s", get_baudrate(iface->baudrate, "Bit/s"));
printf("\n");
}
static void
show_communities(struct ibuf *data, struct parse_result *res)
{
struct community c;
uint64_t ext;
uint8_t type = 0;
while (ibuf_size(data) != 0) {
if (ibuf_get(data, &c, sizeof(c)) == -1) {
warn("communities");
break;
}
if (type != c.flags) {
if (type != 0)
printf("%c", EOL0(res->flags));
printf(" %s:", fmt_attr(c.flags,
ATTR_OPTIONAL | ATTR_TRANSITIVE));
type = c.flags;
}
switch (c.flags) {
case COMMUNITY_TYPE_BASIC:
printf(" %s", fmt_community(c.data1, c.data2));
break;
case COMMUNITY_TYPE_LARGE:
printf(" %s",
fmt_large_community(c.data1, c.data2, c.data3));
break;
case COMMUNITY_TYPE_EXT:
ext = (uint64_t)c.data3 << 48;
switch ((c.data3 >> 8) & EXT_COMMUNITY_VALUE) {
case EXT_COMMUNITY_TRANS_TWO_AS:
case EXT_COMMUNITY_TRANS_OPAQUE:
case EXT_COMMUNITY_TRANS_EVPN:
ext |= ((uint64_t)c.data1 & 0xffff) << 32;
ext |= (uint64_t)c.data2;
break;
case EXT_COMMUNITY_TRANS_FOUR_AS:
case EXT_COMMUNITY_TRANS_IPV4:
ext |= (uint64_t)c.data1 << 16;
ext |= (uint64_t)c.data2 & 0xffff;
break;
}
printf(" %s", fmt_ext_community(ext));
break;
}
}
printf("%c", EOL0(res->flags));
}
static void
show_community(struct ibuf *buf)
{
uint16_t a, v;
while (ibuf_size(buf) > 0) {
if (ibuf_get_n16(buf, &a) == -1 ||
ibuf_get_n16(buf, &v) == -1) {
printf("bad length");
return;
}
printf("%s", fmt_community(a, v));
if (ibuf_size(buf) > 0)
printf(" ");
}
}
static void
show_large_community(struct ibuf *buf)
{
uint32_t a, l1, l2;
while (ibuf_size(buf) > 0) {
if (ibuf_get_n32(buf, &a) == -1 ||
ibuf_get_n32(buf, &l1) == -1 ||
ibuf_get_n32(buf, &l2) == -1) {
printf("bad length");
return;
}
printf("%s", fmt_large_community(a, l1, l2));
if (ibuf_size(buf) > 0)
printf(" ");
}
}
static void
show_ext_community(struct ibuf *buf)
{
uint64_t ext;
while (ibuf_size(buf) > 0) {
if (ibuf_get_n64(buf, &ext) == -1) {
printf("bad length");
return;
}
printf("%s", fmt_ext_community(ext));
if (ibuf_size(buf) > 0)
printf(" ");
}
}
static void
show_attr(struct ibuf *buf, int reqflags, int addpath)
{
struct in_addr id;
struct bgpd_addr prefix;
struct ibuf asbuf, *path = NULL;
char *aspath;
size_t i, alen;
uint32_t as, pathid, val;
uint16_t short_as, afi;
uint8_t flags, type, safi, aid, prefixlen, origin, b;
int e2, e4;
if (ibuf_get_n8(buf, &flags) == -1 ||
ibuf_get_n8(buf, &type) == -1)
goto bad_len;
if (flags & ATTR_EXTLEN) {
uint16_t attr_len;
if (ibuf_get_n16(buf, &attr_len) == -1)
goto bad_len;
alen = attr_len;
} else {
uint8_t attr_len;
if (ibuf_get_n8(buf, &attr_len) == -1)
goto bad_len;
alen = attr_len;
}
if (alen > ibuf_size(buf))
goto bad_len;
printf(" %s: ", fmt_attr(type, flags));
switch (type) {
case ATTR_ORIGIN:
if (alen != 1 || ibuf_get_n8(buf, &origin) == -1)
goto bad_len;
printf("%s", fmt_origin(origin, 0));
break;
case ATTR_ASPATH:
case ATTR_AS4_PATH:
e4 = aspath_verify(buf, 1, 0);
e2 = aspath_verify(buf, 0, 0);
if (e4 == 0 || e4 == AS_ERR_SOFT) {
ibuf_from_ibuf(&asbuf, buf);
} else if (e2 == 0 || e2 == AS_ERR_SOFT) {
if ((path = aspath_inflate(buf)) == NULL) {
printf("aspath_inflate failed");
break;
}
ibuf_from_ibuf(&asbuf, path);
} else {
printf("bad AS-Path");
break;
}
if (aspath_asprint(&aspath, &asbuf) == -1)
err(1, NULL);
printf("%s", aspath);
free(aspath);
ibuf_free(path);
break;
case ATTR_NEXTHOP:
case ATTR_ORIGINATOR_ID:
if (alen != 4 || ibuf_get(buf, &id, sizeof(id)) == -1)
goto bad_len;
printf("%s", inet_ntoa(id));
break;
case ATTR_MED:
case ATTR_LOCALPREF:
if (alen != 4 || ibuf_get_n32(buf, &val) == -1)
goto bad_len;
printf("%u", val);
break;
case ATTR_AGGREGATOR:
case ATTR_AS4_AGGREGATOR:
if (alen == 8) {
if (ibuf_get_n32(buf, &as) == -1 ||
ibuf_get(buf, &id, sizeof(id)) == -1)
goto bad_len;
} else if (alen == 6) {
if (ibuf_get_n16(buf, &short_as) == -1 ||
ibuf_get(buf, &id, sizeof(id)) == -1)
goto bad_len;
as = short_as;
} else {
goto bad_len;
}
printf("%s [%s]", log_as(as), inet_ntoa(id));
break;
case ATTR_COMMUNITIES:
show_community(buf);
break;
case ATTR_CLUSTER_LIST:
while (ibuf_size(buf) > 0) {
if (ibuf_get(buf, &id, sizeof(id)) == -1)
goto bad_len;
printf(" %s", inet_ntoa(id));
}
break;
case ATTR_MP_REACH_NLRI:
case ATTR_MP_UNREACH_NLRI:
if (ibuf_get_n16(buf, &afi) == -1 ||
ibuf_get_n8(buf, &safi) == -1)
goto bad_len;
if (afi2aid(afi, safi, &aid) == -1) {
printf("bad AFI/SAFI pair");
break;
}
printf(" %s", aid2str(aid));
if (type == ATTR_MP_REACH_NLRI) {
struct bgpd_addr nexthop;
uint8_t nhlen;
if (ibuf_get_n8(buf, &nhlen) == -1)
goto bad_len;
memset(&nexthop, 0, sizeof(nexthop));
switch (aid) {
case AID_INET6:
nexthop.aid = aid;
if (nhlen != 16 && nhlen != 32)
goto bad_len;
if (ibuf_get(buf, &nexthop.v6,
sizeof(nexthop.v6)) == -1)
goto bad_len;
break;
case AID_VPN_IPv4:
if (nhlen != 12)
goto bad_len;
nexthop.aid = AID_INET;
if (ibuf_skip(buf, sizeof(uint64_t)) == -1 ||
ibuf_get(buf, &nexthop.v4,
sizeof(nexthop.v4)) == -1)
goto bad_len;
break;
case AID_VPN_IPv6:
if (nhlen != 24)
goto bad_len;
nexthop.aid = AID_INET6;
if (ibuf_skip(buf, sizeof(uint64_t)) == -1 ||
ibuf_get(buf, &nexthop.v6,
sizeof(nexthop.v6)) == -1)
goto bad_len;
break;
default:
printf("unhandled AID #%u", aid);
goto done;
}
if (ibuf_skip(buf, 1) == -1)
goto bad_len;
printf(" nexthop: %s", log_addr(&nexthop));
}
while (ibuf_size(buf) > 0) {
if (addpath)
if (ibuf_get_n32(buf, &pathid) == -1)
goto bad_len;
switch (aid) {
case AID_INET6:
if (nlri_get_prefix6(buf, &prefix,
&prefixlen) == -1)
goto bad_len;
break;
case AID_VPN_IPv4:
if (nlri_get_vpn4(buf, &prefix,
&prefixlen, 1) == -1)
goto bad_len;
break;
case AID_VPN_IPv6:
if (nlri_get_vpn6(buf, &prefix,
&prefixlen, 1) == -1)
goto bad_len;
break;
default:
printf("unhandled AID #%u", aid);
goto done;
}
printf(" %s/%u", log_addr(&prefix), prefixlen);
if (addpath)
printf(" path-id %u", pathid);
}
break;
case ATTR_EXT_COMMUNITIES:
show_ext_community(buf);
break;
case ATTR_LARGE_COMMUNITIES:
show_large_community(buf);
break;
case ATTR_OTC:
if (alen != 4 || ibuf_get_n32(buf, &as) == -1)
goto bad_len;
printf("%s", log_as(as));
break;
case ATTR_ATOMIC_AGGREGATE:
default:
printf(" len %zu", alen);
if (alen) {
printf(":");
for (i = 0; i < alen; i++) {
if (ibuf_get_n8(buf, &b) == -1)
goto bad_len;
printf(" %02x", b);
}
}
break;
}
done:
printf("%c", EOL0(reqflags));
return;
bad_len:
printf("bad length%c", EOL0(reqflags));
}
static void
show_rib_brief(struct ctl_show_rib *r, struct ibuf *asbuf)
{
char *p, *aspath;
if (asprintf(&p, "%s/%u", log_addr(&r->prefix), r->prefixlen) == -1)
err(1, NULL);
printf("%s %s-%s %-20s %-15s %5u %5u ",
fmt_flags(r->flags, 1), fmt_ovs(r->roa_validation_state, 1),
fmt_avs(r->aspa_validation_state, 1), p,
log_addr(&r->exit_nexthop), r->local_pref, r->med);
free(p);
if (aspath_asprint(&aspath, asbuf) == -1)
err(1, NULL);
if (strlen(aspath) > 0)
printf("%s ", aspath);
free(aspath);
printf("%s\n", fmt_origin(r->origin, 1));
}
static void
show_rib_detail(struct ctl_show_rib *r, struct ibuf *asbuf, int flag0)
{
struct in_addr id;
char *aspath, *s;
printf("\nBGP routing table entry for %s/%u%c",
log_addr(&r->prefix), r->prefixlen,
EOL0(flag0));
if (aspath_asprint(&aspath, asbuf) == -1)
err(1, NULL);
if (strlen(aspath) > 0)
printf(" %s%c", aspath, EOL0(flag0));
free(aspath);
s = fmt_peer(r->descr, &r->remote_addr, -1);
id.s_addr = htonl(r->remote_id);
printf(" Nexthop %s ", log_addr(&r->exit_nexthop));
printf("(via %s) Neighbor %s (%s)", log_addr(&r->true_nexthop), s,
inet_ntoa(id));
if (r->flags & F_PREF_PATH_ID)
printf(" Path-Id: %u", r->path_id);
printf("%c", EOL0(flag0));
free(s);
printf(" Origin %s, metric %u, localpref %u, weight %u, ovs %s, ",
fmt_origin(r->origin, 0), r->med, r->local_pref, r->weight,
fmt_ovs(r->roa_validation_state, 0));
printf("avs %s, %s", fmt_avs(r->aspa_validation_state, 0),
fmt_flags(r->flags, 0));
printf("%c Last update: %s ago%c", EOL0(flag0),
fmt_monotime(r->lastchange), EOL0(flag0));
}
static void
show_rib(struct ctl_show_rib *r, struct ibuf *aspath, struct parse_result *res)
{
if (res->flags & F_CTL_DETAIL)
show_rib_detail(r, aspath, res->flags);
else
show_rib_brief(r, aspath);
}
static void
show_rib_mem(struct rde_memstats *stats)
{
size_t pts = 0;
int i;
printf("RDE memory statistics\n");
for (i = 0; i < AID_MAX; i++) {
if (stats->pt_cnt[i] == 0)
continue;
pts += stats->pt_size[i];
printf("%10lld %s network entries using %s of memory\n",
stats->pt_cnt[i], aid_vals[i].name,
fmt_mem(stats->pt_size[i]));
}
printf("%10lld rib entries using %s of memory\n",
stats->rib_cnt, fmt_mem(stats->rib_cnt *
sizeof(struct rib_entry)));
printf("%10lld prefix entries using %s of memory\n",
stats->prefix_cnt, fmt_mem(stats->prefix_cnt *
sizeof(struct prefix)));
printf("%10lld adjout_prefix entries using %s out of",
stats->adjout_prefix_cnt,
fmt_mem(stats->adjout_prefix_cnt * sizeof(struct adjout_prefix)));
printf(" %s memory\n", fmt_mem(stats->adjout_prefix_size));
printf("%10lld adjout attribute entries using %s of memory\n",
stats->adjout_attr_cnt, fmt_mem(stats->adjout_attr_cnt *
sizeof(struct adjout_attr)));
printf("\t and holding %lld references\n",
stats->adjout_attr_refs);
printf("%10lld BGP path attribute entries using %s of memory\n",
stats->path_cnt, fmt_mem(stats->path_cnt *
sizeof(struct rde_aspath)));
printf("\t and holding %lld references\n",
stats->path_refs);
printf("%10lld BGP AS-PATH attribute entries using "
"%s of memory\n", stats->aspath_cnt, fmt_mem(stats->aspath_size));
printf("%10lld entries for %lld BGP communities "
"using %s of memory\n", stats->comm_cnt, stats->comm_nmemb,
fmt_mem(stats->comm_cnt * sizeof(struct rde_community) +
stats->comm_size * sizeof(struct community)));
printf("\t and holding %lld references\n",
stats->comm_refs);
printf("%10lld BGP attributes entries using %s of memory\n",
stats->attr_cnt, fmt_mem(stats->attr_cnt *
sizeof(struct attr)));
printf("\t and holding %lld references\n",
stats->attr_refs);
printf("%10lld BGP attributes using %s of memory\n",
stats->attr_dcnt, fmt_mem(stats->attr_data));
printf("%10lld pending attribute entries using %s of memory\n",
stats->pend_attr_cnt, fmt_mem(stats->pend_attr_cnt *
sizeof(struct pend_attr)));
printf("%10lld pending prefix entries using %s of memory\n",
stats->pend_prefix_cnt, fmt_mem(stats->pend_prefix_cnt *
sizeof(struct pend_prefix)));
printf("%10lld extended bitmaps using %s of memory\n",
stats->bitmap_cnt, fmt_mem(stats->bitmap_size));
printf("%10lld hash tables using %s of memory\n",
stats->hash_cnt, fmt_mem(stats->hash_size));
printf("\t and holding %lld references\n",
stats->hash_refs);
printf("%10lld filters using %s of memory\n",
stats->filter_cnt, fmt_mem(stats->filter_size));
printf("\t and holding %lld references\n",
stats->filter_refs);
printf("%10lld filter-sets using %s of memory\n",
stats->filter_set_cnt, fmt_mem(stats->filter_set_size));
printf("\t and holding %lld references\n",
stats->filter_set_refs);
printf("%10lld as-set elements in %lld tables using "
"%s of memory\n", stats->aset_nmemb, stats->aset_cnt,
fmt_mem(stats->aset_size));
printf("%10lld prefix-set elements using %s of memory\n",
stats->pset_cnt, fmt_mem(stats->pset_size));
printf("%10lld aspa-set elements using %s of memory\n",
stats->aspa_cnt, fmt_mem(stats->aspa_size));
printf("RIB using %s of memory\n", fmt_mem(pts +
stats->prefix_cnt * sizeof(struct prefix) +
stats->adjout_prefix_cnt * sizeof(struct adjout_prefix) +
stats->adjout_attr_cnt * sizeof(struct adjout_attr) +
stats->pend_prefix_cnt * sizeof(struct pend_prefix) +
stats->pend_attr_cnt * sizeof(struct pend_attr) +
stats->rib_cnt * sizeof(struct rib_entry) +
stats->path_cnt * sizeof(struct rde_aspath) +
stats->aspath_size + stats->attr_cnt * sizeof(struct attr) +
stats->attr_data + stats->bitmap_size + stats->hash_size));
printf("Sets and filters using %s of memory\n",
fmt_mem(stats->aset_size + stats->pset_size + stats->aspa_size +
stats->filter_set_size));
printf("\nRDE queue statistics\n");
printf("%10lld messages queued holding %s of data\n",
stats->rde_ibufq_msg_count, fmt_mem(stats->rde_ibufq_payload_size));
printf("%10lld rib entries queued\n", stats->rde_rib_entry_count);
printf("\nRDE timing statistics\n");
printf("%10lld usec spent in the event loop for %llu rounds\n",
stats->rde_event_loop_usec, stats->rde_event_loop_count);
printf("%10lld usec spent on io\n", stats->rde_event_io_usec);
printf("%10lld usec spent on peers\n", stats->rde_event_peer_usec);
printf("%10lld usec spent on adj-out\n", stats->rde_event_adjout_usec);
printf("%10lld usec spent on rib dumps\n",
stats->rde_event_ribdump_usec);
printf("%10lld usec spent on nexthops\n",
stats->rde_event_nexthop_usec);
printf("%10lld usec spent on updates\n", stats->rde_event_update_usec);
}
static void
show_rib_set(struct ctl_show_set *set)
{
char buf[64];
if (set->type == ASNUM_SET || set->type == ASPA_SET)
snprintf(buf, sizeof(buf), "%7s %7s %6zu",
"-", "-", set->as_cnt);
else
snprintf(buf, sizeof(buf), "%7zu %7zu %6s",
set->v4_cnt, set->v6_cnt, "-");
printf("%-6s %-34s %s %12s\n", fmt_set_type(set), set->name,
buf, fmt_monotime(set->lastchange));
}
static void
show_rtr(struct ctl_show_rtr *rtr)
{
static int not_first;
if (not_first)
printf("\n");
not_first = 1;
printf("RTR neighbor is %s, port %u\n",
log_addr(&rtr->remote_addr), rtr->remote_port);
printf(" State: %s\n", rtr->state);
if (rtr->descr[0])
printf(" Description: %s\n", rtr->descr);
if (rtr->local_addr.aid != AID_UNSPEC)
printf(" Local Address: %s\n", log_addr(&rtr->local_addr));
if (rtr->session_id != -1)
printf(" Version: %u min %u Session ID: %d Serial #: %u\n",
rtr->version, rtr->min_version, rtr->session_id,
rtr->serial);
printf(" Refresh: %u, Retry: %u, Expire: %u\n",
rtr->refresh, rtr->retry, rtr->expire);
if (rtr->last_sent_error != NO_ERROR) {
printf(" Last sent error: %s\n",
log_rtr_error(rtr->last_sent_error));
if (rtr->last_sent_msg[0])
printf(" with reason \"%s\"\n",
log_reason(rtr->last_sent_msg));
}
if (rtr->last_recv_error != NO_ERROR) {
printf(" Last received error: %s\n",
log_rtr_error(rtr->last_recv_error));
if (rtr->last_recv_msg[0])
printf(" with reason \"%s\"\n",
log_reason(rtr->last_recv_msg));
}
printf("\n");
}
static void
show_result(u_int rescode)
{
if (rescode == 0)
printf("request processed\n");
else if (rescode >=
sizeof(ctl_res_strerror)/sizeof(ctl_res_strerror[0]))
printf("unknown result error code %u\n", rescode);
else
printf("%s\n", ctl_res_strerror[rescode]);
}
static void
show_tail(void)
{
}
const struct output show_output = {
.head = show_head,
.neighbor = show_neighbor,
.timer = show_timer,
.fib = show_fib,
.fib_table = show_fib_table,
.flowspec = show_flowspec,
.nexthop = show_nexthop,
.interface = show_interface,
.communities = show_communities,
.attr = show_attr,
.rib = show_rib,
.rib_mem = show_rib_mem,
.set = show_rib_set,
.rtr = show_rtr,
.result = show_result,
.tail = show_tail,
};
