2 * Copyright (c) 2007-2012 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>
29 #include <net/rtnetlink.h>
32 #include "vport-internal_dev.h"
33 #include "vport-netdev.h"
39 static struct vport_ops ovs_internal_vport_ops
;
41 static struct internal_dev
*internal_dev_priv(struct net_device
*netdev
)
43 return netdev_priv(netdev
);
46 /* Called with rcu_read_lock_bh. */
47 static int internal_dev_xmit(struct sk_buff
*skb
, struct net_device
*netdev
)
53 err
= ovs_vport_receive(internal_dev_priv(netdev
)->vport
, skb
, NULL
);
57 struct pcpu_sw_netstats
*tstats
= this_cpu_ptr(netdev
->tstats
);
59 u64_stats_update_begin(&tstats
->syncp
);
60 tstats
->tx_bytes
+= len
;
62 u64_stats_update_end(&tstats
->syncp
);
64 netdev
->stats
.tx_errors
++;
69 static int internal_dev_open(struct net_device
*netdev
)
71 netif_start_queue(netdev
);
75 static int internal_dev_stop(struct net_device
*netdev
)
77 netif_stop_queue(netdev
);
81 static void internal_dev_getinfo(struct net_device
*netdev
,
82 struct ethtool_drvinfo
*info
)
84 strlcpy(info
->driver
, "openvswitch", sizeof(info
->driver
));
87 static const struct ethtool_ops internal_dev_ethtool_ops
= {
88 .get_drvinfo
= internal_dev_getinfo
,
89 .get_link
= ethtool_op_get_link
,
92 static int internal_dev_change_mtu(struct net_device
*netdev
, int new_mtu
)
97 netdev
->mtu
= new_mtu
;
101 static void internal_dev_destructor(struct net_device
*dev
)
103 struct vport
*vport
= ovs_internal_dev_get_vport(dev
);
105 ovs_vport_free(vport
);
109 static struct rtnl_link_stats64
*
110 internal_get_stats(struct net_device
*dev
, struct rtnl_link_stats64
*stats
)
114 memset(stats
, 0, sizeof(*stats
));
115 stats
->rx_errors
= dev
->stats
.rx_errors
;
116 stats
->tx_errors
= dev
->stats
.tx_errors
;
117 stats
->tx_dropped
= dev
->stats
.tx_dropped
;
118 stats
->rx_dropped
= dev
->stats
.rx_dropped
;
120 for_each_possible_cpu(i
) {
121 const struct pcpu_sw_netstats
*percpu_stats
;
122 struct pcpu_sw_netstats local_stats
;
125 percpu_stats
= per_cpu_ptr(dev
->tstats
, i
);
128 start
= u64_stats_fetch_begin_irq(&percpu_stats
->syncp
);
129 local_stats
= *percpu_stats
;
130 } while (u64_stats_fetch_retry_irq(&percpu_stats
->syncp
, start
));
132 stats
->rx_bytes
+= local_stats
.rx_bytes
;
133 stats
->rx_packets
+= local_stats
.rx_packets
;
134 stats
->tx_bytes
+= local_stats
.tx_bytes
;
135 stats
->tx_packets
+= local_stats
.tx_packets
;
141 #ifdef HAVE_IFF_PHONY_HEADROOM
142 static void internal_set_rx_headroom(struct net_device
*dev
, int new_hr
)
144 dev
->needed_headroom
= new_hr
< 0 ? 0 : new_hr
;
148 static const struct net_device_ops internal_dev_netdev_ops
= {
149 .ndo_open
= internal_dev_open
,
150 .ndo_stop
= internal_dev_stop
,
151 .ndo_start_xmit
= internal_dev_xmit
,
152 .ndo_set_mac_address
= eth_mac_addr
,
153 .ndo_change_mtu
= internal_dev_change_mtu
,
154 .ndo_get_stats64
= internal_get_stats
,
155 #ifdef HAVE_IFF_PHONY_HEADROOM
156 #ifndef HAVE_NET_DEVICE_OPS_WITH_EXTENDED
157 .ndo_set_rx_headroom
= internal_set_rx_headroom
,
159 .extended
.ndo_set_rx_headroom
= internal_set_rx_headroom
,
164 static struct rtnl_link_ops internal_dev_link_ops __read_mostly
= {
165 .kind
= "openvswitch",
168 static void do_setup(struct net_device
*netdev
)
172 netdev
->netdev_ops
= &internal_dev_netdev_ops
;
174 netdev
->priv_flags
&= ~IFF_TX_SKB_SHARING
;
175 netdev
->priv_flags
|= IFF_LIVE_ADDR_CHANGE
| IFF_OPENVSWITCH
|
176 IFF_PHONY_HEADROOM
| IFF_NO_QUEUE
;
177 netdev
->destructor
= internal_dev_destructor
;
178 netdev
->ethtool_ops
= &internal_dev_ethtool_ops
;
179 netdev
->rtnl_link_ops
= &internal_dev_link_ops
;
181 #ifndef HAVE_IFF_NO_QUEUE
182 netdev
->tx_queue_len
= 0;
185 netdev
->features
= NETIF_F_LLTX
| NETIF_F_SG
| NETIF_F_FRAGLIST
|
186 NETIF_F_HIGHDMA
| NETIF_F_HW_CSUM
|
187 NETIF_F_GSO_SOFTWARE
| NETIF_F_GSO_ENCAP_ALL
;
189 netdev
->vlan_features
= netdev
->features
;
190 netdev
->hw_enc_features
= netdev
->features
;
191 netdev
->features
|= NETIF_F_HW_VLAN_CTAG_TX
;
192 netdev
->hw_features
= netdev
->features
& ~NETIF_F_LLTX
;
194 eth_hw_addr_random(netdev
);
197 static struct vport
*internal_dev_create(const struct vport_parms
*parms
)
200 struct internal_dev
*internal_dev
;
203 vport
= ovs_vport_alloc(0, &ovs_internal_vport_ops
, parms
);
205 err
= PTR_ERR(vport
);
209 vport
->dev
= alloc_netdev(sizeof(struct internal_dev
),
210 parms
->name
, NET_NAME_USER
, do_setup
);
213 goto error_free_vport
;
215 vport
->dev
->tstats
= netdev_alloc_pcpu_stats(struct pcpu_sw_netstats
);
216 if (!vport
->dev
->tstats
) {
218 goto error_free_netdev
;
221 #ifdef HAVE_IFF_PHONY_HEADROOM
222 vport
->dev
->needed_headroom
= vport
->dp
->max_headroom
;
224 dev_net_set(vport
->dev
, ovs_dp_get_net(vport
->dp
));
225 internal_dev
= internal_dev_priv(vport
->dev
);
226 internal_dev
->vport
= vport
;
228 /* Restrict bridge port to current netns. */
229 if (vport
->port_no
== OVSP_LOCAL
)
230 vport
->dev
->features
|= NETIF_F_NETNS_LOCAL
;
233 err
= register_netdevice(vport
->dev
);
237 dev_set_promiscuity(vport
->dev
, 1);
239 netif_start_queue(vport
->dev
);
245 free_percpu(vport
->dev
->tstats
);
247 free_netdev(vport
->dev
);
249 ovs_vport_free(vport
);
254 static void internal_dev_destroy(struct vport
*vport
)
256 netif_stop_queue(vport
->dev
);
258 dev_set_promiscuity(vport
->dev
, -1);
260 /* unregister_netdevice() waits for an RCU grace period. */
261 unregister_netdevice(vport
->dev
);
262 free_percpu(vport
->dev
->tstats
);
266 static netdev_tx_t
internal_dev_recv(struct sk_buff
*skb
)
268 struct net_device
*netdev
= skb
->dev
;
269 struct pcpu_sw_netstats
*stats
;
271 if (unlikely(!(netdev
->flags
& IFF_UP
))) {
273 netdev
->stats
.rx_dropped
++;
281 skb
->pkt_type
= PACKET_HOST
;
282 skb
->protocol
= eth_type_trans(skb
, netdev
);
283 skb_postpull_rcsum(skb
, eth_hdr(skb
), ETH_HLEN
);
285 stats
= this_cpu_ptr(netdev
->tstats
);
286 u64_stats_update_begin(&stats
->syncp
);
288 stats
->rx_bytes
+= skb
->len
;
289 u64_stats_update_end(&stats
->syncp
);
295 static struct vport_ops ovs_internal_vport_ops
= {
296 .type
= OVS_VPORT_TYPE_INTERNAL
,
297 .create
= internal_dev_create
,
298 .destroy
= internal_dev_destroy
,
299 .send
= internal_dev_recv
,
302 int ovs_is_internal_dev(const struct net_device
*netdev
)
304 return netdev
->netdev_ops
== &internal_dev_netdev_ops
;
307 struct vport
*ovs_internal_dev_get_vport(struct net_device
*netdev
)
309 if (!ovs_is_internal_dev(netdev
))
312 return internal_dev_priv(netdev
)->vport
;
315 int ovs_internal_dev_rtnl_link_register(void)
319 err
= rtnl_link_register(&internal_dev_link_ops
);
323 err
= ovs_vport_ops_register(&ovs_internal_vport_ops
);
325 rtnl_link_unregister(&internal_dev_link_ops
);
330 void ovs_internal_dev_rtnl_link_unregister(void)
332 ovs_vport_ops_unregister(&ovs_internal_vport_ops
);
333 rtnl_link_unregister(&internal_dev_link_ops
);