X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=ofproto%2Fin-band.c;h=6623aca0b261537a626bac4466311b9d2152cc4a;hb=c97fb13280c565f55ed0de7cf0bf06ffe8320b70;hp=8968cff59c26932f3ca1712561adef4587db65cb;hpb=cf3fad8a1b633c7c4231edda04b0e56e67df0d91;p=openvswitch diff --git a/ofproto/in-band.c b/ofproto/in-band.c index 8968cff5..6623aca0 100644 --- a/ofproto/in-band.c +++ b/ofproto/in-band.c @@ -28,6 +28,7 @@ #include "dpif.h" #include "flow.h" #include "netdev.h" +#include "netlink.h" #include "odp-util.h" #include "ofproto.h" #include "ofpbuf.h" @@ -235,6 +236,7 @@ struct in_band_remote { struct in_band { struct ofproto *ofproto; struct status_category *ss_cat; + int queue_id, prev_queue_id; /* Remote information. */ time_t next_remote_refresh; /* Refresh timer. */ @@ -427,7 +429,7 @@ in_band_msg_in_hook(struct in_band *in_band, const struct flow *flow, * allowed to be set up in the datapath. */ bool in_band_rule_check(struct in_band *in_band, const struct flow *flow, - const struct odp_actions *actions) + const struct nlattr *actions, size_t actions_len) { if (!in_band) { return true; @@ -439,11 +441,12 @@ in_band_rule_check(struct in_band *in_band, const struct flow *flow, && flow->nw_proto == IP_TYPE_UDP && flow->tp_src == htons(DHCP_SERVER_PORT) && flow->tp_dst == htons(DHCP_CLIENT_PORT)) { - int i; + const struct nlattr *a; + unsigned int left; - for (i=0; in_actions; i++) { - if (actions->actions[i].output.type == ODPAT_OUTPUT - && actions->actions[i].output.port == ODPP_LOCAL) { + NL_ATTR_FOR_EACH_UNSAFE (a, left, actions, actions_len) { + if (nl_attr_type(a) == ODPAT_OUTPUT + && nl_attr_get_u32(a) == ODPP_LOCAL) { return true; } } @@ -453,69 +456,6 @@ in_band_rule_check(struct in_band *in_band, const struct flow *flow, return true; } -static void -set_in_port(struct cls_rule *rule, uint16_t odp_port) -{ - rule->wc.wildcards &= ~OFPFW_IN_PORT; - rule->flow.in_port = odp_port; -} - -static void -set_dl_type(struct cls_rule *rule, uint16_t dl_type) -{ - rule->wc.wildcards &= ~OFPFW_DL_TYPE; - rule->flow.dl_type = dl_type; -} - -static void -set_dl_src(struct cls_rule *rule, const uint8_t dl_src[ETH_ADDR_LEN]) -{ - rule->wc.wildcards &= ~OFPFW_DL_SRC; - memcpy(rule->flow.dl_src, dl_src, ETH_ADDR_LEN); -} - -static void -set_dl_dst(struct cls_rule *rule, const uint8_t dl_dst[ETH_ADDR_LEN]) -{ - rule->wc.wildcards &= ~OFPFW_DL_DST; - memcpy(rule->flow.dl_dst, dl_dst, ETH_ADDR_LEN); -} - -static void -set_tp_src(struct cls_rule *rule, uint16_t tp_src) -{ - rule->wc.wildcards &= ~OFPFW_TP_SRC; - rule->flow.tp_src = tp_src; -} - -static void -set_tp_dst(struct cls_rule *rule, uint16_t tp_dst) -{ - rule->wc.wildcards &= ~OFPFW_TP_DST; - rule->flow.tp_dst = tp_dst; -} - -static void -set_nw_proto(struct cls_rule *rule, uint8_t nw_proto) -{ - rule->wc.wildcards &= ~OFPFW_NW_PROTO; - rule->flow.nw_proto = nw_proto; -} - -static void -set_nw_src(struct cls_rule *rule, const struct in_addr nw_src) -{ - rule->wc.wildcards &= ~OFPFW_NW_SRC_MASK; - rule->flow.nw_src = nw_src.s_addr; -} - -static void -set_nw_dst(struct cls_rule *rule, const struct in_addr nw_dst) -{ - rule->wc.wildcards &= ~OFPFW_NW_DST_MASK; - rule->flow.nw_dst = nw_dst.s_addr; -} - static void make_rules(struct in_band *ib, void (*cb)(struct in_band *, const struct cls_rule *)) @@ -526,26 +466,26 @@ make_rules(struct in_band *ib, if (!eth_addr_is_zero(ib->installed_local_mac)) { /* (a) Allow DHCP requests sent from the local port. */ cls_rule_init_catchall(&rule, IBR_FROM_LOCAL_DHCP); - set_in_port(&rule, ODPP_LOCAL); - set_dl_type(&rule, htons(ETH_TYPE_IP)); - set_dl_src(&rule, ib->installed_local_mac); - set_nw_proto(&rule, IP_TYPE_UDP); - set_tp_src(&rule, htons(DHCP_CLIENT_PORT)); - set_tp_dst(&rule, htons(DHCP_SERVER_PORT)); + cls_rule_set_in_port(&rule, ODPP_LOCAL); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_IP)); + cls_rule_set_dl_src(&rule, ib->installed_local_mac); + cls_rule_set_nw_proto(&rule, IP_TYPE_UDP); + cls_rule_set_tp_src(&rule, htons(DHCP_CLIENT_PORT)); + cls_rule_set_tp_dst(&rule, htons(DHCP_SERVER_PORT)); cb(ib, &rule); /* (b) Allow ARP replies to the local port's MAC address. */ cls_rule_init_catchall(&rule, IBR_TO_LOCAL_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_dl_dst(&rule, ib->installed_local_mac); - set_nw_proto(&rule, ARP_OP_REPLY); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_dl_dst(&rule, ib->installed_local_mac); + cls_rule_set_nw_proto(&rule, ARP_OP_REPLY); cb(ib, &rule); /* (c) Allow ARP requests from the local port's MAC address. */ cls_rule_init_catchall(&rule, IBR_FROM_LOCAL_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_dl_src(&rule, ib->installed_local_mac); - set_nw_proto(&rule, ARP_OP_REQUEST); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_dl_src(&rule, ib->installed_local_mac); + cls_rule_set_nw_proto(&rule, ARP_OP_REQUEST); cb(ib, &rule); } @@ -562,16 +502,16 @@ make_rules(struct in_band *ib, /* (d) Allow ARP replies to the next hop's MAC address. */ cls_rule_init_catchall(&rule, IBR_TO_NEXT_HOP_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_dl_dst(&rule, remote_mac); - set_nw_proto(&rule, ARP_OP_REPLY); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_dl_dst(&rule, remote_mac); + cls_rule_set_nw_proto(&rule, ARP_OP_REPLY); cb(ib, &rule); /* (e) Allow ARP requests from the next hop's MAC address. */ cls_rule_init_catchall(&rule, IBR_FROM_NEXT_HOP_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_dl_src(&rule, remote_mac); - set_nw_proto(&rule, ARP_OP_REQUEST); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_dl_src(&rule, remote_mac); + cls_rule_set_nw_proto(&rule, ARP_OP_REQUEST); cb(ib, &rule); } @@ -582,17 +522,17 @@ make_rules(struct in_band *ib, /* (f) Allow ARP replies containing the remote's IP address as a * target. */ cls_rule_init_catchall(&rule, IBR_TO_REMOTE_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_nw_proto(&rule, ARP_OP_REPLY); - set_nw_dst(&rule, a->sin_addr); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_nw_proto(&rule, ARP_OP_REPLY); + cls_rule_set_nw_dst(&rule, a->sin_addr.s_addr); cb(ib, &rule); /* (g) Allow ARP requests containing the remote's IP address as a * source. */ cls_rule_init_catchall(&rule, IBR_FROM_REMOTE_ARP); - set_dl_type(&rule, htons(ETH_TYPE_ARP)); - set_nw_proto(&rule, ARP_OP_REQUEST); - set_nw_src(&rule, a->sin_addr); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_ARP)); + cls_rule_set_nw_proto(&rule, ARP_OP_REQUEST); + cls_rule_set_nw_src(&rule, a->sin_addr.s_addr); cb(ib, &rule); } @@ -601,18 +541,18 @@ make_rules(struct in_band *ib, || a->sin_port != a[-1].sin_port) { /* (h) Allow TCP traffic to the remote's IP and port. */ cls_rule_init_catchall(&rule, IBR_TO_REMOTE_TCP); - set_dl_type(&rule, htons(ETH_TYPE_IP)); - set_nw_proto(&rule, IP_TYPE_TCP); - set_nw_dst(&rule, a->sin_addr); - set_tp_dst(&rule, a->sin_port); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_IP)); + cls_rule_set_nw_proto(&rule, IP_TYPE_TCP); + cls_rule_set_nw_dst(&rule, a->sin_addr.s_addr); + cls_rule_set_tp_dst(&rule, a->sin_port); cb(ib, &rule); /* (i) Allow TCP traffic from the remote's IP and port. */ cls_rule_init_catchall(&rule, IBR_FROM_REMOTE_TCP); - set_dl_type(&rule, htons(ETH_TYPE_IP)); - set_nw_proto(&rule, IP_TYPE_TCP); - set_nw_src(&rule, a->sin_addr); - set_tp_src(&rule, a->sin_port); + cls_rule_set_dl_type(&rule, htons(ETH_TYPE_IP)); + cls_rule_set_nw_proto(&rule, IP_TYPE_TCP); + cls_rule_set_nw_src(&rule, a->sin_addr.s_addr); + cls_rule_set_tp_src(&rule, a->sin_port); cb(ib, &rule); } } @@ -648,13 +588,31 @@ drop_rules(struct in_band *ib) static void add_rule(struct in_band *ib, const struct cls_rule *rule) { - union ofp_action action; - - action.type = htons(OFPAT_OUTPUT); - action.output.len = htons(sizeof action); - action.output.port = htons(OFPP_NORMAL); - action.output.max_len = htons(0); - ofproto_add_flow(ib->ofproto, rule, &action, 1, 0); + struct { + struct nx_action_set_queue nxsq; + struct ofp_action_output oao; + } actions; + + memset(&actions, 0, sizeof actions); + + actions.oao.type = htons(OFPAT_OUTPUT); + actions.oao.len = htons(sizeof actions.oao); + actions.oao.port = htons(OFPP_NORMAL); + actions.oao.max_len = htons(0); + + if (ib->queue_id < 0) { + ofproto_add_flow(ib->ofproto, rule, + (union ofp_action *) &actions.oao, 1); + } else { + actions.nxsq.type = htons(OFPAT_VENDOR); + actions.nxsq.len = htons(sizeof actions.nxsq); + actions.nxsq.vendor = htonl(NX_VENDOR_ID); + actions.nxsq.subtype = htons(NXAST_SET_QUEUE); + actions.nxsq.queue_id = htonl(ib->queue_id); + + ofproto_add_flow(ib->ofproto, rule, (union ofp_action *) &actions, + sizeof actions / sizeof(union ofp_action)); + } } /* Inserts flows into the flow table for the current state of 'ib'. */ @@ -689,15 +647,17 @@ compare_macs(const void *a, const void *b) void in_band_run(struct in_band *ib) { + bool local_change, remote_change, queue_id_change; struct in_band_remote *r; - bool local_change, remote_change; local_change = refresh_local(ib); remote_change = refresh_remotes(ib); - if (!local_change && !remote_change) { + queue_id_change = ib->queue_id != ib->prev_queue_id; + if (!local_change && !remote_change && !queue_id_change) { /* Nothing changed, nothing to do. */ return; } + ib->prev_queue_id = ib->queue_id; /* Drop old rules. */ drop_rules(ib); @@ -771,6 +731,7 @@ in_band_create(struct ofproto *ofproto, struct dpif *dpif, in_band->ofproto = ofproto; in_band->ss_cat = switch_status_register(ss, "in-band", in_band_status_cb, in_band); + in_band->queue_id = in_band->prev_queue_id = -1; in_band->next_remote_refresh = TIME_MIN; in_band->next_local_refresh = TIME_MIN; in_band->local_netdev = local_netdev; @@ -841,3 +802,13 @@ in_band_set_remotes(struct in_band *ib, /* Force refresh in next call to in_band_run(). */ ib->next_remote_refresh = TIME_MIN; } + +/* Sets the OpenFlow queue used by flows set up by 'ib' to 'queue_id'. If + * 'queue_id' is negative, 'ib' will not set any queue (which is also the + * default). */ +void +in_band_set_queue(struct in_band *ib, int queue_id) +{ + ib->queue_id = queue_id; +} +