Commit f203af70 authored by Somnath Kotur's avatar Somnath Kotur Committed by David S. Miller

be2net: Schedule/Destroy worker thread in probe()/remove() rather than open()/close()

When async mcc compls are rcvd on an i/f that is down (and so interrupts are disabled)
they just lie unprocessed in the compl queue.The compl queue can eventually get filled
up and cause the BE to lock up.The fix is to use be_worker to reap mcc compls when the
i/f is down.be_worker is now launched in be_probe() and canceled in be_remove().
Signed-off-by: default avatarSomnath Kotur <somnath.kotur@emulex.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 853dc2e0
...@@ -1802,6 +1802,20 @@ static void be_worker(struct work_struct *work) ...@@ -1802,6 +1802,20 @@ static void be_worker(struct work_struct *work)
struct be_rx_obj *rxo; struct be_rx_obj *rxo;
int i; int i;
/* when interrupts are not yet enabled, just reap any pending
* mcc completions */
if (!netif_running(adapter->netdev)) {
int mcc_compl, status = 0;
mcc_compl = be_process_mcc(adapter, &status);
if (mcc_compl) {
struct be_mcc_obj *mcc_obj = &adapter->mcc_obj;
be_cq_notify(adapter, mcc_obj->cq.id, false, mcc_compl);
}
goto reschedule;
}
if (!adapter->stats_ioctl_sent) if (!adapter->stats_ioctl_sent)
be_cmd_get_stats(adapter, &adapter->stats_cmd); be_cmd_get_stats(adapter, &adapter->stats_cmd);
...@@ -1820,6 +1834,7 @@ static void be_worker(struct work_struct *work) ...@@ -1820,6 +1834,7 @@ static void be_worker(struct work_struct *work)
if (!adapter->ue_detected) if (!adapter->ue_detected)
be_detect_dump_ue(adapter); be_detect_dump_ue(adapter);
reschedule:
schedule_delayed_work(&adapter->work, msecs_to_jiffies(1000)); schedule_delayed_work(&adapter->work, msecs_to_jiffies(1000));
} }
...@@ -2015,8 +2030,6 @@ static int be_close(struct net_device *netdev) ...@@ -2015,8 +2030,6 @@ static int be_close(struct net_device *netdev)
struct be_eq_obj *tx_eq = &adapter->tx_eq; struct be_eq_obj *tx_eq = &adapter->tx_eq;
int vec, i; int vec, i;
cancel_delayed_work_sync(&adapter->work);
be_async_mcc_disable(adapter); be_async_mcc_disable(adapter);
netif_stop_queue(netdev); netif_stop_queue(netdev);
...@@ -2081,8 +2094,6 @@ static int be_open(struct net_device *netdev) ...@@ -2081,8 +2094,6 @@ static int be_open(struct net_device *netdev)
/* Now that interrupts are on we can process async mcc */ /* Now that interrupts are on we can process async mcc */
be_async_mcc_enable(adapter); be_async_mcc_enable(adapter);
schedule_delayed_work(&adapter->work, msecs_to_jiffies(100));
status = be_cmd_link_status_query(adapter, &link_up, &mac_speed, status = be_cmd_link_status_query(adapter, &link_up, &mac_speed,
&link_speed); &link_speed);
if (status) if (status)
...@@ -2707,6 +2718,8 @@ static void __devexit be_remove(struct pci_dev *pdev) ...@@ -2707,6 +2718,8 @@ static void __devexit be_remove(struct pci_dev *pdev)
if (!adapter) if (!adapter)
return; return;
cancel_delayed_work_sync(&adapter->work);
unregister_netdev(adapter->netdev); unregister_netdev(adapter->netdev);
be_clear(adapter); be_clear(adapter);
...@@ -2863,6 +2876,7 @@ static int __devinit be_probe(struct pci_dev *pdev, ...@@ -2863,6 +2876,7 @@ static int __devinit be_probe(struct pci_dev *pdev,
netif_carrier_off(netdev); netif_carrier_off(netdev);
dev_info(&pdev->dev, "%s port %d\n", nic_name(pdev), adapter->port_num); dev_info(&pdev->dev, "%s port %d\n", nic_name(pdev), adapter->port_num);
schedule_delayed_work(&adapter->work, msecs_to_jiffies(100));
return 0; return 0;
unsetup: unsetup:
......
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