2 * Copyright (c) 2007-2015 Nicira, Inc.
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of version 2 of the GNU General Public
6 * License as published by the Free Software Foundation.
8 * This program is distributed in the hope that it will be useful, but
9 * WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 * General Public License for more details.
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19 #include <linux/hardirq.h>
20 #include <linux/if_vlan.h>
21 #include <linux/kernel.h>
22 #include <linux/netdevice.h>
23 #include <linux/etherdevice.h>
24 #include <linux/ethtool.h>
25 #include <linux/skbuff.h>
26 #include <linux/percpu.h>
27 #include <linux/u64_stats_sync.h>
28 #include <linux/netdev_features.h>
32 #include <net/rtnetlink.h>
35 #include "vport-internal_dev.h"
36 #include "vport-netdev.h"
42 static struct vport_ops ovs_internal_vport_ops
;
44 static struct internal_dev
*internal_dev_priv(struct net_device
*netdev
)
46 return netdev_priv(netdev
);
49 /* Called with rcu_read_lock_bh. */
50 static int internal_dev_xmit(struct sk_buff
*skb
, struct net_device
*netdev
)
56 err
= ovs_vport_receive(internal_dev_priv(netdev
)->vport
, skb
, NULL
);
60 #ifdef HAVE_DEV_TSTATS
61 struct pcpu_sw_netstats
*tstats
;
63 tstats
= this_cpu_ptr((struct pcpu_sw_netstats __percpu
*)netdev
->tstats
);
65 u64_stats_update_begin(&tstats
->syncp
);
66 tstats
->tx_bytes
+= len
;
68 u64_stats_update_end(&tstats
->syncp
);
71 netdev
->stats
.tx_errors
++;
76 static int internal_dev_open(struct net_device
*netdev
)
78 netif_start_queue(netdev
);
82 static int internal_dev_stop(struct net_device
*netdev
)
84 netif_stop_queue(netdev
);
88 static void internal_dev_getinfo(struct net_device
*netdev
,
89 struct ethtool_drvinfo
*info
)
91 strlcpy(info
->driver
, "openvswitch", sizeof(info
->driver
));
94 static const struct ethtool_ops internal_dev_ethtool_ops
= {
95 .get_drvinfo
= internal_dev_getinfo
,
96 .get_link
= ethtool_op_get_link
,
97 #if LINUX_VERSION_CODE < KERNEL_VERSION(2,6,39)
98 .get_sg
= ethtool_op_get_sg
,
99 .set_sg
= ethtool_op_set_sg
,
100 .get_tx_csum
= ethtool_op_get_tx_csum
,
101 .set_tx_csum
= ethtool_op_set_tx_hw_csum
,
102 .get_tso
= ethtool_op_get_tso
,
103 .set_tso
= ethtool_op_set_tso
,
107 static int internal_dev_change_mtu(struct net_device
*netdev
, int new_mtu
)
112 netdev
->mtu
= new_mtu
;
116 static void internal_dev_destructor(struct net_device
*dev
)
118 struct vport
*vport
= ovs_internal_dev_get_vport(dev
);
120 ovs_vport_free(vport
);
124 #ifdef HAVE_DEV_TSTATS
125 static int internal_dev_init(struct net_device
*dev
)
127 dev
->tstats
= (typeof(dev
->tstats
)) netdev_alloc_pcpu_stats(struct pcpu_sw_netstats
);
133 static void internal_dev_uninit(struct net_device
*dev
)
135 free_percpu(dev
->tstats
);
139 static const struct net_device_ops internal_dev_netdev_ops
= {
140 #ifdef HAVE_DEV_TSTATS
141 .ndo_init
= internal_dev_init
,
142 .ndo_uninit
= internal_dev_uninit
,
143 .ndo_get_stats64
= ip_tunnel_get_stats64
,
145 .ndo_open
= internal_dev_open
,
146 .ndo_stop
= internal_dev_stop
,
147 .ndo_start_xmit
= internal_dev_xmit
,
148 .ndo_set_mac_address
= eth_mac_addr
,
149 .ndo_change_mtu
= internal_dev_change_mtu
,
152 static struct rtnl_link_ops internal_dev_link_ops __read_mostly
= {
153 .kind
= "openvswitch",
156 static void do_setup(struct net_device
*netdev
)
160 netdev
->netdev_ops
= &internal_dev_netdev_ops
;
162 netdev
->priv_flags
&= ~IFF_TX_SKB_SHARING
;
163 netdev
->priv_flags
|= IFF_LIVE_ADDR_CHANGE
| IFF_OPENVSWITCH
;
164 netdev
->destructor
= internal_dev_destructor
;
165 netdev
->ethtool_ops
= &internal_dev_ethtool_ops
;
166 netdev
->rtnl_link_ops
= &internal_dev_link_ops
;
167 netdev
->tx_queue_len
= 0;
169 netdev
->features
= NETIF_F_LLTX
| NETIF_F_SG
| NETIF_F_FRAGLIST
|
170 NETIF_F_HIGHDMA
| NETIF_F_HW_CSUM
|
171 NETIF_F_GSO_SOFTWARE
| NETIF_F_GSO_ENCAP_ALL
;
173 netdev
->vlan_features
= netdev
->features
;
174 netdev
->features
|= NETIF_F_HW_VLAN_CTAG_TX
;
176 #if LINUX_VERSION_CODE >= KERNEL_VERSION(3,8,0)
177 netdev
->hw_enc_features
= netdev
->features
;
179 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,39)
180 netdev
->hw_features
= netdev
->features
& ~NETIF_F_LLTX
;
182 eth_hw_addr_random(netdev
);
185 static struct vport
*internal_dev_create(const struct vport_parms
*parms
)
188 struct internal_dev
*internal_dev
;
191 vport
= ovs_vport_alloc(0, &ovs_internal_vport_ops
, parms
);
193 err
= PTR_ERR(vport
);
197 vport
->dev
= alloc_netdev(sizeof(struct internal_dev
),
198 parms
->name
, NET_NAME_UNKNOWN
, do_setup
);
201 goto error_free_vport
;
204 dev_net_set(vport
->dev
, ovs_dp_get_net(vport
->dp
));
205 internal_dev
= internal_dev_priv(vport
->dev
);
206 internal_dev
->vport
= vport
;
208 /* Restrict bridge port to current netns. */
209 if (vport
->port_no
== OVSP_LOCAL
)
210 vport
->dev
->features
|= NETIF_F_NETNS_LOCAL
;
213 err
= register_netdevice(vport
->dev
);
215 goto error_free_netdev
;
217 dev_set_promiscuity(vport
->dev
, 1);
219 netif_start_queue(vport
->dev
);
225 free_netdev(vport
->dev
);
227 ovs_vport_free(vport
);
232 static void internal_dev_destroy(struct vport
*vport
)
234 netif_stop_queue(vport
->dev
);
236 dev_set_promiscuity(vport
->dev
, -1);
238 /* unregister_netdevice() waits for an RCU grace period. */
239 unregister_netdevice(vport
->dev
);
244 static netdev_tx_t
internal_dev_recv(struct sk_buff
*skb
)
246 struct net_device
*netdev
= skb
->dev
;
247 #ifdef HAVE_DEV_TSTATS
248 struct pcpu_sw_netstats
*stats
;
251 if (unlikely(!(netdev
->flags
& IFF_UP
))) {
253 netdev
->stats
.rx_dropped
++;
257 #if LINUX_VERSION_CODE < KERNEL_VERSION(2,6,37)
258 if (skb_vlan_tag_present(skb
)) {
259 if (unlikely(!vlan_insert_tag_set_proto(skb
,
261 skb_vlan_tag_get(skb
))))
264 if (skb
->ip_summed
== CHECKSUM_COMPLETE
)
265 skb
->csum
= csum_add(skb
->csum
,
266 csum_partial(skb
->data
+ (2 * ETH_ALEN
),
269 vlan_set_tci(skb
, 0);
277 skb
->pkt_type
= PACKET_HOST
;
278 skb
->protocol
= eth_type_trans(skb
, netdev
);
279 skb_postpull_rcsum(skb
, eth_hdr(skb
), ETH_HLEN
);
281 #ifdef HAVE_DEV_TSTATS
282 stats
= this_cpu_ptr((struct pcpu_sw_netstats __percpu
*)netdev
->tstats
);
283 u64_stats_update_begin(&stats
->syncp
);
285 stats
->rx_bytes
+= skb
->len
;
286 u64_stats_update_end(&stats
->syncp
);
293 static struct vport_ops ovs_internal_vport_ops
= {
294 .type
= OVS_VPORT_TYPE_INTERNAL
,
295 .create
= internal_dev_create
,
296 .destroy
= internal_dev_destroy
,
297 .send
= internal_dev_recv
,
300 int ovs_is_internal_dev(const struct net_device
*netdev
)
302 return netdev
->netdev_ops
== &internal_dev_netdev_ops
;
305 struct vport
*ovs_internal_dev_get_vport(struct net_device
*netdev
)
307 if (!ovs_is_internal_dev(netdev
))
310 return internal_dev_priv(netdev
)->vport
;
313 int ovs_internal_dev_rtnl_link_register(void)
317 err
= rtnl_link_register(&internal_dev_link_ops
);
321 err
= ovs_vport_ops_register(&ovs_internal_vport_ops
);
323 rtnl_link_unregister(&internal_dev_link_ops
);
328 void ovs_internal_dev_rtnl_link_unregister(void)
330 ovs_vport_ops_unregister(&ovs_internal_vport_ops
);
331 rtnl_link_unregister(&internal_dev_link_ops
);