[ovs-dev] [PATCH v3 4/7] match: color output of match conditions for ovs-ofctl dump-flows
Quentin Monnet
quentin.monnet at 6wind.com
Wed Mar 2 14:56:19 UTC 2016
Add color output for flow match conditions for ovs-ofctl dump-flows
command utility, by inserting color markers in the functions responsible
for printing those match condictions.
Signed-off-by: Quentin Monnet <quentin.monnet at 6wind.com>
---
lib/flow.c | 3 +-
lib/match.c | 126 ++++++++++++++++++++++++++++++++++--------------------------
2 files changed, 73 insertions(+), 56 deletions(-)
diff --git a/lib/flow.c b/lib/flow.c
index 2a7116b675da..5e962e231572 100644
--- a/lib/flow.c
+++ b/lib/flow.c
@@ -26,6 +26,7 @@
#include <stdlib.h>
#include <string.h>
#include "byte-order.h"
+#include "colors.h"
#include "coverage.h"
#include "csum.h"
#include "dynamic-string.h"
@@ -984,7 +985,7 @@ format_flags_masked(struct ds *ds, const char *name,
uint32_t mask, uint32_t max_mask)
{
if (name) {
- ds_put_format(ds, "%s=", name);
+ ds_put_format(ds, "%s%s=%s", colors.param, name, colors.end);
}
if (mask == max_mask) {
diff --git a/lib/match.c b/lib/match.c
index 95d34bc7011f..bbcfb4d99435 100644
--- a/lib/match.c
+++ b/lib/match.c
@@ -18,6 +18,7 @@
#include "match.h"
#include <stdlib.h>
#include "byte-order.h"
+#include "colors.h"
#include "dynamic-string.h"
#include "ofp-util.h"
#include "packets.h"
@@ -868,7 +869,7 @@ format_eth_masked(struct ds *s, const char *name,
const struct eth_addr eth, const struct eth_addr mask)
{
if (!eth_addr_is_zero(mask)) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
eth_format_masked(eth, &mask, s);
ds_put_char(s, ',');
}
@@ -879,7 +880,7 @@ format_ip_netmask(struct ds *s, const char *name, ovs_be32 ip,
ovs_be32 netmask)
{
if (netmask) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
ip_format_masked(ip, netmask, s);
ds_put_char(s, ',');
}
@@ -891,7 +892,7 @@ format_ipv6_netmask(struct ds *s, const char *name,
const struct in6_addr *netmask)
{
if (!ipv6_mask_is_any(netmask)) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
ipv6_format_masked(addr, netmask, s);
ds_put_char(s, ',');
}
@@ -902,7 +903,7 @@ format_uint16_masked(struct ds *s, const char *name,
uint16_t value, uint16_t mask)
{
if (mask != 0) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
if (mask == UINT16_MAX) {
ds_put_format(s, "%"PRIu16, value);
} else {
@@ -917,7 +918,7 @@ format_be16_masked(struct ds *s, const char *name,
ovs_be16 value, ovs_be16 mask)
{
if (mask != htons(0)) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
if (mask == OVS_BE16_MAX) {
ds_put_format(s, "%"PRIu16, ntohs(value));
} else {
@@ -933,7 +934,7 @@ format_be32_masked(struct ds *s, const char *name,
ovs_be32 value, ovs_be32 mask)
{
if (mask != htonl(0)) {
- ds_put_format(s, "%s=", name);
+ ds_put_format(s, "%s%s=%s", colors.param, name, colors.end);
if (mask == OVS_BE32_MAX) {
ds_put_format(s, "%"PRIu32, ntohl(value));
} else {
@@ -949,7 +950,8 @@ format_uint32_masked(struct ds *s, const char *name,
uint32_t value, uint32_t mask)
{
if (mask) {
- ds_put_format(s, "%s=%#"PRIx32, name, value);
+ ds_put_format(s, "%s%s=%s%#"PRIx32,
+ colors.param, name, colors.end, value);
if (mask != UINT32_MAX) {
ds_put_format(s, "/%#"PRIx32, mask);
}
@@ -962,7 +964,8 @@ format_be64_masked(struct ds *s, const char *name,
ovs_be64 value, ovs_be64 mask)
{
if (mask != htonll(0)) {
- ds_put_format(s, "%s=%#"PRIx64, name, ntohll(value));
+ ds_put_format(s, "%s%s=%s%#"PRIx64,
+ colors.param, name, colors.end, ntohll(value));
if (mask != OVS_BE64_MAX) {
ds_put_format(s, "/%#"PRIx64, ntohll(mask));
}
@@ -1014,7 +1017,7 @@ format_ct_label_masked(struct ds *s, const ovs_u128 *key, const ovs_u128 *mask)
{
if (!ovs_u128_is_zero(mask)) {
ovs_be128 value = hton128(*key);
- ds_put_format(s, "ct_label=");
+ ds_put_format(s, "%sct_label=%s", colors.param, colors.end);
ds_put_hex(s, &value, sizeof value);
if (!is_all_ones(mask, sizeof(*mask))) {
value = hton128(*mask);
@@ -1034,6 +1037,7 @@ match_format(const struct match *match, struct ds *s, int priority)
size_t start_len = s->length;
const struct flow *f = &match->flow;
bool skip_type = false;
+
bool skip_proto = false;
int i;
@@ -1041,7 +1045,8 @@ match_format(const struct match *match, struct ds *s, int priority)
BUILD_ASSERT_DECL(FLOW_WC_SEQ == 35);
if (priority != OFP_DEFAULT_PRIORITY) {
- ds_put_format(s, "priority=%d,", priority);
+ ds_put_format(s, "%spriority=%s%d,",
+ colors.special, colors.end, priority);
}
format_uint32_masked(s, "pkt_mark", f->pkt_mark, wc->masks.pkt_mark);
@@ -1057,22 +1062,24 @@ match_format(const struct match *match, struct ds *s, int priority)
}
if (wc->masks.conj_id) {
- ds_put_format(s, "conj_id=%"PRIu32",", f->conj_id);
+ ds_put_format(s, "%sconj_id%s=%"PRIu32",",
+ colors.param, colors.end, f->conj_id);
}
if (wc->masks.skb_priority) {
- ds_put_format(s, "skb_priority=%#"PRIx32",", f->skb_priority);
+ ds_put_format(s, "%sskb_priority=%s%#"PRIx32",",
+ colors.param, colors.end, f->skb_priority);
}
if (wc->masks.actset_output) {
- ds_put_cstr(s, "actset_output=");
+ ds_put_format(s, "%sactset_output=%s", colors.param, colors.end);
ofputil_format_port(f->actset_output, s);
ds_put_char(s, ',');
}
if (wc->masks.ct_state) {
if (wc->masks.ct_state == UINT16_MAX) {
- ds_put_cstr(s, "ct_state=");
+ ds_put_format(s, "%sct_state=%s", colors.param, colors.end);
if (f->ct_state) {
format_flags(s, ct_state_to_string, f->ct_state, '|');
} else {
@@ -1103,48 +1110,48 @@ match_format(const struct match *match, struct ds *s, int priority)
if (wc->masks.nw_proto) {
skip_proto = true;
if (f->nw_proto == IPPROTO_ICMP) {
- ds_put_cstr(s, "icmp,");
+ ds_put_format(s, "%sicmp%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_IGMP) {
- ds_put_cstr(s, "igmp,");
+ ds_put_format(s, "%sigmp%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_TCP) {
- ds_put_cstr(s, "tcp,");
+ ds_put_format(s, "%stcp%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_UDP) {
- ds_put_cstr(s, "udp,");
+ ds_put_format(s, "%sudp%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_SCTP) {
- ds_put_cstr(s, "sctp,");
+ ds_put_format(s, "%ssctp%s,", colors.value, colors.end);
} else {
- ds_put_cstr(s, "ip,");
+ ds_put_format(s, "%sip%s,", colors.value, colors.end);
skip_proto = false;
}
} else {
- ds_put_cstr(s, "ip,");
+ ds_put_format(s, "%sip%s,", colors.value, colors.end);
}
} else if (f->dl_type == htons(ETH_TYPE_IPV6)) {
if (wc->masks.nw_proto) {
skip_proto = true;
if (f->nw_proto == IPPROTO_ICMPV6) {
- ds_put_cstr(s, "icmp6,");
+ ds_put_format(s, "%sicmp6%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_TCP) {
- ds_put_cstr(s, "tcp6,");
+ ds_put_format(s, "%stcp6%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_UDP) {
- ds_put_cstr(s, "udp6,");
+ ds_put_format(s, "%sudp6%s,", colors.value, colors.end);
} else if (f->nw_proto == IPPROTO_SCTP) {
- ds_put_cstr(s, "sctp6,");
+ ds_put_format(s, "%ssctp6%s,", colors.value, colors.end);
} else {
- ds_put_cstr(s, "ipv6,");
+ ds_put_format(s, "%sipv6%s,", colors.value, colors.end);
skip_proto = false;
}
} else {
- ds_put_cstr(s, "ipv6,");
+ ds_put_format(s, "%sipv6%s,", colors.value, colors.end);
}
} else if (f->dl_type == htons(ETH_TYPE_ARP)) {
- ds_put_cstr(s, "arp,");
+ ds_put_format(s, "%sarp%s,", colors.value, colors.end);
} else if (f->dl_type == htons(ETH_TYPE_RARP)) {
- ds_put_cstr(s, "rarp,");
+ ds_put_format(s, "%srarp%s,", colors.value, colors.end);
} else if (f->dl_type == htons(ETH_TYPE_MPLS)) {
- ds_put_cstr(s, "mpls,");
+ ds_put_format(s, "%smpls%s,", colors.value, colors.end);
} else if (f->dl_type == htons(ETH_TYPE_MPLS_MCAST)) {
- ds_put_cstr(s, "mplsm,");
+ ds_put_format(s, "%smplsm%s,", colors.value, colors.end);
} else {
skip_type = false;
}
@@ -1163,7 +1170,7 @@ match_format(const struct match *match, struct ds *s, int priority)
format_be64_masked(s, "metadata", f->metadata, wc->masks.metadata);
if (wc->masks.in_port.ofp_port) {
- ds_put_cstr(s, "in_port=");
+ ds_put_format(s, "%sin_port=%s", colors.param, colors.end);
ofputil_format_port(f->in_port.ofp_port, s);
ds_put_char(s, ',');
}
@@ -1177,35 +1184,39 @@ match_format(const struct match *match, struct ds *s, int priority)
&& (!pcp_mask || pcp_mask == htons(VLAN_PCP_MASK))
&& (vid_mask || pcp_mask)) {
if (vid_mask) {
- ds_put_format(s, "dl_vlan=%"PRIu16",",
- vlan_tci_to_vid(f->vlan_tci));
+ ds_put_format(s, "%sdl_vlan=%s%"PRIu16",", colors.param,
+ colors.end, vlan_tci_to_vid(f->vlan_tci));
}
if (pcp_mask) {
- ds_put_format(s, "dl_vlan_pcp=%d,",
- vlan_tci_to_pcp(f->vlan_tci));
+ ds_put_format(s, "%sdl_vlan_pcp=%s%d,", colors.param,
+ colors.end, vlan_tci_to_pcp(f->vlan_tci));
}
} else if (wc->masks.vlan_tci == htons(0xffff)) {
- ds_put_format(s, "vlan_tci=0x%04"PRIx16",", ntohs(f->vlan_tci));
+ ds_put_format(s, "%svlan_tci=%s0x%04"PRIx16",", colors.param,
+ colors.end, ntohs(f->vlan_tci));
} else {
- ds_put_format(s, "vlan_tci=0x%04"PRIx16"/0x%04"PRIx16",",
+ ds_put_format(s, "%svlan_tci=%s0x%04"PRIx16"/0x%04"PRIx16",",
+ colors.param, colors.end,
ntohs(f->vlan_tci), ntohs(wc->masks.vlan_tci));
}
}
format_eth_masked(s, "dl_src", f->dl_src, wc->masks.dl_src);
format_eth_masked(s, "dl_dst", f->dl_dst, wc->masks.dl_dst);
if (!skip_type && wc->masks.dl_type) {
- ds_put_format(s, "dl_type=0x%04"PRIx16",", ntohs(f->dl_type));
+ ds_put_format(s, "%sdl_type=%s0x%04"PRIx16",",
+ colors.param, colors.end, ntohs(f->dl_type));
}
if (f->dl_type == htons(ETH_TYPE_IPV6)) {
format_ipv6_netmask(s, "ipv6_src", &f->ipv6_src, &wc->masks.ipv6_src);
format_ipv6_netmask(s, "ipv6_dst", &f->ipv6_dst, &wc->masks.ipv6_dst);
if (wc->masks.ipv6_label) {
if (wc->masks.ipv6_label == OVS_BE32_MAX) {
- ds_put_format(s, "ipv6_label=0x%05"PRIx32",",
+ ds_put_format(s, "%sipv6_label=%s0x%05"PRIx32",",
+ colors.param, colors.end,
ntohl(f->ipv6_label));
} else {
- ds_put_format(s, "ipv6_label=0x%05"PRIx32"/0x%05"PRIx32",",
- ntohl(f->ipv6_label),
+ ds_put_format(s, "%sipv6_label=%s0x%05"PRIx32"/0x%05"PRIx32",",
+ colors.param, colors.end, ntohl(f->ipv6_label),
ntohl(wc->masks.ipv6_label));
}
}
@@ -1220,9 +1231,11 @@ match_format(const struct match *match, struct ds *s, int priority)
if (!skip_proto && wc->masks.nw_proto) {
if (f->dl_type == htons(ETH_TYPE_ARP) ||
f->dl_type == htons(ETH_TYPE_RARP)) {
- ds_put_format(s, "arp_op=%"PRIu8",", f->nw_proto);
+ ds_put_format(s, "%sarp_op=%s%"PRIu8",",
+ colors.param, colors.end, f->nw_proto);
} else {
- ds_put_format(s, "nw_proto=%"PRIu8",", f->nw_proto);
+ ds_put_format(s, "%snw_proto=%s%"PRIu8",",
+ colors.param, colors.end, f->nw_proto);
}
}
if (f->dl_type == htons(ETH_TYPE_ARP) ||
@@ -1231,28 +1244,31 @@ match_format(const struct match *match, struct ds *s, int priority)
format_eth_masked(s, "arp_tha", f->arp_tha, wc->masks.arp_tha);
}
if (wc->masks.nw_tos & IP_DSCP_MASK) {
- ds_put_format(s, "nw_tos=%"PRIu8",", f->nw_tos & IP_DSCP_MASK);
+ ds_put_format(s, "%snw_tos=%s%"PRIu8",",
+ colors.param, colors.end, f->nw_tos & IP_DSCP_MASK);
}
if (wc->masks.nw_tos & IP_ECN_MASK) {
- ds_put_format(s, "nw_ecn=%"PRIu8",", f->nw_tos & IP_ECN_MASK);
+ ds_put_format(s, "%snw_ecn=%s%"PRIu8",",
+ colors.param, colors.end, f->nw_tos & IP_ECN_MASK);
}
if (wc->masks.nw_ttl) {
- ds_put_format(s, "nw_ttl=%"PRIu8",", f->nw_ttl);
+ ds_put_format(s, "%snw_ttl=%s%"PRIu8",",
+ colors.param, colors.end, f->nw_ttl);
}
if (wc->masks.mpls_lse[0] & htonl(MPLS_LABEL_MASK)) {
- ds_put_format(s, "mpls_label=%"PRIu32",",
- mpls_lse_to_label(f->mpls_lse[0]));
+ ds_put_format(s, "%smpls_label=%s%"PRIu32",", colors.param,
+ colors.end, mpls_lse_to_label(f->mpls_lse[0]));
}
if (wc->masks.mpls_lse[0] & htonl(MPLS_TC_MASK)) {
- ds_put_format(s, "mpls_tc=%"PRIu8",",
+ ds_put_format(s, "%smpls_tc=%s%"PRIu8",", colors.param, colors.end,
mpls_lse_to_tc(f->mpls_lse[0]));
}
if (wc->masks.mpls_lse[0] & htonl(MPLS_TTL_MASK)) {
- ds_put_format(s, "mpls_ttl=%"PRIu8",",
+ ds_put_format(s, "%smpls_ttl=%s%"PRIu8",", colors.param, colors.end,
mpls_lse_to_ttl(f->mpls_lse[0]));
}
if (wc->masks.mpls_lse[0] & htonl(MPLS_BOS_MASK)) {
- ds_put_format(s, "mpls_bos=%"PRIu8",",
+ ds_put_format(s, "%smpls_bos=%s%"PRIu8",", colors.param, colors.end,
mpls_lse_to_bos(f->mpls_lse[0]));
}
format_be32_masked(s, "mpls_lse1", f->mpls_lse[1], wc->masks.mpls_lse[1]);
@@ -1260,19 +1276,19 @@ match_format(const struct match *match, struct ds *s, int priority)
switch (wc->masks.nw_frag) {
case FLOW_NW_FRAG_ANY | FLOW_NW_FRAG_LATER:
- ds_put_format(s, "nw_frag=%s,",
+ ds_put_format(s, "%snw_frag=%s%s,", colors.param, colors.end,
f->nw_frag & FLOW_NW_FRAG_ANY
? (f->nw_frag & FLOW_NW_FRAG_LATER ? "later" : "first")
: (f->nw_frag & FLOW_NW_FRAG_LATER ? "<error>" : "no"));
break;
case FLOW_NW_FRAG_ANY:
- ds_put_format(s, "nw_frag=%s,",
+ ds_put_format(s, "%snw_frag=%s%s,", colors.param, colors.end,
f->nw_frag & FLOW_NW_FRAG_ANY ? "yes" : "no");
break;
case FLOW_NW_FRAG_LATER:
- ds_put_format(s, "nw_frag=%s,",
+ ds_put_format(s, "%snw_frag=%s%s,", colors.param, colors.end,
f->nw_frag & FLOW_NW_FRAG_LATER ? "later" : "not_later");
break;
}
--
1.9.1
More information about the dev
mailing list