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