tjh.dev
Linux kernel mirror (for testing)
git.kernel.org/pub/scm/linux/kernel/git/torvalds/linux.git
kernel
os
linux
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
31static struct vport_ops ovs_geneve_vport_ops;
32/**
33 * struct geneve_port - Keeps track of open UDP ports
34 * @dst_port: destination port.
35 */
36struct geneve_port {
37 u16 port_no;
38};
39
40static inline struct geneve_port *geneve_vport(const struct vport *vport)
41{
42 return vport_priv(vport);
43}
44
45static 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
55static int geneve_get_egress_tun_info(struct vport *vport, struct sk_buff *skb,
56 struct dp_upcall_info *upcall)
57{
58 struct geneve_port *geneve_port = geneve_vport(vport);
59 struct net *net = ovs_dp_get_net(vport->dp);
60 __be16 dport = htons(geneve_port->port_no);
61 __be16 sport = udp_flow_src_port(net, skb, 1, USHRT_MAX, true);
62
63 return ovs_tunnel_get_egress_info(upcall, ovs_dp_get_net(vport->dp),
64 skb, IPPROTO_UDP, sport, dport);
65}
66
67static struct vport *geneve_tnl_create(const struct vport_parms *parms)
68{
69 struct net *net = ovs_dp_get_net(parms->dp);
70 struct nlattr *options = parms->options;
71 struct geneve_port *geneve_port;
72 struct net_device *dev;
73 struct vport *vport;
74 struct nlattr *a;
75 u16 dst_port;
76 int err;
77
78 if (!options) {
79 err = -EINVAL;
80 goto error;
81 }
82
83 a = nla_find_nested(options, OVS_TUNNEL_ATTR_DST_PORT);
84 if (a && nla_len(a) == sizeof(u16)) {
85 dst_port = nla_get_u16(a);
86 } else {
87 /* Require destination port from userspace. */
88 err = -EINVAL;
89 goto error;
90 }
91
92 vport = ovs_vport_alloc(sizeof(struct geneve_port),
93 &ovs_geneve_vport_ops, parms);
94 if (IS_ERR(vport))
95 return vport;
96
97 geneve_port = geneve_vport(vport);
98 geneve_port->port_no = dst_port;
99
100 rtnl_lock();
101 dev = geneve_dev_create_fb(net, parms->name, NET_NAME_USER, dst_port);
102 if (IS_ERR(dev)) {
103 rtnl_unlock();
104 ovs_vport_free(vport);
105 return ERR_CAST(dev);
106 }
107
108 dev_change_flags(dev, dev->flags | IFF_UP);
109 rtnl_unlock();
110 return vport;
111error:
112 return ERR_PTR(err);
113}
114
115static struct vport *geneve_create(const struct vport_parms *parms)
116{
117 struct vport *vport;
118
119 vport = geneve_tnl_create(parms);
120 if (IS_ERR(vport))
121 return vport;
122
123 return ovs_netdev_link(vport, parms->name);
124}
125
126static struct vport_ops ovs_geneve_vport_ops = {
127 .type = OVS_VPORT_TYPE_GENEVE,
128 .create = geneve_create,
129 .destroy = ovs_netdev_tunnel_destroy,
130 .get_options = geneve_get_options,
131 .send = ovs_netdev_send,
132 .owner = THIS_MODULE,
133 .get_egress_tun_info = geneve_get_egress_tun_info,
134};
135
136static int __init ovs_geneve_tnl_init(void)
137{
138 return ovs_vport_ops_register(&ovs_geneve_vport_ops);
139}
140
141static void __exit ovs_geneve_tnl_exit(void)
142{
143 ovs_vport_ops_unregister(&ovs_geneve_vport_ops);
144}
145
146module_init(ovs_geneve_tnl_init);
147module_exit(ovs_geneve_tnl_exit);
148
149MODULE_DESCRIPTION("OVS: Geneve swiching port");
150MODULE_LICENSE("GPL");
151MODULE_ALIAS("vport-type-5");