Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 2abdc0b7 authored by David Woodhouse's avatar David Woodhouse Committed by David S. Miller
Browse files

libertas: kill internal tx queue for PS mode



It was buggy as hell anyway, since it was just spewing packets at the
device when it wasn't necessarily ready for them (in the USB case, while
the URB was still busy).

We could probably do with a better way of flushing packets to the device
_immediately_, before we stick it back into sleep mode. But we can no
longer just dequeue packets directly, it seems.

Signed-off-by: default avatarDavid Woodhouse <dwmw2@infradead.org>
Signed-off-by: default avatarJohn W. Linville <linville@tuxdriver.com>
parent 020bb19e
Loading
Loading
Loading
Loading
+0 −2
Original line number Diff line number Diff line
@@ -62,8 +62,6 @@ void lbs_ps_sleep(struct lbs_private *priv, int wait_option);
void lbs_ps_confirm_sleep(struct lbs_private *priv, u16 psmode);
void lbs_ps_wakeup(struct lbs_private *priv, int wait_option);

void lbs_tx_runqueue(struct lbs_private *priv);

struct chan_freq_power *lbs_find_cfp_by_band_and_channel(
	struct lbs_private *priv,
	u8 band,
+0 −5
Original line number Diff line number Diff line
@@ -197,11 +197,6 @@ struct lbs_private {
	/** Timers */
	struct timer_list command_timer;

	/* TX queue used in PS mode */
	spinlock_t txqueue_lock;
	struct sk_buff *tx_queue_ps[NR_TX_QUEUE];
	unsigned int tx_queue_idx;

	u8 hisregcpy;

	/** current ssid/bssid related parameters*/
+0 −6
Original line number Diff line number Diff line
@@ -914,8 +914,6 @@ static int lbs_thread(void *data)
		 */
		if (!list_empty(&priv->cmdpendingq))
			wake_up_all(&priv->cmd_pending);

		lbs_tx_runqueue(priv);
	}

	del_timer(&priv->command_timer);
@@ -1072,10 +1070,6 @@ static int lbs_init_adapter(struct lbs_private *priv)

	mutex_init(&priv->lock);

	memset(&priv->tx_queue_ps, 0, NR_TX_QUEUE*sizeof(struct sk_buff*));
	priv->tx_queue_idx = 0;
	spin_lock_init(&priv->txqueue_lock);

	setup_timer(&priv->command_timer, command_timer_fn,
	            (unsigned long)priv);

+3 −37
Original line number Diff line number Diff line
@@ -164,41 +164,6 @@ static int SendSinglePacket(struct lbs_private *priv, struct sk_buff *skb)
}


void lbs_tx_runqueue(struct lbs_private *priv)
{
	int i;

	spin_lock(&priv->txqueue_lock);
	for (i = 0; i < priv->tx_queue_idx; i++) {
		struct sk_buff *skb = priv->tx_queue_ps[i];
		spin_unlock(&priv->txqueue_lock);
		SendSinglePacket(priv, skb);
		spin_lock(&priv->txqueue_lock);
	}
	priv->tx_queue_idx = 0;
	spin_unlock(&priv->txqueue_lock);
}

static void lbs_tx_queue(struct lbs_private *priv, struct sk_buff *skb)
{

	spin_lock(&priv->txqueue_lock);

	WARN_ON(priv->tx_queue_idx >= NR_TX_QUEUE);
	priv->tx_queue_ps[priv->tx_queue_idx++] = skb;
	if (priv->tx_queue_idx == NR_TX_QUEUE) {
		netif_stop_queue(priv->dev);
		if (priv->mesh_dev)
			netif_stop_queue(priv->mesh_dev);
	} else {
		netif_start_queue(priv->dev);
		if (priv->mesh_dev)
			netif_start_queue(priv->mesh_dev);
	}

	spin_unlock(&priv->txqueue_lock);
}

/**
 *  @brief This function checks the conditions and sends packet to IF
 *  layer if everything is ok.
@@ -221,8 +186,9 @@ int lbs_process_tx(struct lbs_private *priv, struct sk_buff *skb)

	if ((priv->psstate == PS_STATE_SLEEP) ||
	    (priv->psstate == PS_STATE_PRE_SLEEP)) {
		lbs_tx_queue(priv, skb);
		return ret;
		lbs_pr_alert("TX error: packet xmit in %ssleep mode\n",
			     priv->psstate == PS_STATE_SLEEP?"":"pre-");
		goto done;
	}

	ret = SendSinglePacket(priv, skb);