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 const struct net_device_ops internal_dev_netdev_ops
= {
110 .ndo_open
= internal_dev_open
,
111 .ndo_stop
= internal_dev_stop
,
112 .ndo_start_xmit
= internal_dev_xmit
,
113 .ndo_set_mac_address
= eth_mac_addr
,
114 .ndo_change_mtu
= internal_dev_change_mtu
,
117 static struct rtnl_link_ops internal_dev_link_ops __read_mostly
= {
118 .kind
= "openvswitch",
121 static void do_setup(struct net_device
*netdev
)
125 netdev
->netdev_ops
= &internal_dev_netdev_ops
;
127 netdev
->priv_flags
&= ~IFF_TX_SKB_SHARING
;
128 netdev
->priv_flags
|= IFF_LIVE_ADDR_CHANGE
| IFF_OPENVSWITCH
;
129 netdev
->destructor
= internal_dev_destructor
;
130 netdev
->ethtool_ops
= &internal_dev_ethtool_ops
;
131 netdev
->rtnl_link_ops
= &internal_dev_link_ops
;
132 netdev
->tx_queue_len
= 0;
134 netdev
->features
= NETIF_F_LLTX
| NETIF_F_SG
| NETIF_F_FRAGLIST
|
135 NETIF_F_HIGHDMA
| NETIF_F_HW_CSUM
|
136 NETIF_F_GSO_SOFTWARE
| NETIF_F_GSO_ENCAP_ALL
;
138 netdev
->vlan_features
= netdev
->features
;
139 netdev
->hw_enc_features
= netdev
->features
;
140 netdev
->features
|= NETIF_F_HW_VLAN_CTAG_TX
;
141 netdev
->hw_features
= netdev
->features
& ~NETIF_F_LLTX
;
143 eth_hw_addr_random(netdev
);
146 static struct vport
*internal_dev_create(const struct vport_parms
*parms
)
149 struct internal_dev
*internal_dev
;
152 vport
= ovs_vport_alloc(0, &ovs_internal_vport_ops
, parms
);
154 err
= PTR_ERR(vport
);
158 vport
->dev
= alloc_netdev(sizeof(struct internal_dev
),
159 parms
->name
, NET_NAME_UNKNOWN
, do_setup
);
162 goto error_free_vport
;
165 dev_net_set(vport
->dev
, ovs_dp_get_net(vport
->dp
));
166 internal_dev
= internal_dev_priv(vport
->dev
);
167 internal_dev
->vport
= vport
;
169 /* Restrict bridge port to current netns. */
170 if (vport
->port_no
== OVSP_LOCAL
)
171 vport
->dev
->features
|= NETIF_F_NETNS_LOCAL
;
174 err
= register_netdevice(vport
->dev
);
176 goto error_free_netdev
;
178 dev_set_promiscuity(vport
->dev
, 1);
180 netif_start_queue(vport
->dev
);
186 free_netdev(vport
->dev
);
188 ovs_vport_free(vport
);
193 static void internal_dev_destroy(struct vport
*vport
)
195 netif_stop_queue(vport
->dev
);
197 dev_set_promiscuity(vport
->dev
, -1);
199 /* unregister_netdevice() waits for an RCU grace period. */
200 unregister_netdevice(vport
->dev
);
205 static void internal_dev_recv(struct vport
*vport
, struct sk_buff
*skb
)
207 struct net_device
*netdev
= vport
->dev
;
208 struct pcpu_sw_netstats
*stats
;
210 if (unlikely(!(netdev
->flags
& IFF_UP
))) {
212 netdev
->stats
.rx_dropped
++;
221 skb
->pkt_type
= PACKET_HOST
;
222 skb
->protocol
= eth_type_trans(skb
, netdev
);
223 skb_postpull_rcsum(skb
, eth_hdr(skb
), ETH_HLEN
);
225 stats
= this_cpu_ptr(netdev
->tstats
);
226 u64_stats_update_begin(&stats
->syncp
);
228 stats
->rx_bytes
+= skb
->len
;
229 u64_stats_update_end(&stats
->syncp
);
234 static struct vport_ops ovs_internal_vport_ops
= {
235 .type
= OVS_VPORT_TYPE_INTERNAL
,
236 .create
= internal_dev_create
,
237 .destroy
= internal_dev_destroy
,
238 .send
= internal_dev_recv
,
241 int ovs_is_internal_dev(const struct net_device
*netdev
)
243 return netdev
->netdev_ops
== &internal_dev_netdev_ops
;
246 struct vport
*ovs_internal_dev_get_vport(struct net_device
*netdev
)
248 if (!ovs_is_internal_dev(netdev
))
251 return internal_dev_priv(netdev
)->vport
;
254 int ovs_internal_dev_rtnl_link_register(void)
258 err
= rtnl_link_register(&internal_dev_link_ops
);
262 err
= ovs_vport_ops_register(&ovs_internal_vport_ops
);
264 rtnl_link_unregister(&internal_dev_link_ops
);
269 void ovs_internal_dev_rtnl_link_unregister(void)
271 ovs_vport_ops_unregister(&ovs_internal_vport_ops
);
272 rtnl_link_unregister(&internal_dev_link_ops
);