projects / cascardo / ovs.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
meta-flow: Correctly byteswap skb_priority/skb_mark for mf_value.
[cascardo/ovs.git] / lib / meta-flow.c
diff --git a/lib/meta-flow.c b/lib/meta-flow.c
index 1dabf60..314ffc6 100644 (file)
--- a/lib/meta-flow.c
+++ b/lib/meta-flow.c
@@ -118,6 +118,24 @@ static const struct mf_field mf_fields[MFF_N_IDS] = {
         false,
         NXM_OF_IN_PORT, "NXM_OF_IN_PORT",
         OXM_OF_IN_PORT, "OXM_OF_IN_PORT",
+    }, {
+        MFF_SKB_PRIORITY, "skb_priority", NULL,
+        MF_FIELD_SIZES(be32),
+        MFM_NONE,
+        MFS_HEXADECIMAL,
+        MFP_NONE,
+        false,
+        0, NULL,
+        0, NULL,
+    }, {
+        MFF_SKB_MARK, "skb_mark", NULL,
+        MF_FIELD_SIZES(be32),
+        MFM_NONE,
+        MFS_HEXADECIMAL,
+        MFP_NONE,
+        false,
+        0, NULL,
+        0, NULL,
     },
 
 #define REGISTER(IDX)                           \
@@ -629,6 +647,10 @@ mf_is_all_wild(const struct mf_field *mf, const struct flow_wildcards *wc)
         return !wc->masks.metadata;
     case MFF_IN_PORT:
         return !wc->masks.in_port;
+    case MFF_SKB_PRIORITY:
+        return !wc->masks.skb_priority;
+    case MFF_SKB_MARK:
+        return !wc->masks.skb_mark;
     CASE_MFF_REGS:
         return !wc->masks.regs[mf->id - MFF_REG0];
 
@@ -719,127 +741,7 @@ void
 mf_get_mask(const struct mf_field *mf, const struct flow_wildcards *wc,
             union mf_value *mask)
 {
-    switch (mf->id) {
-    case MFF_TUN_ID:
-    case MFF_TUN_SRC:
-    case MFF_TUN_DST:
-    case MFF_TUN_TOS:
-    case MFF_TUN_TTL:
-    case MFF_TUN_FLAGS:
-        mask->be64 = wc->masks.tunnel.tun_id;
-        break;
-    case MFF_METADATA:
-        mask->be64 = wc->masks.metadata;
-        break;
-    case MFF_IN_PORT:
-        mask->be16 = htons(wc->masks.in_port);
-        break;
-    CASE_MFF_REGS:
-        mask->be32 = htonl(wc->masks.regs[mf->id - MFF_REG0]);
-        break;
-
-    case MFF_ETH_DST:
-        memcpy(mask->mac, wc->masks.dl_dst, ETH_ADDR_LEN);
-        break;
-    case MFF_ETH_SRC:
-        memcpy(mask->mac, wc->masks.dl_src, ETH_ADDR_LEN);
-        break;
-    case MFF_ETH_TYPE:
-        mask->be16 = wc->masks.dl_type;
-        break;
-
-    case MFF_VLAN_TCI:
-        mask->be16 = wc->masks.vlan_tci;
-        break;
-    case MFF_DL_VLAN:
-        mask->be16 = wc->masks.vlan_tci & htons(VLAN_VID_MASK);
-        break;
-    case MFF_VLAN_VID:
-        mask->be16 = wc->masks.vlan_tci & htons(VLAN_VID_MASK | VLAN_CFI);
-        break;
-    case MFF_DL_VLAN_PCP:
-    case MFF_VLAN_PCP:
-        mask->u8 = vlan_tci_to_pcp(wc->masks.vlan_tci);
-        break;
-
-    case MFF_IPV4_SRC:
-        mask->be32 = wc->masks.nw_src;
-        break;
-    case MFF_IPV4_DST:
-        mask->be32 = wc->masks.nw_dst;
-        break;
-
-    case MFF_IPV6_SRC:
-        mask->ipv6 = wc->masks.ipv6_src;
-        break;
-    case MFF_IPV6_DST:
-        mask->ipv6 = wc->masks.ipv6_dst;
-        break;
-    case MFF_IPV6_LABEL:
-        mask->be32 = wc->masks.ipv6_label;
-        break;
-
-    case MFF_IP_PROTO:
-        mask->u8 = wc->masks.nw_proto;
-        break;
-    case MFF_IP_DSCP:
-        mask->u8 = wc->masks.nw_tos & IP_DSCP_MASK;
-        break;
-    case MFF_IP_ECN:
-        mask->u8 = wc->masks.nw_tos & IP_ECN_MASK;
-        break;
-
-    case MFF_ND_TARGET:
-        mask->ipv6 = wc->masks.nd_target;
-        break;
-
-    case MFF_IP_TTL:
-        mask->u8 = wc->masks.nw_ttl;
-        break;
-    case MFF_IP_FRAG:
-        mask->u8 = wc->masks.nw_frag & FLOW_NW_FRAG_MASK;
-        break;
-
-    case MFF_ARP_OP:
-        mask->u8 = wc->masks.nw_proto;
-        break;
-    case MFF_ARP_SPA:
-        mask->be32 = wc->masks.nw_src;
-        break;
-    case MFF_ARP_TPA:
-        mask->be32 = wc->masks.nw_dst;
-        break;
-    case MFF_ARP_SHA:
-    case MFF_ND_SLL:
-        memcpy(mask->mac, wc->masks.arp_sha, ETH_ADDR_LEN);
-        break;
-    case MFF_ARP_THA:
-    case MFF_ND_TLL:
-        memcpy(mask->mac, wc->masks.arp_tha, ETH_ADDR_LEN);
-        break;
-
-    case MFF_TCP_SRC:
-    case MFF_UDP_SRC:
-        mask->be16 = wc->masks.tp_src;
-        break;
-    case MFF_TCP_DST:
-    case MFF_UDP_DST:
-        mask->be16 = wc->masks.tp_dst;
-        break;
-
-    case MFF_ICMPV4_TYPE:
-    case MFF_ICMPV6_TYPE:
-        mask->u8 = ntohs(wc->masks.tp_src);
-        break;
-    case MFF_ICMPV4_CODE:
-    case MFF_ICMPV6_CODE:
-        mask->u8 = ntohs(wc->masks.tp_dst);
-        break;
-
-    case MFF_N_IDS:
-    default:
-        NOT_REACHED();
-    }
+    mf_get_value(mf, &wc->masks, mask);
 }
 
 /* Tests whether 'mask' is a valid wildcard bit pattern for 'mf'.  Returns true
@@ -949,6 +851,8 @@ mf_is_value_valid(const struct mf_field *mf, const union mf_value *value)
     case MFF_TUN_FLAGS:
     case MFF_METADATA:
     case MFF_IN_PORT:
+    case MFF_SKB_PRIORITY:
+    case MFF_SKB_MARK:
     CASE_MFF_REGS:
     case MFF_ETH_SRC:
     case MFF_ETH_DST:
@@ -1039,6 +943,14 @@ mf_get_value(const struct mf_field *mf, const struct flow *flow,
         value->be16 = htons(flow->in_port);
         break;
 
+    case MFF_SKB_PRIORITY:
+        value->be32 = htonl(flow->skb_priority);
+        break;
+
+    case MFF_SKB_MARK:
+        value->be32 = htonl(flow->skb_mark);
+        break;
+
     CASE_MFF_REGS:
         value->be32 = htonl(flow->regs[mf->id - MFF_REG0]);
         break;
@@ -1198,6 +1110,14 @@ mf_set_value(const struct mf_field *mf,
         match_set_in_port(match, ntohs(value->be16));
         break;
 
+    case MFF_SKB_PRIORITY:
+        match_set_skb_priority(match, ntohl(value->be32));
+        break;
+
+    case MFF_SKB_MARK:
+        match_set_skb_mark(match, ntohl(value->be32));
+        break;
+
     CASE_MFF_REGS:
         match_set_reg(match, mf->id - MFF_REG0, ntohl(value->be32));
         break;
@@ -1357,6 +1277,14 @@ mf_set_flow_value(const struct mf_field *mf,
         flow->in_port = ntohs(value->be16);
         break;
 
+    case MFF_SKB_PRIORITY:
+        flow->skb_priority = ntohl(value->be32);
+        break;
+
+    case MFF_SKB_MARK:
+        flow->skb_mark = ntohl(value->be32);
+        break;
+
     CASE_MFF_REGS:
         flow->regs[mf->id - MFF_REG0] = ntohl(value->be32);
         break;
@@ -1531,6 +1459,16 @@ mf_set_wild(const struct mf_field *mf, struct match *match)
         match->wc.masks.in_port = 0;
         break;
 
+    case MFF_SKB_PRIORITY:
+        match->flow.skb_priority = 0;
+        match->wc.masks.skb_priority = 0;
+        break;
+
+    case MFF_SKB_MARK:
+        match->flow.skb_mark = 0;
+        match->wc.masks.skb_mark = 0;
+        break;
+
     CASE_MFF_REGS:
         match_set_reg_masked(match, mf->id - MFF_REG0, 0, 0);
         break;
@@ -1685,6 +1623,8 @@ mf_set(const struct mf_field *mf,
 
     switch (mf->id) {
     case MFF_IN_PORT:
+    case MFF_SKB_MARK:
+    case MFF_SKB_PRIORITY:
     case MFF_ETH_TYPE:
     case MFF_DL_VLAN:
     case MFF_DL_VLAN_PCP:
@@ -1884,6 +1824,8 @@ mf_random_value(const struct mf_field *mf, union mf_value *value)
     case MFF_TUN_FLAGS:
     case MFF_METADATA:
     case MFF_IN_PORT:
+    case MFF_SKB_MARK:
+    case MFF_SKB_PRIORITY:
     CASE_MFF_REGS:
     case MFF_ETH_SRC:
     case MFF_ETH_DST:
Unnamed repository; edit this file 'description' to name the repository.