net/openvswitch/vport-geneve.c

   1 // SPDX-License-Identifier: GPL-2.0-or-later
   2 /*
   3  * Copyright (c) 2014 Nicira, Inc.
   4  */
   5
   6 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
   7
   8 #include <linux/in.h>
   9 #include <linux/ip.h>
  10 #include <linux/net.h>
  11 #include <linux/rculist.h>
  12 #include <linux/udp.h>
  13 #include <linux/if_vlan.h>
  14 #include <linux/module.h>
  15
  16 #include <net/geneve.h>
  17 #include <net/icmp.h>
  18 #include <net/ip.h>
  19 #include <net/route.h>
  20 #include <net/udp.h>
  21 #include <net/xfrm.h>
  22
  23 #include "datapath.h"
  24 #include "vport.h"
  25 #include "vport-netdev.h"
  26
  27 static struct vport_ops ovs_geneve_vport_ops;
  28 /**
  29  * struct geneve_port - Keeps track of open UDP ports
  30  * @dst_port: destination port.
  31  */
  32 struct geneve_port {
  33         u16 dst_port;
  34 };
  35
  36 static inline struct geneve_port *geneve_vport(const struct vport *vport)
  37 {
  38         return vport_priv(vport);
  39 }
  40
  41 static int geneve_get_options(const struct vport *vport,
  42                               struct sk_buff *skb)
  43 {
  44         struct geneve_port *geneve_port = geneve_vport(vport);
  45
  46         if (nla_put_u16(skb, OVS_TUNNEL_ATTR_DST_PORT, geneve_port->dst_port))
  47                 return -EMSGSIZE;
  48         return 0;
  49 }
  50
  51 static struct vport *geneve_tnl_create(const struct vport_parms *parms)
  52 {
  53         struct net *net = ovs_dp_get_net(parms->dp);
  54         struct nlattr *options = parms->options;
  55         struct geneve_port *geneve_port;
  56         struct net_device *dev;
  57         struct vport *vport;
  58         struct nlattr *a;
  59         u16 dst_port;
  60         int err;
  61
  62         if (!options) {
  63                 err = -EINVAL;
  64                 goto error;
  65         }
  66
  67         a = nla_find_nested(options, OVS_TUNNEL_ATTR_DST_PORT);
  68         if (a && nla_len(a) == sizeof(u16)) {
  69                 dst_port = nla_get_u16(a);
  70         } else {
  71                 /* Require destination port from userspace. */
  72                 err = -EINVAL;
  73                 goto error;
  74         }
  75
  76         vport = ovs_vport_alloc(sizeof(struct geneve_port),
  77                                 &ovs_geneve_vport_ops, parms);
  78         if (IS_ERR(vport))
  79                 return vport;
  80
  81         geneve_port = geneve_vport(vport);
  82         geneve_port->dst_port = dst_port;
  83
  84         rtnl_lock();
  85         dev = geneve_dev_create_fb(net, parms->name, NET_NAME_USER, dst_port);
  86         if (IS_ERR(dev)) {
  87                 rtnl_unlock();
  88                 ovs_vport_free(vport);
  89                 return ERR_CAST(dev);
  90         }
  91
  92         err = dev_change_flags(dev, dev->flags | IFF_UP, NULL);
  93         if (err < 0) {
  94                 rtnl_delete_link(dev, 0, NULL);
  95                 rtnl_unlock();
  96                 ovs_vport_free(vport);
  97                 goto error;
  98         }
  99
 100         rtnl_unlock();
 101         return vport;
 102 error:
 103         return ERR_PTR(err);
 104 }
 105
 106 static struct vport *geneve_create(const struct vport_parms *parms)
 107 {
 108         struct vport *vport;
 109
 110         vport = geneve_tnl_create(parms);
 111         if (IS_ERR(vport))
 112                 return vport;
 113
 114         return ovs_netdev_link(vport, parms->name);
 115 }
 116
 117 static struct vport_ops ovs_geneve_vport_ops = {
 118         .type           = OVS_VPORT_TYPE_GENEVE,
 119         .create         = geneve_create,
 120         .destroy        = ovs_netdev_tunnel_destroy,
 121         .get_options    = geneve_get_options,
 122         .send           = dev_queue_xmit,
 123 };
 124
 125 static int __init ovs_geneve_tnl_init(void)
 126 {
 127         return ovs_vport_ops_register(&ovs_geneve_vport_ops);
 128 }
 129
 130 static void __exit ovs_geneve_tnl_exit(void)
 131 {
 132         ovs_vport_ops_unregister(&ovs_geneve_vport_ops);
 133 }
 134
 135 module_init(ovs_geneve_tnl_init);
 136 module_exit(ovs_geneve_tnl_exit);
 137
 138 MODULE_DESCRIPTION("OVS: Geneve switching port");
 139 MODULE_LICENSE("GPL");
 140 MODULE_ALIAS("vport-type-5");