net_failover.c 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842
  1. // SPDX-License-Identifier: GPL-2.0
  2. /* Copyright (c) 2018, Intel Corporation. */
  3. /* This provides a net_failover interface for paravirtual drivers to
  4. * provide an alternate datapath by exporting APIs to create and
  5. * destroy a upper 'net_failover' netdev. The upper dev manages the
  6. * original paravirtual interface as a 'standby' netdev and uses the
  7. * generic failover infrastructure to register and manage a direct
  8. * attached VF as a 'primary' netdev. This enables live migration of
  9. * a VM with direct attached VF by failing over to the paravirtual
  10. * datapath when the VF is unplugged.
  11. *
  12. * Some of the netdev management routines are based on bond/team driver as
  13. * this driver provides active-backup functionality similar to those drivers.
  14. */
  15. #include <linux/netdevice.h>
  16. #include <linux/etherdevice.h>
  17. #include <linux/ethtool.h>
  18. #include <linux/module.h>
  19. #include <linux/slab.h>
  20. #include <linux/netpoll.h>
  21. #include <linux/rtnetlink.h>
  22. #include <linux/if_vlan.h>
  23. #include <linux/pci.h>
  24. #include <net/sch_generic.h>
  25. #include <uapi/linux/if_arp.h>
  26. #include <net/net_failover.h>
  27. static bool net_failover_xmit_ready(struct net_device *dev)
  28. {
  29. return netif_running(dev) && netif_carrier_ok(dev);
  30. }
  31. static int net_failover_open(struct net_device *dev)
  32. {
  33. struct net_failover_info *nfo_info = netdev_priv(dev);
  34. struct net_device *primary_dev, *standby_dev;
  35. int err;
  36. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  37. if (primary_dev) {
  38. err = dev_open(primary_dev, NULL);
  39. if (err)
  40. goto err_primary_open;
  41. }
  42. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  43. if (standby_dev) {
  44. err = dev_open(standby_dev, NULL);
  45. if (err)
  46. goto err_standby_open;
  47. }
  48. if ((primary_dev && net_failover_xmit_ready(primary_dev)) ||
  49. (standby_dev && net_failover_xmit_ready(standby_dev))) {
  50. netif_carrier_on(dev);
  51. netif_tx_wake_all_queues(dev);
  52. }
  53. return 0;
  54. err_standby_open:
  55. if (primary_dev)
  56. dev_close(primary_dev);
  57. err_primary_open:
  58. netif_tx_disable(dev);
  59. return err;
  60. }
  61. static int net_failover_close(struct net_device *dev)
  62. {
  63. struct net_failover_info *nfo_info = netdev_priv(dev);
  64. struct net_device *slave_dev;
  65. netif_tx_disable(dev);
  66. slave_dev = rtnl_dereference(nfo_info->primary_dev);
  67. if (slave_dev)
  68. dev_close(slave_dev);
  69. slave_dev = rtnl_dereference(nfo_info->standby_dev);
  70. if (slave_dev)
  71. dev_close(slave_dev);
  72. return 0;
  73. }
  74. static netdev_tx_t net_failover_drop_xmit(struct sk_buff *skb,
  75. struct net_device *dev)
  76. {
  77. atomic_long_inc(&dev->tx_dropped);
  78. dev_kfree_skb_any(skb);
  79. return NETDEV_TX_OK;
  80. }
  81. static netdev_tx_t net_failover_start_xmit(struct sk_buff *skb,
  82. struct net_device *dev)
  83. {
  84. struct net_failover_info *nfo_info = netdev_priv(dev);
  85. struct net_device *xmit_dev;
  86. /* Try xmit via primary netdev followed by standby netdev */
  87. xmit_dev = rcu_dereference_bh(nfo_info->primary_dev);
  88. if (!xmit_dev || !net_failover_xmit_ready(xmit_dev)) {
  89. xmit_dev = rcu_dereference_bh(nfo_info->standby_dev);
  90. if (!xmit_dev || !net_failover_xmit_ready(xmit_dev))
  91. return net_failover_drop_xmit(skb, dev);
  92. }
  93. skb->dev = xmit_dev;
  94. skb->queue_mapping = qdisc_skb_cb(skb)->slave_dev_queue_mapping;
  95. return dev_queue_xmit(skb);
  96. }
  97. static u16 net_failover_select_queue(struct net_device *dev,
  98. struct sk_buff *skb,
  99. struct net_device *sb_dev)
  100. {
  101. struct net_failover_info *nfo_info = netdev_priv(dev);
  102. struct net_device *primary_dev;
  103. u16 txq;
  104. primary_dev = rcu_dereference(nfo_info->primary_dev);
  105. if (primary_dev) {
  106. const struct net_device_ops *ops = primary_dev->netdev_ops;
  107. if (ops->ndo_select_queue)
  108. txq = ops->ndo_select_queue(primary_dev, skb, sb_dev);
  109. else
  110. txq = netdev_pick_tx(primary_dev, skb, NULL);
  111. qdisc_skb_cb(skb)->slave_dev_queue_mapping = skb->queue_mapping;
  112. return txq;
  113. }
  114. txq = skb_rx_queue_recorded(skb) ? skb_get_rx_queue(skb) : 0;
  115. /* Save the original txq to restore before passing to the driver */
  116. qdisc_skb_cb(skb)->slave_dev_queue_mapping = skb->queue_mapping;
  117. if (unlikely(txq >= dev->real_num_tx_queues)) {
  118. do {
  119. txq -= dev->real_num_tx_queues;
  120. } while (txq >= dev->real_num_tx_queues);
  121. }
  122. return txq;
  123. }
  124. /* fold stats, assuming all rtnl_link_stats64 fields are u64, but
  125. * that some drivers can provide 32bit values only.
  126. */
  127. static void net_failover_fold_stats(struct rtnl_link_stats64 *_res,
  128. const struct rtnl_link_stats64 *_new,
  129. const struct rtnl_link_stats64 *_old)
  130. {
  131. const u64 *new = (const u64 *)_new;
  132. const u64 *old = (const u64 *)_old;
  133. u64 *res = (u64 *)_res;
  134. int i;
  135. for (i = 0; i < sizeof(*_res) / sizeof(u64); i++) {
  136. u64 nv = new[i];
  137. u64 ov = old[i];
  138. s64 delta = nv - ov;
  139. /* detects if this particular field is 32bit only */
  140. if (((nv | ov) >> 32) == 0)
  141. delta = (s64)(s32)((u32)nv - (u32)ov);
  142. /* filter anomalies, some drivers reset their stats
  143. * at down/up events.
  144. */
  145. if (delta > 0)
  146. res[i] += delta;
  147. }
  148. }
  149. static void net_failover_get_stats(struct net_device *dev,
  150. struct rtnl_link_stats64 *stats)
  151. {
  152. struct net_failover_info *nfo_info = netdev_priv(dev);
  153. const struct rtnl_link_stats64 *new;
  154. struct rtnl_link_stats64 temp;
  155. struct net_device *slave_dev;
  156. spin_lock(&nfo_info->stats_lock);
  157. memcpy(stats, &nfo_info->failover_stats, sizeof(*stats));
  158. rcu_read_lock();
  159. slave_dev = rcu_dereference(nfo_info->primary_dev);
  160. if (slave_dev) {
  161. new = dev_get_stats(slave_dev, &temp);
  162. net_failover_fold_stats(stats, new, &nfo_info->primary_stats);
  163. memcpy(&nfo_info->primary_stats, new, sizeof(*new));
  164. }
  165. slave_dev = rcu_dereference(nfo_info->standby_dev);
  166. if (slave_dev) {
  167. new = dev_get_stats(slave_dev, &temp);
  168. net_failover_fold_stats(stats, new, &nfo_info->standby_stats);
  169. memcpy(&nfo_info->standby_stats, new, sizeof(*new));
  170. }
  171. rcu_read_unlock();
  172. memcpy(&nfo_info->failover_stats, stats, sizeof(*stats));
  173. spin_unlock(&nfo_info->stats_lock);
  174. }
  175. static int net_failover_change_mtu(struct net_device *dev, int new_mtu)
  176. {
  177. struct net_failover_info *nfo_info = netdev_priv(dev);
  178. struct net_device *primary_dev, *standby_dev;
  179. int ret = 0;
  180. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  181. if (primary_dev) {
  182. ret = dev_set_mtu(primary_dev, new_mtu);
  183. if (ret)
  184. return ret;
  185. }
  186. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  187. if (standby_dev) {
  188. ret = dev_set_mtu(standby_dev, new_mtu);
  189. if (ret) {
  190. if (primary_dev)
  191. dev_set_mtu(primary_dev, dev->mtu);
  192. return ret;
  193. }
  194. }
  195. dev->mtu = new_mtu;
  196. return 0;
  197. }
  198. static void net_failover_set_rx_mode(struct net_device *dev)
  199. {
  200. struct net_failover_info *nfo_info = netdev_priv(dev);
  201. struct net_device *slave_dev;
  202. rcu_read_lock();
  203. slave_dev = rcu_dereference(nfo_info->primary_dev);
  204. if (slave_dev) {
  205. dev_uc_sync_multiple(slave_dev, dev);
  206. dev_mc_sync_multiple(slave_dev, dev);
  207. }
  208. slave_dev = rcu_dereference(nfo_info->standby_dev);
  209. if (slave_dev) {
  210. dev_uc_sync_multiple(slave_dev, dev);
  211. dev_mc_sync_multiple(slave_dev, dev);
  212. }
  213. rcu_read_unlock();
  214. }
  215. static int net_failover_vlan_rx_add_vid(struct net_device *dev, __be16 proto,
  216. u16 vid)
  217. {
  218. struct net_failover_info *nfo_info = netdev_priv(dev);
  219. struct net_device *primary_dev, *standby_dev;
  220. int ret = 0;
  221. primary_dev = rcu_dereference(nfo_info->primary_dev);
  222. if (primary_dev) {
  223. ret = vlan_vid_add(primary_dev, proto, vid);
  224. if (ret)
  225. return ret;
  226. }
  227. standby_dev = rcu_dereference(nfo_info->standby_dev);
  228. if (standby_dev) {
  229. ret = vlan_vid_add(standby_dev, proto, vid);
  230. if (ret)
  231. if (primary_dev)
  232. vlan_vid_del(primary_dev, proto, vid);
  233. }
  234. return ret;
  235. }
  236. static int net_failover_vlan_rx_kill_vid(struct net_device *dev, __be16 proto,
  237. u16 vid)
  238. {
  239. struct net_failover_info *nfo_info = netdev_priv(dev);
  240. struct net_device *slave_dev;
  241. slave_dev = rcu_dereference(nfo_info->primary_dev);
  242. if (slave_dev)
  243. vlan_vid_del(slave_dev, proto, vid);
  244. slave_dev = rcu_dereference(nfo_info->standby_dev);
  245. if (slave_dev)
  246. vlan_vid_del(slave_dev, proto, vid);
  247. return 0;
  248. }
  249. static const struct net_device_ops failover_dev_ops = {
  250. .ndo_open = net_failover_open,
  251. .ndo_stop = net_failover_close,
  252. .ndo_start_xmit = net_failover_start_xmit,
  253. .ndo_select_queue = net_failover_select_queue,
  254. .ndo_get_stats64 = net_failover_get_stats,
  255. .ndo_change_mtu = net_failover_change_mtu,
  256. .ndo_set_rx_mode = net_failover_set_rx_mode,
  257. .ndo_vlan_rx_add_vid = net_failover_vlan_rx_add_vid,
  258. .ndo_vlan_rx_kill_vid = net_failover_vlan_rx_kill_vid,
  259. .ndo_validate_addr = eth_validate_addr,
  260. .ndo_features_check = passthru_features_check,
  261. };
  262. #define FAILOVER_NAME "net_failover"
  263. #define FAILOVER_VERSION "0.1"
  264. static void nfo_ethtool_get_drvinfo(struct net_device *dev,
  265. struct ethtool_drvinfo *drvinfo)
  266. {
  267. strlcpy(drvinfo->driver, FAILOVER_NAME, sizeof(drvinfo->driver));
  268. strlcpy(drvinfo->version, FAILOVER_VERSION, sizeof(drvinfo->version));
  269. }
  270. static int nfo_ethtool_get_link_ksettings(struct net_device *dev,
  271. struct ethtool_link_ksettings *cmd)
  272. {
  273. struct net_failover_info *nfo_info = netdev_priv(dev);
  274. struct net_device *slave_dev;
  275. slave_dev = rtnl_dereference(nfo_info->primary_dev);
  276. if (!slave_dev || !net_failover_xmit_ready(slave_dev)) {
  277. slave_dev = rtnl_dereference(nfo_info->standby_dev);
  278. if (!slave_dev || !net_failover_xmit_ready(slave_dev)) {
  279. cmd->base.duplex = DUPLEX_UNKNOWN;
  280. cmd->base.port = PORT_OTHER;
  281. cmd->base.speed = SPEED_UNKNOWN;
  282. return 0;
  283. }
  284. }
  285. return __ethtool_get_link_ksettings(slave_dev, cmd);
  286. }
  287. static const struct ethtool_ops failover_ethtool_ops = {
  288. .get_drvinfo = nfo_ethtool_get_drvinfo,
  289. .get_link = ethtool_op_get_link,
  290. .get_link_ksettings = nfo_ethtool_get_link_ksettings,
  291. };
  292. /* Called when slave dev is injecting data into network stack.
  293. * Change the associated network device from lower dev to failover dev.
  294. * note: already called with rcu_read_lock
  295. */
  296. static rx_handler_result_t net_failover_handle_frame(struct sk_buff **pskb)
  297. {
  298. struct sk_buff *skb = *pskb;
  299. struct net_device *dev = rcu_dereference(skb->dev->rx_handler_data);
  300. struct net_failover_info *nfo_info = netdev_priv(dev);
  301. struct net_device *primary_dev, *standby_dev;
  302. primary_dev = rcu_dereference(nfo_info->primary_dev);
  303. standby_dev = rcu_dereference(nfo_info->standby_dev);
  304. if (primary_dev && skb->dev == standby_dev)
  305. return RX_HANDLER_EXACT;
  306. skb->dev = dev;
  307. return RX_HANDLER_ANOTHER;
  308. }
  309. static void net_failover_compute_features(struct net_device *dev)
  310. {
  311. netdev_features_t vlan_features = FAILOVER_VLAN_FEATURES &
  312. NETIF_F_ALL_FOR_ALL;
  313. netdev_features_t enc_features = FAILOVER_ENC_FEATURES;
  314. unsigned short max_hard_header_len = ETH_HLEN;
  315. unsigned int dst_release_flag = IFF_XMIT_DST_RELEASE |
  316. IFF_XMIT_DST_RELEASE_PERM;
  317. struct net_failover_info *nfo_info = netdev_priv(dev);
  318. struct net_device *primary_dev, *standby_dev;
  319. primary_dev = rcu_dereference(nfo_info->primary_dev);
  320. if (primary_dev) {
  321. vlan_features =
  322. netdev_increment_features(vlan_features,
  323. primary_dev->vlan_features,
  324. FAILOVER_VLAN_FEATURES);
  325. enc_features =
  326. netdev_increment_features(enc_features,
  327. primary_dev->hw_enc_features,
  328. FAILOVER_ENC_FEATURES);
  329. dst_release_flag &= primary_dev->priv_flags;
  330. if (primary_dev->hard_header_len > max_hard_header_len)
  331. max_hard_header_len = primary_dev->hard_header_len;
  332. }
  333. standby_dev = rcu_dereference(nfo_info->standby_dev);
  334. if (standby_dev) {
  335. vlan_features =
  336. netdev_increment_features(vlan_features,
  337. standby_dev->vlan_features,
  338. FAILOVER_VLAN_FEATURES);
  339. enc_features =
  340. netdev_increment_features(enc_features,
  341. standby_dev->hw_enc_features,
  342. FAILOVER_ENC_FEATURES);
  343. dst_release_flag &= standby_dev->priv_flags;
  344. if (standby_dev->hard_header_len > max_hard_header_len)
  345. max_hard_header_len = standby_dev->hard_header_len;
  346. }
  347. dev->vlan_features = vlan_features;
  348. dev->hw_enc_features = enc_features | NETIF_F_GSO_ENCAP_ALL;
  349. dev->hard_header_len = max_hard_header_len;
  350. dev->priv_flags &= ~IFF_XMIT_DST_RELEASE;
  351. if (dst_release_flag == (IFF_XMIT_DST_RELEASE |
  352. IFF_XMIT_DST_RELEASE_PERM))
  353. dev->priv_flags |= IFF_XMIT_DST_RELEASE;
  354. netdev_change_features(dev);
  355. }
  356. static void net_failover_lower_state_changed(struct net_device *slave_dev,
  357. struct net_device *primary_dev,
  358. struct net_device *standby_dev)
  359. {
  360. struct netdev_lag_lower_state_info info;
  361. if (netif_carrier_ok(slave_dev))
  362. info.link_up = true;
  363. else
  364. info.link_up = false;
  365. if (slave_dev == primary_dev) {
  366. if (netif_running(primary_dev))
  367. info.tx_enabled = true;
  368. else
  369. info.tx_enabled = false;
  370. } else {
  371. if ((primary_dev && netif_running(primary_dev)) ||
  372. (!netif_running(standby_dev)))
  373. info.tx_enabled = false;
  374. else
  375. info.tx_enabled = true;
  376. }
  377. netdev_lower_state_changed(slave_dev, &info);
  378. }
  379. static int net_failover_slave_pre_register(struct net_device *slave_dev,
  380. struct net_device *failover_dev)
  381. {
  382. struct net_device *standby_dev, *primary_dev;
  383. struct net_failover_info *nfo_info;
  384. bool slave_is_standby;
  385. nfo_info = netdev_priv(failover_dev);
  386. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  387. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  388. slave_is_standby = slave_dev->dev.parent == failover_dev->dev.parent;
  389. if (slave_is_standby ? standby_dev : primary_dev) {
  390. netdev_err(failover_dev, "%s attempting to register as slave dev when %s already present\n",
  391. slave_dev->name,
  392. slave_is_standby ? "standby" : "primary");
  393. return -EINVAL;
  394. }
  395. /* We want to allow only a direct attached VF device as a primary
  396. * netdev. As there is no easy way to check for a VF device, restrict
  397. * this to a pci device.
  398. */
  399. if (!slave_is_standby && (!slave_dev->dev.parent ||
  400. !dev_is_pci(slave_dev->dev.parent)))
  401. return -EINVAL;
  402. if (failover_dev->features & NETIF_F_VLAN_CHALLENGED &&
  403. vlan_uses_dev(failover_dev)) {
  404. netdev_err(failover_dev, "Device %s is VLAN challenged and failover device has VLAN set up\n",
  405. failover_dev->name);
  406. return -EINVAL;
  407. }
  408. return 0;
  409. }
  410. static int net_failover_slave_register(struct net_device *slave_dev,
  411. struct net_device *failover_dev)
  412. {
  413. struct net_device *standby_dev, *primary_dev;
  414. struct net_failover_info *nfo_info;
  415. bool slave_is_standby;
  416. u32 orig_mtu;
  417. int err;
  418. /* Align MTU of slave with failover dev */
  419. orig_mtu = slave_dev->mtu;
  420. err = dev_set_mtu(slave_dev, failover_dev->mtu);
  421. if (err) {
  422. netdev_err(failover_dev, "unable to change mtu of %s to %u register failed\n",
  423. slave_dev->name, failover_dev->mtu);
  424. goto done;
  425. }
  426. dev_hold(slave_dev);
  427. if (netif_running(failover_dev)) {
  428. err = dev_open(slave_dev, NULL);
  429. if (err && (err != -EBUSY)) {
  430. netdev_err(failover_dev, "Opening slave %s failed err:%d\n",
  431. slave_dev->name, err);
  432. goto err_dev_open;
  433. }
  434. }
  435. netif_addr_lock_bh(failover_dev);
  436. dev_uc_sync_multiple(slave_dev, failover_dev);
  437. dev_mc_sync_multiple(slave_dev, failover_dev);
  438. netif_addr_unlock_bh(failover_dev);
  439. err = vlan_vids_add_by_dev(slave_dev, failover_dev);
  440. if (err) {
  441. netdev_err(failover_dev, "Failed to add vlan ids to device %s err:%d\n",
  442. slave_dev->name, err);
  443. goto err_vlan_add;
  444. }
  445. nfo_info = netdev_priv(failover_dev);
  446. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  447. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  448. slave_is_standby = slave_dev->dev.parent == failover_dev->dev.parent;
  449. if (slave_is_standby) {
  450. rcu_assign_pointer(nfo_info->standby_dev, slave_dev);
  451. standby_dev = slave_dev;
  452. dev_get_stats(standby_dev, &nfo_info->standby_stats);
  453. } else {
  454. rcu_assign_pointer(nfo_info->primary_dev, slave_dev);
  455. primary_dev = slave_dev;
  456. dev_get_stats(primary_dev, &nfo_info->primary_stats);
  457. failover_dev->min_mtu = slave_dev->min_mtu;
  458. failover_dev->max_mtu = slave_dev->max_mtu;
  459. }
  460. net_failover_lower_state_changed(slave_dev, primary_dev, standby_dev);
  461. net_failover_compute_features(failover_dev);
  462. call_netdevice_notifiers(NETDEV_JOIN, slave_dev);
  463. netdev_info(failover_dev, "failover %s slave:%s registered\n",
  464. slave_is_standby ? "standby" : "primary", slave_dev->name);
  465. return 0;
  466. err_vlan_add:
  467. dev_uc_unsync(slave_dev, failover_dev);
  468. dev_mc_unsync(slave_dev, failover_dev);
  469. dev_close(slave_dev);
  470. err_dev_open:
  471. dev_put(slave_dev);
  472. dev_set_mtu(slave_dev, orig_mtu);
  473. done:
  474. return err;
  475. }
  476. static int net_failover_slave_pre_unregister(struct net_device *slave_dev,
  477. struct net_device *failover_dev)
  478. {
  479. struct net_device *standby_dev, *primary_dev;
  480. struct net_failover_info *nfo_info;
  481. nfo_info = netdev_priv(failover_dev);
  482. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  483. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  484. if (slave_dev != primary_dev && slave_dev != standby_dev)
  485. return -ENODEV;
  486. return 0;
  487. }
  488. static int net_failover_slave_unregister(struct net_device *slave_dev,
  489. struct net_device *failover_dev)
  490. {
  491. struct net_device *standby_dev, *primary_dev;
  492. struct net_failover_info *nfo_info;
  493. bool slave_is_standby;
  494. nfo_info = netdev_priv(failover_dev);
  495. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  496. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  497. if (WARN_ON_ONCE(slave_dev != primary_dev && slave_dev != standby_dev))
  498. return -ENODEV;
  499. vlan_vids_del_by_dev(slave_dev, failover_dev);
  500. dev_uc_unsync(slave_dev, failover_dev);
  501. dev_mc_unsync(slave_dev, failover_dev);
  502. dev_close(slave_dev);
  503. nfo_info = netdev_priv(failover_dev);
  504. dev_get_stats(failover_dev, &nfo_info->failover_stats);
  505. slave_is_standby = slave_dev->dev.parent == failover_dev->dev.parent;
  506. if (slave_is_standby) {
  507. RCU_INIT_POINTER(nfo_info->standby_dev, NULL);
  508. } else {
  509. RCU_INIT_POINTER(nfo_info->primary_dev, NULL);
  510. if (standby_dev) {
  511. failover_dev->min_mtu = standby_dev->min_mtu;
  512. failover_dev->max_mtu = standby_dev->max_mtu;
  513. }
  514. }
  515. dev_put(slave_dev);
  516. net_failover_compute_features(failover_dev);
  517. netdev_info(failover_dev, "failover %s slave:%s unregistered\n",
  518. slave_is_standby ? "standby" : "primary", slave_dev->name);
  519. return 0;
  520. }
  521. static int net_failover_slave_link_change(struct net_device *slave_dev,
  522. struct net_device *failover_dev)
  523. {
  524. struct net_device *primary_dev, *standby_dev;
  525. struct net_failover_info *nfo_info;
  526. nfo_info = netdev_priv(failover_dev);
  527. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  528. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  529. if (slave_dev != primary_dev && slave_dev != standby_dev)
  530. return -ENODEV;
  531. if ((primary_dev && net_failover_xmit_ready(primary_dev)) ||
  532. (standby_dev && net_failover_xmit_ready(standby_dev))) {
  533. netif_carrier_on(failover_dev);
  534. netif_tx_wake_all_queues(failover_dev);
  535. } else {
  536. dev_get_stats(failover_dev, &nfo_info->failover_stats);
  537. netif_carrier_off(failover_dev);
  538. netif_tx_stop_all_queues(failover_dev);
  539. }
  540. net_failover_lower_state_changed(slave_dev, primary_dev, standby_dev);
  541. return 0;
  542. }
  543. static int net_failover_slave_name_change(struct net_device *slave_dev,
  544. struct net_device *failover_dev)
  545. {
  546. struct net_device *primary_dev, *standby_dev;
  547. struct net_failover_info *nfo_info;
  548. nfo_info = netdev_priv(failover_dev);
  549. primary_dev = rtnl_dereference(nfo_info->primary_dev);
  550. standby_dev = rtnl_dereference(nfo_info->standby_dev);
  551. if (slave_dev != primary_dev && slave_dev != standby_dev)
  552. return -ENODEV;
  553. /* We need to bring up the slave after the rename by udev in case
  554. * open failed with EBUSY when it was registered.
  555. */
  556. dev_open(slave_dev, NULL);
  557. return 0;
  558. }
  559. static struct failover_ops net_failover_ops = {
  560. .slave_pre_register = net_failover_slave_pre_register,
  561. .slave_register = net_failover_slave_register,
  562. .slave_pre_unregister = net_failover_slave_pre_unregister,
  563. .slave_unregister = net_failover_slave_unregister,
  564. .slave_link_change = net_failover_slave_link_change,
  565. .slave_name_change = net_failover_slave_name_change,
  566. .slave_handle_frame = net_failover_handle_frame,
  567. };
  568. /**
  569. * net_failover_create - Create and register a failover instance
  570. *
  571. * @dev: standby netdev
  572. *
  573. * Creates a failover netdev and registers a failover instance for a standby
  574. * netdev. Used by paravirtual drivers that use 3-netdev model.
  575. * The failover netdev acts as a master device and controls 2 slave devices -
  576. * the original standby netdev and a VF netdev with the same MAC gets
  577. * registered as primary netdev.
  578. *
  579. * Return: pointer to failover instance
  580. */
  581. struct failover *net_failover_create(struct net_device *standby_dev)
  582. {
  583. struct device *dev = standby_dev->dev.parent;
  584. struct net_device *failover_dev;
  585. struct failover *failover;
  586. int err;
  587. /* Alloc at least 2 queues, for now we are going with 16 assuming
  588. * that VF devices being enslaved won't have too many queues.
  589. */
  590. failover_dev = alloc_etherdev_mq(sizeof(struct net_failover_info), 16);
  591. if (!failover_dev) {
  592. dev_err(dev, "Unable to allocate failover_netdev!\n");
  593. return ERR_PTR(-ENOMEM);
  594. }
  595. dev_net_set(failover_dev, dev_net(standby_dev));
  596. SET_NETDEV_DEV(failover_dev, dev);
  597. failover_dev->netdev_ops = &failover_dev_ops;
  598. failover_dev->ethtool_ops = &failover_ethtool_ops;
  599. /* Initialize the device options */
  600. failover_dev->priv_flags |= IFF_UNICAST_FLT | IFF_NO_QUEUE;
  601. failover_dev->priv_flags &= ~(IFF_XMIT_DST_RELEASE |
  602. IFF_TX_SKB_SHARING);
  603. /* don't acquire failover netdev's netif_tx_lock when transmitting */
  604. failover_dev->features |= NETIF_F_LLTX;
  605. /* Don't allow failover devices to change network namespaces. */
  606. failover_dev->features |= NETIF_F_NETNS_LOCAL;
  607. failover_dev->hw_features = FAILOVER_VLAN_FEATURES |
  608. NETIF_F_HW_VLAN_CTAG_TX |
  609. NETIF_F_HW_VLAN_CTAG_RX |
  610. NETIF_F_HW_VLAN_CTAG_FILTER;
  611. failover_dev->hw_features |= NETIF_F_GSO_ENCAP_ALL;
  612. failover_dev->features |= failover_dev->hw_features;
  613. memcpy(failover_dev->dev_addr, standby_dev->dev_addr,
  614. failover_dev->addr_len);
  615. failover_dev->min_mtu = standby_dev->min_mtu;
  616. failover_dev->max_mtu = standby_dev->max_mtu;
  617. err = register_netdev(failover_dev);
  618. if (err) {
  619. dev_err(dev, "Unable to register failover_dev!\n");
  620. goto err_register_netdev;
  621. }
  622. netif_carrier_off(failover_dev);
  623. failover = failover_register(failover_dev, &net_failover_ops);
  624. if (IS_ERR(failover)) {
  625. err = PTR_ERR(failover);
  626. goto err_failover_register;
  627. }
  628. return failover;
  629. err_failover_register:
  630. unregister_netdev(failover_dev);
  631. err_register_netdev:
  632. free_netdev(failover_dev);
  633. return ERR_PTR(err);
  634. }
  635. EXPORT_SYMBOL_GPL(net_failover_create);
  636. /**
  637. * net_failover_destroy - Destroy a failover instance
  638. *
  639. * @failover: pointer to failover instance
  640. *
  641. * Unregisters any slave netdevs associated with the failover instance by
  642. * calling failover_slave_unregister().
  643. * unregisters the failover instance itself and finally frees the failover
  644. * netdev. Used by paravirtual drivers that use 3-netdev model.
  645. *
  646. */
  647. void net_failover_destroy(struct failover *failover)
  648. {
  649. struct net_failover_info *nfo_info;
  650. struct net_device *failover_dev;
  651. struct net_device *slave_dev;
  652. if (!failover)
  653. return;
  654. failover_dev = rcu_dereference(failover->failover_dev);
  655. nfo_info = netdev_priv(failover_dev);
  656. netif_device_detach(failover_dev);
  657. rtnl_lock();
  658. slave_dev = rtnl_dereference(nfo_info->primary_dev);
  659. if (slave_dev)
  660. failover_slave_unregister(slave_dev);
  661. slave_dev = rtnl_dereference(nfo_info->standby_dev);
  662. if (slave_dev)
  663. failover_slave_unregister(slave_dev);
  664. failover_unregister(failover);
  665. unregister_netdevice(failover_dev);
  666. rtnl_unlock();
  667. free_netdev(failover_dev);
  668. }
  669. EXPORT_SYMBOL_GPL(net_failover_destroy);
  670. static __init int
  671. net_failover_init(void)
  672. {
  673. return 0;
  674. }
  675. module_init(net_failover_init);
  676. static __exit
  677. void net_failover_exit(void)
  678. {
  679. }
  680. module_exit(net_failover_exit);
  681. MODULE_DESCRIPTION("Failover driver for Paravirtual drivers");
  682. MODULE_LICENSE("GPL v2");