From: Ben Pfaff Date: Tue, 7 Aug 2012 20:43:18 +0000 (-0700) Subject: flow: Simplify many functions for working with flows and wildcards. X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=659c23467978f40200686695c48b09582f2c534b;p=openvswitch flow: Simplify many functions for working with flows and wildcards. Now that "struct flow" and "struct flow_wildcards" have the same simple and uniform structure, it's easy to handle common operations by just iterating over the bits inside them. Signed-off-by: Ben Pfaff --- diff --git a/lib/classifier.c b/lib/classifier.c index fab856b7..2fd33e5a 100644 --- a/lib/classifier.c +++ b/lib/classifier.c @@ -40,9 +40,6 @@ static struct cls_rule *find_equal(struct cls_table *, const struct flow *, uint32_t hash); static struct cls_rule *insert_rule(struct cls_table *, struct cls_rule *); -static bool flow_equal_except(const struct flow *, const struct flow *, - const struct flow_wildcards *); - /* Iterates RULE over HEAD and all of the cls_rules on HEAD->list. */ #define FOR_EACH_RULE_IN_LIST(RULE, HEAD) \ for ((RULE) = (HEAD); (RULE) != NULL; (RULE) = next_rule_in_list(RULE)) @@ -1258,71 +1255,3 @@ next_rule_in_list(struct cls_rule *rule) struct cls_rule *next = next_rule_in_list__(rule); return next->priority < rule->priority ? next : NULL; } - -static bool -ipv6_equal_except(const struct in6_addr *a, const struct in6_addr *b, - const struct in6_addr *mask) -{ - int i; - -#ifdef s6_addr32 - for (i=0; i<4; i++) { - if ((a->s6_addr32[i] ^ b->s6_addr32[i]) & mask->s6_addr32[i]) { - return false; - } - } -#else - for (i=0; i<16; i++) { - if ((a->s6_addr[i] ^ b->s6_addr[i]) & mask->s6_addr[i]) { - return false; - } - } -#endif - - return true; -} - - -static bool -flow_equal_except(const struct flow *a, const struct flow *b, - const struct flow_wildcards *wildcards) -{ - int i; - - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - for (i = 0; i < FLOW_N_REGS; i++) { - if ((a->regs[i] ^ b->regs[i]) & wildcards->masks.regs[i]) { - return false; - } - } - - return (!((a->tun_id ^ b->tun_id) & wildcards->masks.tun_id) - && !((a->metadata ^ b->metadata) & wildcards->masks.metadata) - && !((a->nw_src ^ b->nw_src) & wildcards->masks.nw_src) - && !((a->nw_dst ^ b->nw_dst) & wildcards->masks.nw_dst) - && !((a->in_port ^ b->in_port) & wildcards->masks.in_port) - && !((a->vlan_tci ^ b->vlan_tci) & wildcards->masks.vlan_tci) - && !((a->dl_type ^ b->dl_type) & wildcards->masks.dl_type) - && !((a->tp_src ^ b->tp_src) & wildcards->masks.tp_src) - && !((a->tp_dst ^ b->tp_dst) & wildcards->masks.tp_dst) - && eth_addr_equal_except(a->dl_src, b->dl_src, - wildcards->masks.dl_src) - && eth_addr_equal_except(a->dl_dst, b->dl_dst, - wildcards->masks.dl_dst) - && !((a->nw_proto ^ b->nw_proto) & wildcards->masks.nw_proto) - && !((a->nw_ttl ^ b->nw_ttl) & wildcards->masks.nw_ttl) - && !((a->nw_tos ^ b->nw_tos) & wildcards->masks.nw_tos) - && !((a->nw_frag ^ b->nw_frag) & wildcards->masks.nw_frag) - && eth_addr_equal_except(a->arp_sha, b->arp_sha, - wildcards->masks.arp_sha) - && eth_addr_equal_except(a->arp_tha, b->arp_tha, - wildcards->masks.arp_tha) - && !((a->ipv6_label ^ b->ipv6_label) & wildcards->masks.ipv6_label) - && ipv6_equal_except(&a->ipv6_src, &b->ipv6_src, - &wildcards->masks.ipv6_src) - && ipv6_equal_except(&a->ipv6_dst, &b->ipv6_dst, - &wildcards->masks.ipv6_dst) - && ipv6_equal_except(&a->nd_target, &b->nd_target, - &wildcards->masks.nd_target)); -} diff --git a/lib/flow.c b/lib/flow.c index 5dcc08b1..d7765676 100644 --- a/lib/flow.c +++ b/lib/flow.c @@ -442,38 +442,13 @@ flow_extract(struct ofpbuf *packet, uint32_t skb_priority, ovs_be64 tun_id, void flow_zero_wildcards(struct flow *flow, const struct flow_wildcards *wildcards) { - int i; - - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); + uint32_t *flow_u32 = (uint32_t *) flow; + const uint32_t *wc_u32 = (const uint32_t *) &wildcards->masks; + size_t i; - for (i = 0; i < FLOW_N_REGS; i++) { - flow->regs[i] &= wildcards->masks.regs[i]; + for (i = 0; i < FLOW_U32S; i++) { + flow_u32[i] &= wc_u32[i]; } - flow->tun_id &= wildcards->masks.tun_id; - flow->metadata &= wildcards->masks.metadata; - flow->nw_src &= wildcards->masks.nw_src; - flow->nw_dst &= wildcards->masks.nw_dst; - flow->in_port &= wildcards->masks.in_port; - flow->vlan_tci &= wildcards->masks.vlan_tci; - flow->dl_type &= wildcards->masks.dl_type; - flow->tp_src &= wildcards->masks.tp_src; - flow->tp_dst &= wildcards->masks.tp_dst; - eth_addr_bitand(flow->dl_src, wildcards->masks.dl_src, flow->dl_src); - eth_addr_bitand(flow->dl_dst, wildcards->masks.dl_dst, flow->dl_dst); - flow->ipv6_label &= wildcards->masks.ipv6_label; - flow->nw_proto &= wildcards->masks.nw_proto; - flow->nw_tos &= wildcards->masks.nw_tos; - flow->nw_ttl &= wildcards->masks.nw_ttl; - flow->nw_frag &= wildcards->masks.nw_frag; - eth_addr_bitand(flow->arp_sha, wildcards->masks.arp_sha, flow->arp_sha); - eth_addr_bitand(flow->arp_tha, wildcards->masks.arp_tha, flow->arp_tha); - flow->ipv6_src = ipv6_addr_bitand(&flow->ipv6_src, - &wildcards->masks.ipv6_src); - flow->ipv6_dst = ipv6_addr_bitand(&flow->ipv6_dst, - &wildcards->masks.ipv6_dst); - flow->nd_target = ipv6_addr_bitand(&flow->nd_target, - &wildcards->masks.nd_target); - flow->skb_priority = 0; } /* Initializes 'fmd' with the metadata found in 'flow'. */ @@ -568,31 +543,7 @@ flow_print(FILE *stream, const struct flow *flow) void flow_wildcards_init_catchall(struct flow_wildcards *wc) { - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - wc->masks.tun_id = htonll(0); - wc->masks.nw_src = htonl(0); - wc->masks.nw_dst = htonl(0); - wc->masks.ipv6_src = in6addr_any; - wc->masks.ipv6_dst = in6addr_any; - wc->masks.ipv6_label = htonl(0); - wc->masks.nd_target = in6addr_any; - memset(wc->masks.regs, 0, sizeof wc->masks.regs); - wc->masks.metadata = htonll(0); - wc->masks.in_port = 0; - wc->masks.vlan_tci = htons(0); - wc->masks.nw_frag = 0; - wc->masks.dl_type = htons(0); - wc->masks.tp_src = htons(0); - wc->masks.tp_dst = htons(0); - memset(wc->masks.dl_src, 0, ETH_ADDR_LEN); - memset(wc->masks.dl_dst, 0, ETH_ADDR_LEN); - memset(wc->masks.arp_sha, 0, ETH_ADDR_LEN); - memset(wc->masks.arp_tha, 0, ETH_ADDR_LEN); - wc->masks.nw_proto = 0; - wc->masks.nw_tos = 0; - wc->masks.nw_ttl = 0; - memset(wc->masks.zeros, 0, sizeof wc->masks.zeros); + memset(&wc->masks, 0, sizeof wc->masks); } /* Initializes 'wc' as an exact-match set of wildcards; that is, 'wc' does not @@ -600,30 +551,7 @@ flow_wildcards_init_catchall(struct flow_wildcards *wc) void flow_wildcards_init_exact(struct flow_wildcards *wc) { - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - wc->masks.tun_id = htonll(UINT64_MAX); - wc->masks.nw_src = htonl(UINT32_MAX); - wc->masks.nw_dst = htonl(UINT32_MAX); - wc->masks.ipv6_src = in6addr_exact; - wc->masks.ipv6_dst = in6addr_exact; - wc->masks.ipv6_label = htonl(UINT32_MAX); - wc->masks.nd_target = in6addr_exact; - memset(wc->masks.regs, 0xff, sizeof wc->masks.regs); - wc->masks.metadata = htonll(UINT64_MAX); - wc->masks.in_port = UINT16_MAX; - wc->masks.vlan_tci = htons(UINT16_MAX); - wc->masks.nw_frag = UINT8_MAX; - wc->masks.dl_type = htons(UINT16_MAX); - wc->masks.tp_src = htons(UINT16_MAX); - wc->masks.tp_dst = htons(UINT16_MAX); - memset(wc->masks.dl_src, 0xff, ETH_ADDR_LEN); - memset(wc->masks.dl_dst, 0xff, ETH_ADDR_LEN); - memset(wc->masks.arp_sha, 0xff, ETH_ADDR_LEN); - memset(wc->masks.arp_tha, 0xff, ETH_ADDR_LEN); - wc->masks.nw_proto = UINT8_MAX; - wc->masks.nw_tos = UINT8_MAX; - wc->masks.nw_ttl = UINT8_MAX; + memset(&wc->masks, 0xff, sizeof wc->masks); memset(wc->masks.zeros, 0, sizeof wc->masks.zeros); } @@ -632,40 +560,14 @@ flow_wildcards_init_exact(struct flow_wildcards *wc) bool flow_wildcards_is_catchall(const struct flow_wildcards *wc) { - int i; - - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - if (wc->masks.tun_id != htonll(0) - || wc->masks.nw_src != htonl(0) - || wc->masks.nw_dst != htonl(0) - || wc->masks.tp_src != htons(0) - || wc->masks.tp_dst != htons(0) - || wc->masks.in_port != 0 - || wc->masks.vlan_tci != htons(0) - || wc->masks.metadata != htonll(0) - || wc->masks.dl_type != htons(0) - || !eth_addr_is_zero(wc->masks.dl_src) - || !eth_addr_is_zero(wc->masks.dl_dst) - || !eth_addr_is_zero(wc->masks.arp_sha) - || !eth_addr_is_zero(wc->masks.arp_tha) - || !ipv6_mask_is_any(&wc->masks.ipv6_src) - || !ipv6_mask_is_any(&wc->masks.ipv6_dst) - || wc->masks.ipv6_label != htonl(0) - || !ipv6_mask_is_any(&wc->masks.nd_target) - || wc->masks.nw_proto != 0 - || wc->masks.nw_frag != 0 - || wc->masks.nw_tos != 0 - || wc->masks.nw_ttl != 0) { - return false; - } + const uint32_t *wc_u32 = (const uint32_t *) &wc->masks; + size_t i; - for (i = 0; i < FLOW_N_REGS; i++) { - if (wc->masks.regs[i] != 0) { + for (i = 0; i < FLOW_U32S; i++) { + if (wc_u32[i]) { return false; } } - return true; } @@ -677,46 +579,21 @@ flow_wildcards_combine(struct flow_wildcards *dst, const struct flow_wildcards *src1, const struct flow_wildcards *src2) { - int i; + uint32_t *dst_u32 = (uint32_t *) &dst->masks; + const uint32_t *src1_u32 = (const uint32_t *) &src1->masks; + const uint32_t *src2_u32 = (const uint32_t *) &src2->masks; + size_t i; - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - dst->masks.tun_id = src1->masks.tun_id & src2->masks.tun_id; - dst->masks.nw_src = src1->masks.nw_src & src2->masks.nw_src; - dst->masks.nw_dst = src1->masks.nw_dst & src2->masks.nw_dst; - dst->masks.ipv6_src = ipv6_addr_bitand(&src1->masks.ipv6_src, - &src2->masks.ipv6_src); - dst->masks.ipv6_dst = ipv6_addr_bitand(&src1->masks.ipv6_dst, - &src2->masks.ipv6_dst); - dst->masks.ipv6_label = src1->masks.ipv6_label & src2->masks.ipv6_label; - dst->masks.nd_target = ipv6_addr_bitand(&src1->masks.nd_target, - &src2->masks.nd_target); - for (i = 0; i < FLOW_N_REGS; i++) { - dst->masks.regs[i] = src1->masks.regs[i] & src2->masks.regs[i]; + for (i = 0; i < FLOW_U32S; i++) { + dst_u32[i] = src1_u32[i] & src2_u32[i]; } - dst->masks.metadata = src1->masks.metadata & src2->masks.metadata; - dst->masks.in_port = src1->masks.in_port & src2->masks.in_port; - dst->masks.vlan_tci = src1->masks.vlan_tci & src2->masks.vlan_tci; - dst->masks.dl_type = src1->masks.dl_type & src2->masks.dl_type; - dst->masks.tp_src = src1->masks.tp_src & src2->masks.tp_src; - dst->masks.tp_dst = src1->masks.tp_dst & src2->masks.tp_dst; - dst->masks.nw_frag = src1->masks.nw_frag & src2->masks.nw_frag; - eth_addr_bitand(src1->masks.dl_src, src2->masks.dl_src, dst->masks.dl_src); - eth_addr_bitand(src1->masks.dl_dst, src2->masks.dl_dst, dst->masks.dl_dst); - eth_addr_bitand(src1->masks.arp_sha, src2->masks.arp_sha, - dst->masks.arp_sha); - eth_addr_bitand(src1->masks.arp_tha, src2->masks.arp_tha, - dst->masks.arp_tha); - dst->masks.nw_proto = src1->masks.nw_proto & src2->masks.nw_proto; - dst->masks.nw_tos = src1->masks.nw_tos & src2->masks.nw_tos; - dst->masks.nw_ttl = src1->masks.nw_ttl & src2->masks.nw_ttl; } /* Returns a hash of the wildcards in 'wc'. */ uint32_t flow_wildcards_hash(const struct flow_wildcards *wc, uint32_t basis) { - return hash_words((const uint32_t *) wc, sizeof *wc / 4, basis); + return flow_hash(&wc->masks, basis);; } /* Returns true if 'a' and 'b' represent the same wildcards, false if they are @@ -725,41 +602,7 @@ bool flow_wildcards_equal(const struct flow_wildcards *a, const struct flow_wildcards *b) { - int i; - - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); - - if (a->masks.tun_id != b->masks.tun_id - || a->masks.nw_src != b->masks.nw_src - || a->masks.nw_dst != b->masks.nw_dst - || a->masks.in_port != b->masks.in_port - || a->masks.vlan_tci != b->masks.vlan_tci - || a->masks.metadata != b->masks.metadata - || a->masks.dl_type != b->masks.dl_type - || !ipv6_addr_equals(&a->masks.ipv6_src, &b->masks.ipv6_src) - || !ipv6_addr_equals(&a->masks.ipv6_dst, &b->masks.ipv6_dst) - || a->masks.ipv6_label != b->masks.ipv6_label - || !ipv6_addr_equals(&a->masks.nd_target, &b->masks.nd_target) - || a->masks.tp_src != b->masks.tp_src - || a->masks.tp_dst != b->masks.tp_dst - || a->masks.nw_frag != b->masks.nw_frag - || !eth_addr_equals(a->masks.dl_src, b->masks.dl_src) - || !eth_addr_equals(a->masks.dl_dst, b->masks.dl_dst) - || !eth_addr_equals(a->masks.arp_sha, b->masks.arp_sha) - || !eth_addr_equals(a->masks.arp_tha, b->masks.arp_tha) - || a->masks.nw_proto != b->masks.nw_proto - || a->masks.nw_tos != b->masks.nw_tos - || a->masks.nw_ttl != b->masks.nw_ttl) { - return false; - } - - for (i = 0; i < FLOW_N_REGS; i++) { - if (a->masks.regs[i] != b->masks.regs[i]) { - return false; - } - } - - return true; + return flow_equal(&a->masks, &b->masks); } /* Returns true if at least one bit or field is wildcarded in 'a' but not in @@ -768,69 +611,35 @@ bool flow_wildcards_has_extra(const struct flow_wildcards *a, const struct flow_wildcards *b) { - int i; - uint8_t eth_masked[ETH_ADDR_LEN]; - struct in6_addr ipv6_masked; - - BUILD_ASSERT_DECL(FLOW_WC_SEQ == 17); + const uint32_t *a_u32 = (const uint32_t *) &a->masks; + const uint32_t *b_u32 = (const uint32_t *) &b->masks; + size_t i; - for (i = 0; i < FLOW_N_REGS; i++) { - if ((a->masks.regs[i] & b->masks.regs[i]) != b->masks.regs[i]) { + for (i = 0; i < FLOW_U32S; i++) { + if ((a_u32[i] & b_u32[i]) != b_u32[i]) { return true; } } + return false; +} - eth_addr_bitand(a->masks.dl_src, b->masks.dl_src, eth_masked); - if (!eth_addr_equals(eth_masked, b->masks.dl_src)) { - return true; - } - - eth_addr_bitand(a->masks.dl_dst, b->masks.dl_dst, eth_masked); - if (!eth_addr_equals(eth_masked, b->masks.dl_dst)) { - return true; - } - - eth_addr_bitand(a->masks.arp_sha, b->masks.arp_sha, eth_masked); - if (!eth_addr_equals(eth_masked, b->masks.arp_sha)) { - return true; - } - - eth_addr_bitand(a->masks.arp_tha, b->masks.arp_tha, eth_masked); - if (!eth_addr_equals(eth_masked, b->masks.arp_tha)) { - return true; - } - - ipv6_masked = ipv6_addr_bitand(&a->masks.ipv6_src, &b->masks.ipv6_src); - if (!ipv6_addr_equals(&ipv6_masked, &b->masks.ipv6_src)) { - return true; - } - - ipv6_masked = ipv6_addr_bitand(&a->masks.ipv6_dst, &b->masks.ipv6_dst); - if (!ipv6_addr_equals(&ipv6_masked, &b->masks.ipv6_dst)) { - return true; - } +/* Returns true if 'a' and 'b' are equal, except that 0-bits (wildcarded bits) + * in 'wc' do not need to be equal in 'a' and 'b'. */ +bool +flow_equal_except(const struct flow *a, const struct flow *b, + const struct flow_wildcards *wc) +{ + const uint32_t *a_u32 = (const uint32_t *) a; + const uint32_t *b_u32 = (const uint32_t *) b; + const uint32_t *wc_u32 = (const uint32_t *) &wc->masks; + size_t i; - ipv6_masked = ipv6_addr_bitand(&a->masks.nd_target, &b->masks.nd_target); - if (!ipv6_addr_equals(&ipv6_masked, &b->masks.nd_target)) { - return true; + for (i = 0; i < FLOW_U32S; i++) { + if ((a_u32[i] ^ b_u32[i]) & wc_u32[i]) { + return false; + } } - - return ((a->masks.tun_id & b->masks.tun_id) != b->masks.tun_id - || (a->masks.nw_src & b->masks.nw_src) != b->masks.nw_src - || (a->masks.nw_dst & b->masks.nw_dst) != b->masks.nw_dst - || ((a->masks.ipv6_label & b->masks.ipv6_label) - != b->masks.ipv6_label) - || (a->masks.in_port & b->masks.in_port) != b->masks.in_port - || (a->masks.vlan_tci & b->masks.vlan_tci) != b->masks.vlan_tci - || (a->masks.metadata & b->masks.metadata) != b->masks.metadata - || (a->masks.dl_type & b->masks.dl_type) != b->masks.dl_type - || (a->masks.dl_type & b->masks.dl_type) != b->masks.dl_type - || (a->masks.tp_src & b->masks.tp_src) != b->masks.tp_src - || (a->masks.tp_dst & b->masks.tp_dst) != b->masks.tp_dst - || (a->masks.nw_proto & b->masks.nw_proto) != b->masks.nw_proto - || (a->masks.nw_frag & b->masks.nw_frag) != b->masks.nw_frag - || (a->masks.nw_tos & b->masks.nw_tos) != b->masks.nw_tos - || (a->masks.nw_ttl & b->masks.nw_ttl) != b->masks.nw_ttl); + return true; } /* Sets the wildcard mask for register 'idx' in 'wc' to 'mask'. diff --git a/lib/flow.h b/lib/flow.h index 0ed65d2e..ba2b8f6e 100644 --- a/lib/flow.h +++ b/lib/flow.h @@ -79,6 +79,8 @@ struct flow { }; BUILD_ASSERT_DECL(sizeof(struct flow) % 8 == 0); +#define FLOW_U32S (sizeof(struct flow) / 4) + /* Remember to update FLOW_WC_SEQ when changing 'struct flow'. */ BUILD_ASSERT_DECL(sizeof(struct flow) == 152 && FLOW_WC_SEQ == 17); @@ -125,7 +127,7 @@ flow_hash(const struct flow *flow, uint32_t basis) { return hash_words((const uint32_t *) flow, sizeof *flow / 4, basis); } - + /* Wildcards for a flow. * * A 1-bit in each bit in 'masks' indicates that the corresponding bit of @@ -159,4 +161,7 @@ uint32_t flow_hash_fields(const struct flow *, enum nx_hash_fields, const char *flow_hash_fields_to_str(enum nx_hash_fields); bool flow_hash_fields_valid(enum nx_hash_fields); +bool flow_equal_except(const struct flow *a, const struct flow *b, + const struct flow_wildcards *); + #endif /* flow.h */