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