Commit 82c64484 authored by Alex Maftei (amaftei)'s avatar Alex Maftei (amaftei) Committed by David S. Miller

sfc: move reset workqueue code

Small functions doing work that will be common, related to reset
workqueue management.
Signed-off-by: default avatarAlexandru-Mihai Maftei <amaftei@solarflare.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent b1940451
# SPDX-License-Identifier: GPL-2.0 # SPDX-License-Identifier: GPL-2.0
sfc-y += efx.o nic.o farch.o siena.o ef10.o tx.o rx.o \ sfc-y += efx.o efx_common.o nic.o \
farch.o siena.o ef10.o \
tx.o rx.o \
selftest.o ethtool.o ptp.o tx_tso.o \ selftest.o ethtool.o ptp.o tx_tso.o \
mcdi.o mcdi_port.o mcdi_mon.o mcdi.o mcdi_port.o \
mcdi_mon.o
sfc-$(CONFIG_SFC_MTD) += mtd.o sfc-$(CONFIG_SFC_MTD) += mtd.o
sfc-$(CONFIG_SFC_SRIOV) += sriov.o siena_sriov.o ef10_sriov.o sfc-$(CONFIG_SFC_SRIOV) += sriov.o siena_sriov.o ef10_sriov.o
......
...@@ -108,12 +108,6 @@ void efx_get_udp_tunnel_type_name(u16 type, char *buf, size_t buflen) ...@@ -108,12 +108,6 @@ void efx_get_udp_tunnel_type_name(u16 type, char *buf, size_t buflen)
snprintf(buf, buflen, "type %d", type); snprintf(buf, buflen, "type %d", type);
} }
/* Reset workqueue. If any NIC has a hardware failure then a reset will be
* queued onto this work queue. This is not a per-nic work queue, because
* efx_reset_work() acquires the rtnl lock, so resets are naturally serialised.
*/
static struct workqueue_struct *reset_workqueue;
/* How often and how many times to poll for a reset while waiting for a /* How often and how many times to poll for a reset while waiting for a
* BIST that another function started to complete. * BIST that another function started to complete.
*/ */
...@@ -3106,7 +3100,7 @@ void efx_schedule_reset(struct efx_nic *efx, enum reset_type type) ...@@ -3106,7 +3100,7 @@ void efx_schedule_reset(struct efx_nic *efx, enum reset_type type)
* reset is scheduled. So switch back to poll'd MCDI completions. */ * reset is scheduled. So switch back to poll'd MCDI completions. */
efx_mcdi_mode_poll(efx); efx_mcdi_mode_poll(efx);
queue_work(reset_workqueue, &efx->reset_work); efx_queue_reset_work(efx);
} }
/************************************************************************** /**************************************************************************
...@@ -3492,7 +3486,7 @@ static void efx_pci_remove_main(struct efx_nic *efx) ...@@ -3492,7 +3486,7 @@ static void efx_pci_remove_main(struct efx_nic *efx)
* are not READY. * are not READY.
*/ */
BUG_ON(efx->state == STATE_READY); BUG_ON(efx->state == STATE_READY);
cancel_work_sync(&efx->reset_work); efx_flush_reset_workqueue(efx);
efx_disable_interrupts(efx); efx_disable_interrupts(efx);
efx_clear_interrupt_affinity(efx); efx_clear_interrupt_affinity(efx);
...@@ -3878,7 +3872,7 @@ static int efx_pm_thaw(struct device *dev) ...@@ -3878,7 +3872,7 @@ static int efx_pm_thaw(struct device *dev)
rtnl_unlock(); rtnl_unlock();
/* Reschedule any quenched resets scheduled during efx_pm_freeze() */ /* Reschedule any quenched resets scheduled during efx_pm_freeze() */
queue_work(reset_workqueue, &efx->reset_work); efx_queue_reset_work(efx);
return 0; return 0;
...@@ -4077,11 +4071,9 @@ static int __init efx_init_module(void) ...@@ -4077,11 +4071,9 @@ static int __init efx_init_module(void)
goto err_sriov; goto err_sriov;
#endif #endif
reset_workqueue = create_singlethread_workqueue("sfc_reset"); rc = efx_create_reset_workqueue();
if (!reset_workqueue) { if (rc)
rc = -ENOMEM;
goto err_reset; goto err_reset;
}
rc = pci_register_driver(&efx_pci_driver); rc = pci_register_driver(&efx_pci_driver);
if (rc < 0) if (rc < 0)
...@@ -4090,7 +4082,7 @@ static int __init efx_init_module(void) ...@@ -4090,7 +4082,7 @@ static int __init efx_init_module(void)
return 0; return 0;
err_pci: err_pci:
destroy_workqueue(reset_workqueue); efx_destroy_reset_workqueue();
err_reset: err_reset:
#ifdef CONFIG_SFC_SRIOV #ifdef CONFIG_SFC_SRIOV
efx_fini_sriov(); efx_fini_sriov();
...@@ -4106,7 +4098,7 @@ static void __exit efx_exit_module(void) ...@@ -4106,7 +4098,7 @@ static void __exit efx_exit_module(void)
printk(KERN_INFO "Solarflare NET driver unloading\n"); printk(KERN_INFO "Solarflare NET driver unloading\n");
pci_unregister_driver(&efx_pci_driver); pci_unregister_driver(&efx_pci_driver);
destroy_workqueue(reset_workqueue); efx_destroy_reset_workqueue();
#ifdef CONFIG_SFC_SRIOV #ifdef CONFIG_SFC_SRIOV
efx_fini_sriov(); efx_fini_sriov();
#endif #endif
......
// SPDX-License-Identifier: GPL-2.0-only
/****************************************************************************
* Driver for Solarflare network controllers and boards
* Copyright 2018 Solarflare Communications Inc.
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 as published
* by the Free Software Foundation, incorporated herein by reference.
*/
#include "net_driver.h"
#include <linux/module.h>
#include <linux/netdevice.h>
#include "efx_common.h"
#include "efx_channels.h"
#include "efx.h"
#include "mcdi.h"
#include "selftest.h"
#include "rx_common.h"
#include "tx_common.h"
#include "nic.h"
#include "io.h"
#include "mcdi_pcol.h"
/* Reset workqueue. If any NIC has a hardware failure then a reset will be
* queued onto this work queue. This is not a per-nic work queue, because
* efx_reset_work() acquires the rtnl lock, so resets are naturally serialised.
*/
static struct workqueue_struct *reset_workqueue;
int efx_create_reset_workqueue(void)
{
reset_workqueue = create_singlethread_workqueue("sfc_reset");
if (!reset_workqueue) {
printk(KERN_ERR "Failed to create reset workqueue\n");
return -ENOMEM;
}
return 0;
}
void efx_queue_reset_work(struct efx_nic *efx)
{
queue_work(reset_workqueue, &efx->reset_work);
}
void efx_flush_reset_workqueue(struct efx_nic *efx)
{
cancel_work_sync(&efx->reset_work);
}
void efx_destroy_reset_workqueue(void)
{
if (reset_workqueue) {
destroy_workqueue(reset_workqueue);
reset_workqueue = NULL;
}
}
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment