eth: nfp: replace driver's "pf" lock with devlink instance lock
authorJakub Kicinski <kuba@kernel.org>
Tue, 15 Mar 2022 06:00:06 +0000 (23:00 -0700)
committerJakub Kicinski <kuba@kernel.org>
Wed, 16 Mar 2022 19:56:37 +0000 (12:56 -0700)
The whole reason for existence of the pf mutex is that we could
not lock the devlink instance around port splitting. There are
more types of reconfig which can make ports appear or disappear.
Now that the devlink instance lock is exposed to drivers and
"locked" helpers exist we can switch to using the devlink lock
directly.

Next patches will move the locking inside .port_(un)split to
the core.

Signed-off-by: Jakub Kicinski <kuba@kernel.org>
drivers/net/ethernet/netronome/nfp/nfp_app.h
drivers/net/ethernet/netronome/nfp/nfp_devlink.c
drivers/net/ethernet/netronome/nfp/nfp_main.c
drivers/net/ethernet/netronome/nfp/nfp_main.h
drivers/net/ethernet/netronome/nfp/nfp_net_main.c
drivers/net/ethernet/netronome/nfp/nfp_port.c

index 60cb8a71e02df0855e3f48ecd9304d610de49981..dd56207df246510d4f1eaa6123e283fad738d962 100644 (file)
@@ -4,12 +4,10 @@
 #ifndef _NFP_APP_H
 #define _NFP_APP_H 1
 
-#include <linux/lockdep.h>
 #include <net/devlink.h>
 
 #include <trace/events/devlink.h>
 
-#include "nfp_main.h"
 #include "nfp_net_repr.h"
 
 #define NFP_APP_CTRL_MTU_MAX   U32_MAX
@@ -77,7 +75,7 @@ extern const struct nfp_app_type app_abm;
  * @bpf:       BPF ndo offload-related calls
  * @xdp_offload:    offload an XDP program
  * @eswitch_mode_get:    get SR-IOV eswitch mode
- * @eswitch_mode_set:    set SR-IOV eswitch mode (under pf->lock)
+ * @eswitch_mode_set:    set SR-IOV eswitch mode
  * @sriov_enable: app-specific sriov initialisation
  * @sriov_disable: app-specific sriov clean-up
  * @dev_get:   get representor or internal port representing netdev
@@ -178,10 +176,13 @@ struct nfp_app {
 
 static inline void assert_nfp_app_locked(struct nfp_app *app)
 {
-       lockdep_assert_held(&app->pf->lock);
+       devl_assert_locked(priv_to_devlink(app->pf));
 }
 
-#define nfp_app_is_locked(app) lockdep_is_held(&(app)->pf->lock)
+static inline bool nfp_app_is_locked(struct nfp_app *app)
+{
+       return devl_lock_is_held(priv_to_devlink(app->pf));
+}
 
 void nfp_check_rhashtable_empty(void *ptr, void *arg);
 bool __nfp_ctrl_tx(struct nfp_net *nn, struct sk_buff *skb);
index bea978df771389a0fd418647aa97d31f4c1c1db9..865f62958a72a73b9c211a3fcd2c5e74df6ce61b 100644 (file)
@@ -70,7 +70,7 @@ nfp_devlink_port_split(struct devlink *devlink, unsigned int port_index,
        unsigned int lanes;
        int ret;
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
 
        rtnl_lock();
        ret = nfp_devlink_fill_eth_port_from_id(pf, port_index, &eth_port);
@@ -90,7 +90,7 @@ nfp_devlink_port_split(struct devlink *devlink, unsigned int port_index,
 
        ret = nfp_devlink_set_lanes(pf, eth_port.index, lanes);
 out:
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        return ret;
 }
@@ -104,7 +104,7 @@ nfp_devlink_port_unsplit(struct devlink *devlink, unsigned int port_index,
        unsigned int lanes;
        int ret;
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
 
        rtnl_lock();
        ret = nfp_devlink_fill_eth_port_from_id(pf, port_index, &eth_port);
@@ -124,7 +124,7 @@ nfp_devlink_port_unsplit(struct devlink *devlink, unsigned int port_index,
 
        ret = nfp_devlink_set_lanes(pf, eth_port.index, lanes);
 out:
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        return ret;
 }
@@ -163,9 +163,9 @@ static int nfp_devlink_eswitch_mode_set(struct devlink *devlink, u16 mode,
        struct nfp_pf *pf = devlink_priv(devlink);
        int ret;
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        ret = nfp_app_eswitch_mode_set(pf->app, mode);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        return ret;
 }
@@ -375,12 +375,12 @@ int nfp_devlink_port_register(struct nfp_app *app, struct nfp_port *port)
 
        devlink = priv_to_devlink(app->pf);
 
-       return devlink_port_register(devlink, &port->dl_port, port->eth_id);
+       return devl_port_register(devlink, &port->dl_port, port->eth_id);
 }
 
 void nfp_devlink_port_unregister(struct nfp_port *port)
 {
-       devlink_port_unregister(&port->dl_port);
+       devl_port_unregister(&port->dl_port);
 }
 
 void nfp_devlink_port_type_eth_set(struct nfp_port *port)
index 8693f9905fbe4423bdc239586774dc4c44b823e0..eeda39e34f84e1aa47cd76660f42669ff5ca9bbf 100644 (file)
@@ -227,6 +227,7 @@ static int nfp_pcie_sriov_enable(struct pci_dev *pdev, int num_vfs)
 {
 #ifdef CONFIG_PCI_IOV
        struct nfp_pf *pf = pci_get_drvdata(pdev);
+       struct devlink *devlink;
        int err;
 
        if (num_vfs > pf->limit_vfs) {
@@ -241,7 +242,8 @@ static int nfp_pcie_sriov_enable(struct pci_dev *pdev, int num_vfs)
                return err;
        }
 
-       mutex_lock(&pf->lock);
+       devlink = priv_to_devlink(pf);
+       devl_lock(devlink);
 
        err = nfp_app_sriov_enable(pf->app, num_vfs);
        if (err) {
@@ -255,11 +257,11 @@ static int nfp_pcie_sriov_enable(struct pci_dev *pdev, int num_vfs)
 
        dev_dbg(&pdev->dev, "Created %d VFs.\n", pf->num_vfs);
 
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
        return num_vfs;
 
 err_sriov_disable:
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
        pci_disable_sriov(pdev);
        return err;
 #endif
@@ -270,8 +272,10 @@ static int nfp_pcie_sriov_disable(struct pci_dev *pdev)
 {
 #ifdef CONFIG_PCI_IOV
        struct nfp_pf *pf = pci_get_drvdata(pdev);
+       struct devlink *devlink;
 
-       mutex_lock(&pf->lock);
+       devlink = priv_to_devlink(pf);
+       devl_lock(devlink);
 
        /* If the VFs are assigned we cannot shut down SR-IOV without
         * causing issues, so just leave the hardware available but
@@ -279,7 +283,7 @@ static int nfp_pcie_sriov_disable(struct pci_dev *pdev)
         */
        if (pci_vfs_assigned(pdev)) {
                dev_warn(&pdev->dev, "Disabling while VFs assigned - VFs will not be deallocated\n");
-               mutex_unlock(&pf->lock);
+               devl_unlock(devlink);
                return -EPERM;
        }
 
@@ -287,7 +291,7 @@ static int nfp_pcie_sriov_disable(struct pci_dev *pdev)
 
        pf->num_vfs = 0;
 
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        pci_disable_sriov(pdev);
        dev_dbg(&pdev->dev, "Removed VFs.\n");
@@ -707,7 +711,6 @@ static int nfp_pci_probe(struct pci_dev *pdev,
        pf = devlink_priv(devlink);
        INIT_LIST_HEAD(&pf->vnics);
        INIT_LIST_HEAD(&pf->ports);
-       mutex_init(&pf->lock);
        pci_set_drvdata(pdev, pf);
        pf->pdev = pdev;
        pf->dev_info = dev_info;
@@ -798,7 +801,6 @@ err_disable_msix:
        destroy_workqueue(pf->wq);
 err_pci_priv_unset:
        pci_set_drvdata(pdev, NULL);
-       mutex_destroy(&pf->lock);
        devlink_free(devlink);
 err_rel_regions:
        pci_release_regions(pdev);
@@ -835,7 +837,6 @@ static void __nfp_pci_shutdown(struct pci_dev *pdev, bool unload_fw)
 
        kfree(pf->eth_tbl);
        kfree(pf->nspi);
-       mutex_destroy(&pf->lock);
        devlink_free(priv_to_devlink(pf));
        pci_release_regions(pdev);
        pci_disable_device(pdev);
index 9c72a0ad18eaa09c5ffe0b16bfafe02f780206e6..f56ca11de13401d27b3bd74649794ee0b9dccbf4 100644 (file)
@@ -13,7 +13,6 @@
 #include <linux/list.h>
 #include <linux/types.h>
 #include <linux/msi.h>
-#include <linux/mutex.h>
 #include <linux/pci.h>
 #include <linux/workqueue.h>
 #include <net/devlink.h>
@@ -85,7 +84,8 @@ struct nfp_dumpspec {
  * @port_refresh_work: Work entry for taking netdevs out
  * @shared_bufs:       Array of shared buffer structures if FW has any SBs
  * @num_shared_bufs:   Number of elements in @shared_bufs
- * @lock:              Protects all fields which may change after probe
+ *
+ * Fields which may change after proble are protected by devlink instance lock.
  */
 struct nfp_pf {
        struct pci_dev *pdev;
@@ -141,8 +141,6 @@ struct nfp_pf {
 
        struct nfp_shared_buf *shared_bufs;
        unsigned int num_shared_bufs;
-
-       struct mutex lock;
 };
 
 extern struct pci_driver nfp_netvf_pci_driver;
index a18b99c93ab32676fb0352d47b4f4a71cdeb5d6d..09a0a2076c6e20242d499f3ac2631ff1c65591ab 100644 (file)
@@ -308,6 +308,7 @@ err_prev_deinit:
 static int
 nfp_net_pf_app_init(struct nfp_pf *pf, u8 __iomem *qc_bar, unsigned int stride)
 {
+       struct devlink *devlink = priv_to_devlink(pf);
        u8 __iomem *ctrl_bar;
        int err;
 
@@ -315,9 +316,9 @@ nfp_net_pf_app_init(struct nfp_pf *pf, u8 __iomem *qc_bar, unsigned int stride)
        if (IS_ERR(pf->app))
                return PTR_ERR(pf->app);
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        err = nfp_app_init(pf->app);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
        if (err)
                goto err_free;
 
@@ -344,9 +345,9 @@ nfp_net_pf_app_init(struct nfp_pf *pf, u8 __iomem *qc_bar, unsigned int stride)
 err_unmap:
        nfp_cpp_area_release_free(pf->ctrl_vnic_bar);
 err_app_clean:
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        nfp_app_clean(pf->app);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 err_free:
        nfp_app_free(pf->app);
        pf->app = NULL;
@@ -355,14 +356,16 @@ err_free:
 
 static void nfp_net_pf_app_clean(struct nfp_pf *pf)
 {
+       struct devlink *devlink = priv_to_devlink(pf);
+
        if (pf->ctrl_vnic) {
                nfp_net_pf_free_vnic(pf, pf->ctrl_vnic);
                nfp_cpp_area_release_free(pf->ctrl_vnic_bar);
        }
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        nfp_app_clean(pf->app);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        nfp_app_free(pf->app);
        pf->app = NULL;
@@ -548,12 +551,13 @@ nfp_net_eth_port_update(struct nfp_cpp *cpp, struct nfp_port *port,
 
 int nfp_net_refresh_port_table_sync(struct nfp_pf *pf)
 {
+       struct devlink *devlink = priv_to_devlink(pf);
        struct nfp_eth_table *eth_table;
        struct nfp_net *nn, *next;
        struct nfp_port *port;
        int err;
 
-       lockdep_assert_held(&pf->lock);
+       devl_assert_locked(devlink);
 
        /* Check for nfp_net_pci_remove() racing against us */
        if (list_empty(&pf->vnics))
@@ -602,10 +606,11 @@ static void nfp_net_refresh_vnics(struct work_struct *work)
 {
        struct nfp_pf *pf = container_of(work, struct nfp_pf,
                                         port_refresh_work);
+       struct devlink *devlink = priv_to_devlink(pf);
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        nfp_net_refresh_port_table_sync(pf);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 }
 
 void nfp_net_refresh_port_table(struct nfp_port *port)
@@ -711,7 +716,7 @@ int nfp_net_pci_probe(struct nfp_pf *pf)
        if (err)
                goto err_shared_buf_unreg;
 
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        pf->ddir = nfp_net_debugfs_device_add(pf->pdev);
 
        /* Allocate the vnics and do basic init */
@@ -731,7 +736,7 @@ int nfp_net_pci_probe(struct nfp_pf *pf)
        if (err)
                goto err_stop_app;
 
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
        devlink_register(devlink);
 
        return 0;
@@ -744,7 +749,7 @@ err_free_vnics:
        nfp_net_pf_free_vnics(pf);
 err_clean_ddir:
        nfp_net_debugfs_dir_clean(&pf->ddir);
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
        nfp_devlink_params_unregister(pf);
 err_shared_buf_unreg:
        nfp_shared_buf_unregister(pf);
@@ -758,10 +763,11 @@ err_unmap:
 
 void nfp_net_pci_remove(struct nfp_pf *pf)
 {
+       struct devlink *devlink = priv_to_devlink(pf);
        struct nfp_net *nn, *next;
 
        devlink_unregister(priv_to_devlink(pf));
-       mutex_lock(&pf->lock);
+       devl_lock(devlink);
        list_for_each_entry_safe(nn, next, &pf->vnics, vnic_list) {
                if (!nfp_net_is_data_vnic(nn))
                        continue;
@@ -773,7 +779,7 @@ void nfp_net_pci_remove(struct nfp_pf *pf)
        /* stop app first, to avoid double free of ctrl vNIC's ddir */
        nfp_net_debugfs_dir_clean(&pf->ddir);
 
-       mutex_unlock(&pf->lock);
+       devl_unlock(devlink);
 
        nfp_devlink_params_unregister(pf);
        nfp_shared_buf_unregister(pf);
index 93c5bfc0510b59975c72411e3e5d09b068a6984b..236cd3c1201fd32ca444b225c744fd19a41aabc2 100644 (file)
@@ -78,9 +78,10 @@ int nfp_port_set_features(struct net_device *netdev, netdev_features_t features)
 struct nfp_port *
 nfp_port_from_id(struct nfp_pf *pf, enum nfp_port_type type, unsigned int id)
 {
+       struct devlink *devlink = priv_to_devlink(pf);
        struct nfp_port *port;
 
-       lockdep_assert_held(&pf->lock);
+       devl_assert_locked(devlink);
 
        if (type != NFP_PORT_PHYS_PORT)
                return NULL;