X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fflow.c;h=ca745187d20780ac3994085b7fda4eaa6b0b7d70;hb=7da6be985c6fc7f6b425f660501133f1118a73b5;hp=e930a6a4c37477516cc41f8566e76fbcf40d4af2;hpb=10a24935c9d382e4d85b05d9616843f3d3bb4983;p=openvswitch diff --git a/lib/flow.c b/lib/flow.c index e930a6a4..ca745187 100644 --- a/lib/flow.c +++ b/lib/flow.c @@ -31,7 +31,7 @@ #include "unaligned.h" #include "vlog.h" -VLOG_DEFINE_THIS_MODULE(flow) +VLOG_DEFINE_THIS_MODULE(flow); static struct arp_eth_header * pull_arp(struct ofpbuf *packet) @@ -81,24 +81,24 @@ static void parse_vlan(struct ofpbuf *b, struct flow *flow) { struct qtag_prefix { - uint16_t eth_type; /* ETH_TYPE_VLAN */ - uint16_t tci; + ovs_be16 eth_type; /* ETH_TYPE_VLAN */ + ovs_be16 tci; }; - if (b->size >= sizeof(struct qtag_prefix) + sizeof(uint16_t)) { + if (b->size >= sizeof(struct qtag_prefix) + sizeof(ovs_be16)) { struct qtag_prefix *qp = ofpbuf_pull(b, sizeof *qp); flow->dl_vlan = qp->tci & htons(VLAN_VID_MASK); - flow->dl_vlan_pcp = (ntohs(qp->tci) & VLAN_PCP_MASK) >> VLAN_PCP_SHIFT; + flow->dl_vlan_pcp = vlan_tci_to_pcp(qp->tci); } } -static uint16_t +static ovs_be16 parse_ethertype(struct ofpbuf *b) { struct llc_snap_header *llc; - uint16_t proto; + ovs_be16 proto; - proto = *(uint16_t *) ofpbuf_pull(b, sizeof proto); + proto = *(ovs_be16 *) ofpbuf_pull(b, sizeof proto); if (ntohs(proto) >= ODP_DL_TYPE_ETH2_CUTOFF) { return proto; } @@ -120,10 +120,8 @@ parse_ethertype(struct ofpbuf *b) return llc->snap.snap_type; } -/* 'tun_id' is in network byte order, while 'in_port' is in host byte order. - * These byte orders are the same as they are in struct odp_flow_key. - * - * Initializes packet header pointers as follows: +/* Initializes 'flow' members from 'packet', 'tun_id', and 'in_port. + * Initializes 'packet' header pointers as follows: * * - packet->l2 to the start of the Ethernet header. * @@ -138,7 +136,7 @@ parse_ethertype(struct ofpbuf *b) * present and has a correct length, and otherwise NULL. */ int -flow_extract(struct ofpbuf *packet, uint32_t tun_id, uint16_t in_port, +flow_extract(struct ofpbuf *packet, ovs_be32 tun_id, uint16_t in_port, struct flow *flow) { struct ofpbuf b = *packet; @@ -281,7 +279,7 @@ flow_to_match(const struct flow *flow, uint32_t wildcards, void flow_from_match(const struct ofp_match *match, bool tun_id_from_cookie, - uint64_t cookie, struct flow *flow, uint32_t *flow_wildcards) + ovs_be64 cookie, struct flow *flow, uint32_t *flow_wildcards) { uint32_t wildcards = ntohl(match->wildcards); @@ -350,3 +348,88 @@ flow_print(FILE *stream, const struct flow *flow) fputs(s, stream); free(s); } + +/* flow_wildcards functions. */ + +/* Given the wildcard bit count in bits 'shift' through 'shift + 5' (inclusive) + * of 'wildcards', returns a 32-bit bit mask with a 1 in each bit that must + * match and a 0 in each bit that is wildcarded. + * + * The bits in 'wildcards' are in the format used in enum ofp_flow_wildcards: 0 + * is exact match, 1 ignores the LSB, 2 ignores the 2 least-significant bits, + * ..., 32 and higher wildcard the entire field. This is the *opposite* of the + * usual convention where e.g. /24 indicates that 8 bits (not 24 bits) are + * wildcarded. */ +ovs_be32 +flow_nw_bits_to_mask(uint32_t wildcards, int shift) +{ + wildcards = (wildcards >> shift) & 0x3f; + return wildcards < 32 ? htonl(~((1u << wildcards) - 1)) : 0; +} + +/* Initializes 'wc' from 'wildcards', which may be any combination of the + * OFPFW_* and OVSFW_* wildcard bits. */ +void +flow_wildcards_init(struct flow_wildcards *wc, uint32_t wildcards) +{ + wc->wildcards = wildcards & OVSFW_ALL; + wc->nw_src_mask = flow_nw_bits_to_mask(wc->wildcards, OFPFW_NW_SRC_SHIFT); + wc->nw_dst_mask = flow_nw_bits_to_mask(wc->wildcards, OFPFW_NW_DST_SHIFT); +} + +/* Initializes 'wc' as an exact-match set of wildcards; that is, 'wc' does not + * wildcard any bits or fields. */ +void +flow_wildcards_init_exact(struct flow_wildcards *wc) +{ + flow_wildcards_init(wc, 0); +} + +static int +count_ones(ovs_be32 mask) +{ +#if __GNUC__ >= 4 + return __builtin_popcount(mask); +#else + int bits; + + for (bits = 0; mask; bits++) { + mask &= mask - 1; + } + + return bits; +#endif +} + +static bool +set_nw_mask(struct flow_wildcards *wc, ovs_be32 mask, + ovs_be32 *maskp, int shift) +{ + int wcbits = 32 - count_ones(mask); + if (flow_nw_bits_to_mask(wcbits, 0) == mask) { + wc->wildcards &= ~(0x3f << shift); + wc->wildcards |= wcbits << shift; + *maskp = mask; + return true; + } else { + return false; + } +} + +/* Sets the IP (or ARP) source wildcard mask to CIDR 'mask' (consisting of N + * high-order 1-bit and 32-N low-order 0-bits). Returns true if successful, + * false if 'mask' is not a CIDR mask. */ +bool +flow_wildcards_set_nw_src_mask(struct flow_wildcards *wc, ovs_be32 mask) +{ + return set_nw_mask(wc, mask, &wc->nw_src_mask, OFPFW_NW_SRC_SHIFT); +} + +/* Sets the IP (or ARP) destination wildcard mask to CIDR 'mask' (consisting of + * N high-order 1-bit and 32-N low-order 0-bits). Returns true if successful, + * false if 'mask' is not a CIDR mask. */ +bool +flow_wildcards_set_nw_dst_mask(struct flow_wildcards *wc, ovs_be32 mask) +{ + return set_nw_mask(wc, mask, &wc->nw_dst_mask, OFPFW_NW_DST_SHIFT); +}