Re: [PATCH v2.29] datapath: Add basic MPLS support to kernel

diff --git a/datapath/actions.c b/datapath/actions.c
index 0dac658..ac4423a 100644
--- a/datapath/actions.c
+++ b/datapath/actions.c
+/* The end of the mac header.
+ *
+ * For non-MPLS skbs this will correspond to the network header.
+ * For MPLS skbs it will be berfore the network_header as the MPLS
+ * label stack lies between the end of the mac header and the network
+ * header. That is, for MPLS skbs the end of the mac header
+ * is the top of the MPLS label stack.
+ */
+static inline unsigned char *skb_mac_header_end(const struct sk_buff *skb)
+{
+       return skb_mac_header(skb) + skb->mac_len;
+}

+static void set_ethertype(struct sk_buff *skb, __be16 ethertype)
+{
+       __be16 *skb_ethertype = get_ethertype(skb);
+       if (*skb_ethertype == ethertype)
+               return;
+       if (get_ip_summed(skb) == OVS_CSUM_COMPLETE) {
+               __be16 diff[] = { ~*skb_ethertype, ethertype };
+               skb->csum = ~csum_partial((char *)diff, sizeof(diff),
+                                         ~skb->csum);
+       }

+static int push_mpls(struct sk_buff *skb,
+                    const struct ovs_action_push_mpls *mpls)
+{
+       __be32 *new_mpls_lse;
+       int err;
+
+       err = make_writable(skb, skb->mac_len + MPLS_HLEN);
+       if (unlikely(err))
+               return err;
+
+       skb_push(skb, MPLS_HLEN);

+static int pop_mpls(struct sk_buff *skb, const __be16 ethertype)
+{
+       int err;
+
+       err = make_writable(skb, skb->mac_len + MPLS_HLEN);
+       if (unlikely(err))
+               return err;
+
+       if (get_ip_summed(skb) == OVS_CSUM_COMPLETE)
+               skb->csum = csum_sub(skb->csum,
+                                    csum_partial(skb_mac_header_end(skb),
+                                                 MPLS_HLEN, 0));
+
+       memmove(skb_mac_header(skb) + MPLS_HLEN, skb_mac_header(skb),
+               skb->mac_len);
+
+       skb_pull(skb, MPLS_HLEN);

 /* remove VLAN header from packet and update csum accordingly. */
 static int __pop_vlan_tci(struct sk_buff *skb, __be16 *current_tci)
 {

@@ -115,6 +229,9 @@ static int push_vlan(struct sk_buff *skb, const struct ovs_action_push_vlan *vla
                if (!__vlan_put_tag(skb, current_tag))
                        return -ENOMEM;

+               /* update mac_len for skb_mac_header_end() */
+               skb_reset_mac_len(skb);

-/* Execute a list of actions against 'skb'. */
+/* Execute a list of actions against 'skb'.
+ *
+ * The stack depth is only tracked in the case of a non-MPLS packet
+ * that becomes MPLS via an MPLS push action. The stack depth
+ * is passed to do_output() in order to allow it to prepare the
+ * skb for possible GSO segmentation. */

diff --git a/datapath/datapath.c b/datapath/datapath.c
index 42af315..3a1c203 100644
--- a/datapath/datapath.c
+++ b/datapath/datapath.c

@@ -811,6 +869,35 @@ static int validate_and_copy_actions(const struct nlattr *attr,
                                return -EINVAL;
                        break;

+               case OVS_ACTION_ATTR_PUSH_MPLS: {
+                       const struct ovs_action_push_mpls *mpls = nla_data(a);
+                       if (!eth_p_mpls(mpls->mpls_ethertype))
+                               return -EINVAL;
+                       eth_types_set(eth_types, depth, mpls->mpls_ethertype);
+                       break;
+               }
+
+               case OVS_ACTION_ATTR_POP_MPLS: {
+                       size_t i;
+
+                       for (i = 0; i < eth_types->depth; i++)
+                               if (eth_types->types[i] != htons(ETH_P_IP))
+                                       return -EINVAL;

diff --git a/datapath/flow.c b/datapath/flow.c
index 3ce926e..2a86f90 100644
--- a/datapath/flow.c
+++ b/datapath/flow.c

@@ -848,6 +880,9 @@ const int ovs_key_lens[OVS_KEY_ATTR_MAX + 1] = {
        [OVS_KEY_ATTR_ARP] = sizeof(struct ovs_key_arp),
        [OVS_KEY_ATTR_ND] = sizeof(struct ovs_key_nd),
        [OVS_KEY_ATTR_TUNNEL] = -1,
+
+       /* Not upstream. */
+       [OVS_KEY_ATTR_MPLS] = sizeof(struct ovs_key_mpls),