Commit a269913c authored by Larry Finger's avatar Larry Finger Committed by John W. Linville

rtlwifi: Rework rtl_lps_leave() and rtl_lps_enter() to use work queue

In commit a5ffbe0a, some of the calls to rtl_lps_leave() were switched
to be called from a work queue to avoid a scheduling while atomic bug.
This patch converts the remaining calls to use the work queue. In
addition, the call to rtl_lps_enter() is also switched to the work
queue. None of these newly converted calls had triggered the bug (yet),
but this change make all of them fit a single pattern.
Signed-off-by: default avatarLarry Finger <Larry.Finger@lwfinger.net>
Cc: jcheung@suse.com
Cc: machen@suse.com
Cc: mmarek@suse.cz
Cc: zhiyuan_yang@realsil.com.cn
Cc: page_he@realsil.com.cn
Signed-off-by: default avatarJohn W. Linville <linville@tuxdriver.com>
parent 3a16b412
...@@ -1088,8 +1088,9 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx) ...@@ -1088,8 +1088,9 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx)
is_tx ? "Tx" : "Rx"); is_tx ? "Tx" : "Rx");
if (is_tx) { if (is_tx) {
rtlpriv->enter_ps = false;
schedule_work(&rtlpriv-> schedule_work(&rtlpriv->
works.lps_leave_work); works.lps_change_work);
ppsc->last_delaylps_stamp_jiffies = ppsc->last_delaylps_stamp_jiffies =
jiffies; jiffies;
} }
...@@ -1099,7 +1100,8 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx) ...@@ -1099,7 +1100,8 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx)
} }
} else if (ETH_P_ARP == ether_type) { } else if (ETH_P_ARP == ether_type) {
if (is_tx) { if (is_tx) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
ppsc->last_delaylps_stamp_jiffies = jiffies; ppsc->last_delaylps_stamp_jiffies = jiffies;
} }
...@@ -1109,7 +1111,8 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx) ...@@ -1109,7 +1111,8 @@ u8 rtl_is_special_data(struct ieee80211_hw *hw, struct sk_buff *skb, u8 is_tx)
"802.1X %s EAPOL pkt!!\n", is_tx ? "Tx" : "Rx"); "802.1X %s EAPOL pkt!!\n", is_tx ? "Tx" : "Rx");
if (is_tx) { if (is_tx) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
ppsc->last_delaylps_stamp_jiffies = jiffies; ppsc->last_delaylps_stamp_jiffies = jiffies;
} }
...@@ -1318,7 +1321,6 @@ void rtl_watchdog_wq_callback(void *data) ...@@ -1318,7 +1321,6 @@ void rtl_watchdog_wq_callback(void *data)
u32 aver_tx_cnt_inperiod = 0; u32 aver_tx_cnt_inperiod = 0;
u32 aver_tidtx_inperiod[MAX_TID_COUNT] = {0}; u32 aver_tidtx_inperiod[MAX_TID_COUNT] = {0};
u32 tidtx_inp4eriod[MAX_TID_COUNT] = {0}; u32 tidtx_inp4eriod[MAX_TID_COUNT] = {0};
bool enter_ps = false;
if (is_hal_stop(rtlhal)) if (is_hal_stop(rtlhal))
return; return;
...@@ -1400,15 +1402,12 @@ void rtl_watchdog_wq_callback(void *data) ...@@ -1400,15 +1402,12 @@ void rtl_watchdog_wq_callback(void *data)
if (((rtlpriv->link_info.num_rx_inperiod + if (((rtlpriv->link_info.num_rx_inperiod +
rtlpriv->link_info.num_tx_inperiod) > 8) || rtlpriv->link_info.num_tx_inperiod) > 8) ||
(rtlpriv->link_info.num_rx_inperiod > 2)) (rtlpriv->link_info.num_rx_inperiod > 2))
enter_ps = false; rtlpriv->enter_ps = true;
else else
enter_ps = true; rtlpriv->enter_ps = false;
/* LeisurePS only work in infra mode. */ /* LeisurePS only work in infra mode. */
if (enter_ps) schedule_work(&rtlpriv->works.lps_change_work);
rtl_lps_enter(hw);
else
schedule_work(&rtlpriv->works.lps_leave_work);
} }
rtlpriv->link_info.num_rx_inperiod = 0; rtlpriv->link_info.num_rx_inperiod = 0;
......
...@@ -742,8 +742,10 @@ static void rtl_op_bss_info_changed(struct ieee80211_hw *hw, ...@@ -742,8 +742,10 @@ static void rtl_op_bss_info_changed(struct ieee80211_hw *hw,
RT_TRACE(rtlpriv, COMP_MAC80211, DBG_DMESG, RT_TRACE(rtlpriv, COMP_MAC80211, DBG_DMESG,
"BSS_CHANGED_ASSOC\n"); "BSS_CHANGED_ASSOC\n");
} else { } else {
if (mac->link_state == MAC80211_LINKED) if (mac->link_state == MAC80211_LINKED) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
}
if (ppsc->p2p_ps_info.p2p_ps_mode > P2P_PS_NONE) if (ppsc->p2p_ps_info.p2p_ps_mode > P2P_PS_NONE)
rtl_p2p_ps_cmd(hw, P2P_PS_DISABLE); rtl_p2p_ps_cmd(hw, P2P_PS_DISABLE);
...@@ -1018,7 +1020,8 @@ static void rtl_op_sw_scan_start(struct ieee80211_hw *hw) ...@@ -1018,7 +1020,8 @@ static void rtl_op_sw_scan_start(struct ieee80211_hw *hw)
rtlpriv->cfg->ops->chk_switch_dmdp(hw); rtlpriv->cfg->ops->chk_switch_dmdp(hw);
} }
if (mac->link_state == MAC80211_LINKED) { if (mac->link_state == MAC80211_LINKED) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
mac->link_state = MAC80211_LINKED_SCANNING; mac->link_state = MAC80211_LINKED_SCANNING;
} else { } else {
rtl_ips_nic_on(hw); rtl_ips_nic_on(hw);
......
...@@ -654,7 +654,8 @@ static void _rtl_pci_tx_isr(struct ieee80211_hw *hw, int prio) ...@@ -654,7 +654,8 @@ static void _rtl_pci_tx_isr(struct ieee80211_hw *hw, int prio)
if (((rtlpriv->link_info.num_rx_inperiod + if (((rtlpriv->link_info.num_rx_inperiod +
rtlpriv->link_info.num_tx_inperiod) > 8) || rtlpriv->link_info.num_tx_inperiod) > 8) ||
(rtlpriv->link_info.num_rx_inperiod > 2)) { (rtlpriv->link_info.num_rx_inperiod > 2)) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
} }
} }
...@@ -785,7 +786,8 @@ static void _rtl_pci_rx_interrupt(struct ieee80211_hw *hw) ...@@ -785,7 +786,8 @@ static void _rtl_pci_rx_interrupt(struct ieee80211_hw *hw)
if (((rtlpriv->link_info.num_rx_inperiod + if (((rtlpriv->link_info.num_rx_inperiod +
rtlpriv->link_info.num_tx_inperiod) > 8) || rtlpriv->link_info.num_tx_inperiod) > 8) ||
(rtlpriv->link_info.num_rx_inperiod > 2)) { (rtlpriv->link_info.num_rx_inperiod > 2)) {
schedule_work(&rtlpriv->works.lps_leave_work); rtlpriv->enter_ps = false;
schedule_work(&rtlpriv->works.lps_change_work);
} }
dev_kfree_skb_any(skb); dev_kfree_skb_any(skb);
...@@ -1005,12 +1007,16 @@ static void _rtl_pci_prepare_bcn_tasklet(struct ieee80211_hw *hw) ...@@ -1005,12 +1007,16 @@ static void _rtl_pci_prepare_bcn_tasklet(struct ieee80211_hw *hw)
return; return;
} }
static void rtl_lps_leave_work_callback(struct work_struct *work) static void rtl_lps_change_work_callback(struct work_struct *work)
{ {
struct rtl_works *rtlworks = struct rtl_works *rtlworks =
container_of(work, struct rtl_works, lps_leave_work); container_of(work, struct rtl_works, lps_change_work);
struct ieee80211_hw *hw = rtlworks->hw; struct ieee80211_hw *hw = rtlworks->hw;
struct rtl_priv *rtlpriv = rtl_priv(hw);
if (rtlpriv->enter_ps)
rtl_lps_enter(hw);
else
rtl_lps_leave(hw); rtl_lps_leave(hw);
} }
...@@ -1075,7 +1081,8 @@ static void _rtl_pci_init_struct(struct ieee80211_hw *hw, ...@@ -1075,7 +1081,8 @@ static void _rtl_pci_init_struct(struct ieee80211_hw *hw,
tasklet_init(&rtlpriv->works.irq_prepare_bcn_tasklet, tasklet_init(&rtlpriv->works.irq_prepare_bcn_tasklet,
(void (*)(unsigned long))_rtl_pci_prepare_bcn_tasklet, (void (*)(unsigned long))_rtl_pci_prepare_bcn_tasklet,
(unsigned long)hw); (unsigned long)hw);
INIT_WORK(&rtlpriv->works.lps_leave_work, rtl_lps_leave_work_callback); INIT_WORK(&rtlpriv->works.lps_change_work,
rtl_lps_change_work_callback);
} }
static int _rtl_pci_init_tx_ring(struct ieee80211_hw *hw, static int _rtl_pci_init_tx_ring(struct ieee80211_hw *hw,
...@@ -1561,7 +1568,7 @@ static void rtl_pci_deinit(struct ieee80211_hw *hw) ...@@ -1561,7 +1568,7 @@ static void rtl_pci_deinit(struct ieee80211_hw *hw)
synchronize_irq(rtlpci->pdev->irq); synchronize_irq(rtlpci->pdev->irq);
tasklet_kill(&rtlpriv->works.irq_tasklet); tasklet_kill(&rtlpriv->works.irq_tasklet);
cancel_work_sync(&rtlpriv->works.lps_leave_work); cancel_work_sync(&rtlpriv->works.lps_change_work);
flush_workqueue(rtlpriv->works.rtl_wq); flush_workqueue(rtlpriv->works.rtl_wq);
destroy_workqueue(rtlpriv->works.rtl_wq); destroy_workqueue(rtlpriv->works.rtl_wq);
...@@ -1636,7 +1643,7 @@ static void rtl_pci_stop(struct ieee80211_hw *hw) ...@@ -1636,7 +1643,7 @@ static void rtl_pci_stop(struct ieee80211_hw *hw)
set_hal_stop(rtlhal); set_hal_stop(rtlhal);
rtlpriv->cfg->ops->disable_interrupt(hw); rtlpriv->cfg->ops->disable_interrupt(hw);
cancel_work_sync(&rtlpriv->works.lps_leave_work); cancel_work_sync(&rtlpriv->works.lps_change_work);
spin_lock_irqsave(&rtlpriv->locks.rf_ps_lock, flags); spin_lock_irqsave(&rtlpriv->locks.rf_ps_lock, flags);
while (ppsc->rfchange_inprogress) { while (ppsc->rfchange_inprogress) {
......
...@@ -1796,7 +1796,7 @@ struct rtl_works { ...@@ -1796,7 +1796,7 @@ struct rtl_works {
struct delayed_work ps_rfon_wq; struct delayed_work ps_rfon_wq;
struct delayed_work fwevt_wq; struct delayed_work fwevt_wq;
struct work_struct lps_leave_work; struct work_struct lps_change_work;
}; };
struct rtl_debug { struct rtl_debug {
...@@ -1966,6 +1966,7 @@ struct rtl_priv { ...@@ -1966,6 +1966,7 @@ struct rtl_priv {
bool bt_operation_on; bool bt_operation_on;
}; };
}; };
bool enter_ps; /* true when entering PS */
/*This must be the last item so /*This must be the last item so
that it points to the data allocated that it points to the data allocated
......
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