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 vport->dev = dev; 101 netdev_hold(vport->dev, &vport->dev_tracker, GFP_KERNEL); 102 103 rtnl_unlock(); 104 return vport; 105 error: 106 return ERR_PTR(err); 107 } 108 109 static struct vport *geneve_create(const struct vport_parms *parms) 110 { 111 struct vport *vport; 112 113 vport = geneve_tnl_create(parms); 114 if (IS_ERR(vport)) 115 return vport; 116 117 return ovs_netdev_link(vport, true); 118 } 119 120 static struct vport_ops ovs_geneve_vport_ops = { 121 .type = OVS_VPORT_TYPE_GENEVE, 122 .create = geneve_create, 123 .destroy = ovs_netdev_tunnel_destroy, 124 .get_options = geneve_get_options, 125 .send = dev_queue_xmit, 126 }; 127 128 static int __init ovs_geneve_tnl_init(void) 129 { 130 return ovs_vport_ops_register(&ovs_geneve_vport_ops); 131 } 132 133 static void __exit ovs_geneve_tnl_exit(void) 134 { 135 ovs_vport_ops_unregister(&ovs_geneve_vport_ops); 136 } 137 138 module_init(ovs_geneve_tnl_init); 139 module_exit(ovs_geneve_tnl_exit); 140 141 MODULE_DESCRIPTION("OVS: Geneve switching port"); 142 MODULE_LICENSE("GPL"); 143 MODULE_ALIAS("vport-type-5"); 144