[deliverable/linux.git] / drivers / net / wireless / rsi / rsi_91x_core.c

/**
 * Copyright (c) 2014 Redpine Signals Inc.
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#include "rsi_mgmt.h"
#include "rsi_common.h"

/**
 * rsi_determine_min_weight_queue() - This function determines the queue with
 *				      the min weight.
 * @common: Pointer to the driver private structure.
 *
 * Return: q_num: Corresponding queue number.
 */
static u8 rsi_determine_min_weight_queue(struct rsi_common *common)
{
	struct wmm_qinfo *tx_qinfo = common->tx_qinfo;
	u32 q_len = 0;
	u8 ii = 0;

	for (ii = 0; ii < NUM_EDCA_QUEUES; ii++) {
		q_len = skb_queue_len(&common->tx_queue[ii]);
		if ((tx_qinfo[ii].pkt_contended) && q_len) {
			common->min_weight = tx_qinfo[ii].weight;
			break;
		}
	}
	return ii;
}

/**
 * rsi_recalculate_weights() - This function recalculates the weights
 *			       corresponding to each queue.
 * @common: Pointer to the driver private structure.
 *
 * Return: recontend_queue bool variable
 */
static bool rsi_recalculate_weights(struct rsi_common *common)
{
	struct wmm_qinfo *tx_qinfo = common->tx_qinfo;
	bool recontend_queue = false;
	u8 ii = 0;
	u32 q_len = 0;

	for (ii = 0; ii < NUM_EDCA_QUEUES; ii++) {
		q_len = skb_queue_len(&common->tx_queue[ii]);
		/* Check for the need of contention */
		if (q_len) {
			if (tx_qinfo[ii].pkt_contended) {
				tx_qinfo[ii].weight =
				((tx_qinfo[ii].weight > common->min_weight) ?
				 tx_qinfo[ii].weight - common->min_weight : 0);
			} else {
				tx_qinfo[ii].pkt_contended = 1;
				tx_qinfo[ii].weight = tx_qinfo[ii].wme_params;
				recontend_queue = true;
			}
		} else { /* No packets so no contention */
			tx_qinfo[ii].weight = 0;
			tx_qinfo[ii].pkt_contended = 0;
		}
	}

	return recontend_queue;
}

/**
 * rsi_get_num_pkts_dequeue() - This function determines the number of
 *		                packets to be dequeued based on the number
 *			        of bytes calculated using txop.
 *
 * @common: Pointer to the driver private structure.
 * @q_num: the queue from which pkts have to be dequeued
 *
 * Return: pkt_num: Number of pkts to be dequeued.
 */
static u32 rsi_get_num_pkts_dequeue(struct rsi_common *common, u8 q_num)
{
	struct rsi_hw *adapter = common->priv;
	struct sk_buff *skb;
	u32 pkt_cnt = 0;
	s16 txop = common->tx_qinfo[q_num].txop * 32;
	struct ieee80211_rate rate;

	rate.bitrate = RSI_RATE_MCS0 * 5 * 10; /* Convert to Kbps */
	if (q_num == VI_Q)
		txop = ((txop << 5) / 80);

	if (skb_queue_len(&common->tx_queue[q_num]))
		skb = skb_peek(&common->tx_queue[q_num]);
	else
		return 0;

	do {
		txop -= ieee80211_generic_frame_duration(adapter->hw,
							 adapter->vifs[0],
							 common->band,
							 skb->len, &rate);
		pkt_cnt += 1;
		/*checking if pkts are still there*/
		if (skb_queue_len(&common->tx_queue[q_num]) - pkt_cnt)
			skb = skb->next;
		else
			break;

	} while (txop > 0);

	return pkt_cnt;
}

/**
 * rsi_core_determine_hal_queue() - This function determines the queue from
 *				    which packet has to be dequeued.
 * @common: Pointer to the driver private structure.
 *
 * Return: q_num: Corresponding queue number on success.
 */
static u8 rsi_core_determine_hal_queue(struct rsi_common *common)
{
	bool recontend_queue = false;
	u32 q_len = 0;
	u8 q_num = INVALID_QUEUE;
	u8 ii = 0;

	if (skb_queue_len(&common->tx_queue[MGMT_SOFT_Q])) {
		if (!common->mgmt_q_block)
			q_num = MGMT_SOFT_Q;
		return q_num;
	}

	if (common->hw_data_qs_blocked)
		return q_num;

	if (common->pkt_cnt != 0) {
		--common->pkt_cnt;
		return common->selected_qnum;
	}

get_queue_num:
	recontend_queue = false;

	q_num = rsi_determine_min_weight_queue(common);

	ii = q_num;

	/* Selecting the queue with least back off */
	for (; ii < NUM_EDCA_QUEUES; ii++) {
		q_len = skb_queue_len(&common->tx_queue[ii]);
		if (((common->tx_qinfo[ii].pkt_contended) &&
		     (common->tx_qinfo[ii].weight < common->min_weight)) &&
		      q_len) {
			common->min_weight = common->tx_qinfo[ii].weight;
			q_num = ii;
		}
	}

	if (q_num < NUM_EDCA_QUEUES)
		common->tx_qinfo[q_num].pkt_contended = 0;

	/* Adjust the back off values for all queues again */
	recontend_queue = rsi_recalculate_weights(common);

	q_len = skb_queue_len(&common->tx_queue[q_num]);
	if (!q_len) {
		/* If any queues are freshly contended and the selected queue
		 * doesn't have any packets
		 * then get the queue number again with fresh values
		 */
		if (recontend_queue)
			goto get_queue_num;

		q_num = INVALID_QUEUE;
		return q_num;
	}

	common->selected_qnum = q_num;
	q_len = skb_queue_len(&common->tx_queue[q_num]);

	if (q_num == VO_Q || q_num == VI_Q) {
		common->pkt_cnt = rsi_get_num_pkts_dequeue(common, q_num);
		common->pkt_cnt -= 1;
	};

	return q_num;
}

/**
 * rsi_core_queue_pkt() - This functions enqueues the packet to the queue
 *			  specified by the queue number.
 * @common: Pointer to the driver private structure.
 * @skb: Pointer to the socket buffer structure.
 *
 * Return: None.
 */
static void rsi_core_queue_pkt(struct rsi_common *common,
			       struct sk_buff *skb)
{
	u8 q_num = skb->priority;
	if (q_num >= NUM_SOFT_QUEUES) {
		rsi_dbg(ERR_ZONE, "%s: Invalid Queue Number: q_num = %d\n",
			__func__, q_num);
		dev_kfree_skb(skb);
		return;
	}

	skb_queue_tail(&common->tx_queue[q_num], skb);
}

/**
 * rsi_core_dequeue_pkt() - This functions dequeues the packet from the queue
 *			    specified by the queue number.
 * @common: Pointer to the driver private structure.
 * @q_num: Queue number.
 *
 * Return: Pointer to sk_buff structure.
 */
static struct sk_buff *rsi_core_dequeue_pkt(struct rsi_common *common,
					    u8 q_num)
{
	if (q_num >= NUM_SOFT_QUEUES) {
		rsi_dbg(ERR_ZONE, "%s: Invalid Queue Number: q_num = %d\n",
			__func__, q_num);
		return NULL;
	}

	return skb_dequeue(&common->tx_queue[q_num]);
}

/**
 * rsi_core_qos_processor() - This function is used to determine the wmm queue
 *			      based on the backoff procedure. Data packets are
 *			      dequeued from the selected hal queue and sent to
 *			      the below layers.
 * @common: Pointer to the driver private structure.
 *
 * Return: None.
 */
void rsi_core_qos_processor(struct rsi_common *common)
{
	struct rsi_hw *adapter = common->priv;
	struct sk_buff *skb;
	unsigned long tstamp_1, tstamp_2;
	u8 q_num;
	int status;

	tstamp_1 = jiffies;
	while (1) {
		q_num = rsi_core_determine_hal_queue(common);
		rsi_dbg(DATA_TX_ZONE,
			"%s: Queue number = %d\n", __func__, q_num);

		if (q_num == INVALID_QUEUE) {
			rsi_dbg(DATA_TX_ZONE, "%s: No More Pkt\n", __func__);
			break;
		}

		mutex_lock(&common->tx_rxlock);

		status = adapter->check_hw_queue_status(adapter, q_num);
		if ((status <= 0)) {
			mutex_unlock(&common->tx_rxlock);
			break;
		}

		if ((q_num < MGMT_SOFT_Q) &&
		    ((skb_queue_len(&common->tx_queue[q_num])) <=
		      MIN_DATA_QUEUE_WATER_MARK)) {
			if (ieee80211_queue_stopped(adapter->hw, WME_AC(q_num)))
				ieee80211_wake_queue(adapter->hw,
						     WME_AC(q_num));
		}

		skb = rsi_core_dequeue_pkt(common, q_num);
		if (skb == NULL) {
			rsi_dbg(ERR_ZONE, "skb null\n");
			mutex_unlock(&common->tx_rxlock);
			break;
		}

		if (q_num == MGMT_SOFT_Q)
			status = rsi_send_mgmt_pkt(common, skb);
		else
			status = rsi_send_data_pkt(common, skb);

		if (status) {
			mutex_unlock(&common->tx_rxlock);
			break;
		}

		common->tx_stats.total_tx_pkt_send[q_num]++;

		tstamp_2 = jiffies;
		mutex_unlock(&common->tx_rxlock);

		if (tstamp_2 > tstamp_1 + (300 * HZ / 1000))
			schedule();
	}
}

/**
 * rsi_core_xmit() - This function transmits the packets received from mac80211
 * @common: Pointer to the driver private structure.
 * @skb: Pointer to the socket buffer structure.
 *
 * Return: None.
 */
void rsi_core_xmit(struct rsi_common *common, struct sk_buff *skb)
{
	struct rsi_hw *adapter = common->priv;
	struct ieee80211_tx_info *info;
	struct skb_info *tx_params;
	struct ieee80211_hdr *tmp_hdr = NULL;
	u8 q_num, tid = 0;

	if ((!skb) || (!skb->len)) {
		rsi_dbg(ERR_ZONE, "%s: Null skb/zero Length packet\n",
			__func__);
		goto xmit_fail;
	}
	info = IEEE80211_SKB_CB(skb);
	tx_params = (struct skb_info *)info->driver_data;
	tmp_hdr = (struct ieee80211_hdr *)&skb->data[0];

	if (common->fsm_state != FSM_MAC_INIT_DONE) {
		rsi_dbg(ERR_ZONE, "%s: FSM state not open\n", __func__);
		goto xmit_fail;
	}

	if ((ieee80211_is_mgmt(tmp_hdr->frame_control)) ||
	    (ieee80211_is_ctl(tmp_hdr->frame_control))) {
		q_num = MGMT_SOFT_Q;
		skb->priority = q_num;
	} else {
		if (ieee80211_is_data_qos(tmp_hdr->frame_control)) {
			tid = (skb->data[24] & IEEE80211_QOS_TID);
			skb->priority = TID_TO_WME_AC(tid);
		} else {
			tid = IEEE80211_NONQOS_TID;
			skb->priority = BE_Q;
		}
		q_num = skb->priority;
		tx_params->tid = tid;
		tx_params->sta_id = 0;
	}

	if ((q_num != MGMT_SOFT_Q) &&
	    ((skb_queue_len(&common->tx_queue[q_num]) + 1) >=
	     DATA_QUEUE_WATER_MARK)) {
		rsi_dbg(ERR_ZONE, "%s: sw queue full\n", __func__);
		if (!ieee80211_queue_stopped(adapter->hw, WME_AC(q_num)))
			ieee80211_stop_queue(adapter->hw, WME_AC(q_num));
		rsi_set_event(&common->tx_thread.event);
		goto xmit_fail;
	}

	rsi_core_queue_pkt(common, skb);
	rsi_dbg(DATA_TX_ZONE, "%s: ===> Scheduling TX thead <===\n", __func__);
	rsi_set_event(&common->tx_thread.event);

	return;

xmit_fail:
	rsi_dbg(ERR_ZONE, "%s: Failed to queue packet\n", __func__);
	/* Dropping pkt here */
	ieee80211_free_txskb(common->priv->hw, skb);
}
Commit	Line	Data
dad0d04f FF	1	/**
	2	* Copyright (c) 2014 Redpine Signals Inc.
	3	*
	4	* Permission to use, copy, modify, and/or distribute this software for any
	5	* purpose with or without fee is hereby granted, provided that the above
	6	* copyright notice and this permission notice appear in all copies.
	7	*
	8	* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
	9	* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
	10	* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
	11	* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
	12	* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
	13	* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
	14	* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
	15	*/
	16
	17	#include "rsi_mgmt.h"
	18	#include "rsi_common.h"
	19
	20	/**
	21	* rsi_determine_min_weight_queue() - This function determines the queue with
	22	* the min weight.
	23	* @common: Pointer to the driver private structure.
	24	*
	25	* Return: q_num: Corresponding queue number.
	26	*/
	27	static u8 rsi_determine_min_weight_queue(struct rsi_common *common)
	28	{
	29	struct wmm_qinfo *tx_qinfo = common->tx_qinfo;
	30	u32 q_len = 0;
	31	u8 ii = 0;
	32
	33	for (ii = 0; ii < NUM_EDCA_QUEUES; ii++) {
	34	q_len = skb_queue_len(&common->tx_queue[ii]);
	35	if ((tx_qinfo[ii].pkt_contended) && q_len) {
	36	common->min_weight = tx_qinfo[ii].weight;
	37	break;
	38	}
	39	}
	40	return ii;
	41	}
	42
	43	/**
	44	* rsi_recalculate_weights() - This function recalculates the weights
	45	* corresponding to each queue.
	46	* @common: Pointer to the driver private structure.
	47	*
	48	* Return: recontend_queue bool variable
	49	*/
	50	static bool rsi_recalculate_weights(struct rsi_common *common)
	51	{
	52	struct wmm_qinfo *tx_qinfo = common->tx_qinfo;
	53	bool recontend_queue = false;
	54	u8 ii = 0;
	55	u32 q_len = 0;
	56
	57	for (ii = 0; ii < NUM_EDCA_QUEUES; ii++) {
	58	q_len = skb_queue_len(&common->tx_queue[ii]);
	59	/* Check for the need of contention */
	60	if (q_len) {
	61	if (tx_qinfo[ii].pkt_contended) {
	62	tx_qinfo[ii].weight =
	63	((tx_qinfo[ii].weight > common->min_weight) ?
	64	tx_qinfo[ii].weight - common->min_weight : 0);
65	} else {
66	tx_qinfo[ii].pkt_contended = 1;
67	tx_qinfo[ii].weight = tx_qinfo[ii].wme_params;
68	recontend_queue = true;
69	}
70	} else { /* No packets so no contention */
71	tx_qinfo[ii].weight = 0;
72	tx_qinfo[ii].pkt_contended = 0;
73	}
74	}
75
76	return recontend_queue;
77	}
78
360accb0 JM	79	/**
	80	* rsi_get_num_pkts_dequeue() - This function determines the number of
	81	* packets to be dequeued based on the number
	82	* of bytes calculated using txop.
	83	*
	84	* @common: Pointer to the driver private structure.
	85	* @q_num: the queue from which pkts have to be dequeued
	86	*
	87	* Return: pkt_num: Number of pkts to be dequeued.
	88	*/
	89	static u32 rsi_get_num_pkts_dequeue(struct rsi_common *common, u8 q_num)
	90	{
	91	struct rsi_hw *adapter = common->priv;
	92	struct sk_buff *skb;
	93	u32 pkt_cnt = 0;
	94	s16 txop = common->tx_qinfo[q_num].txop * 32;
	95	struct ieee80211_rate rate;
	96
	97	rate.bitrate = RSI_RATE_MCS0 * 5 * 10; /* Convert to Kbps */
	98	if (q_num == VI_Q)
	99	txop = ((txop << 5) / 80);
	100
	101	if (skb_queue_len(&common->tx_queue[q_num]))
	102	skb = skb_peek(&common->tx_queue[q_num]);
	103	else
	104	return 0;
	105
	106	do {
	107	txop -= ieee80211_generic_frame_duration(adapter->hw,
	108	adapter->vifs[0],
	109	common->band,
	110	skb->len, &rate);
	111	pkt_cnt += 1;
	112	/checking if pkts are still there/
	113	if (skb_queue_len(&common->tx_queue[q_num]) - pkt_cnt)
	114	skb = skb->next;
	115	else
	116	break;
	117
	118	} while (txop > 0);
	119
	120	return pkt_cnt;
	121	}
	122
dad0d04f FF	123	/**
	124	* rsi_core_determine_hal_queue() - This function determines the queue from
	125	* which packet has to be dequeued.
	126	* @common: Pointer to the driver private structure.
	127	*
	128	* Return: q_num: Corresponding queue number on success.
	129	*/
	130	static u8 rsi_core_determine_hal_queue(struct rsi_common *common)
	131	{
	132	bool recontend_queue = false;
	133	u32 q_len = 0;
	134	u8 q_num = INVALID_QUEUE;
360accb0	135	u8 ii = 0;
dad0d04f FF	136
	137	if (skb_queue_len(&common->tx_queue[MGMT_SOFT_Q])) {
	138	if (!common->mgmt_q_block)
	139	q_num = MGMT_SOFT_Q;
	140	return q_num;
	141	}
	142
360accb0 JM	143	if (common->hw_data_qs_blocked)
	144	return q_num;
	145
dad0d04f FF	146	if (common->pkt_cnt != 0) {
	147	--common->pkt_cnt;
	148	return common->selected_qnum;
	149	}
	150
	151	get_queue_num:
dad0d04f FF	152	recontend_queue = false;
	153
	154	q_num = rsi_determine_min_weight_queue(common);
5156fd24	155
dad0d04f FF	156	ii = q_num;
	157
	158	/* Selecting the queue with least back off */
	159	for (; ii < NUM_EDCA_QUEUES; ii++) {
360accb0	160	q_len = skb_queue_len(&common->tx_queue[ii]);
dad0d04f	161	if (((common->tx_qinfo[ii].pkt_contended) &&
360accb0 JM	162	(common->tx_qinfo[ii].weight < common->min_weight)) &&
	163	q_len) {
	164	common->min_weight = common->tx_qinfo[ii].weight;
dad0d04f FF	165	q_num = ii;
	166	}
	167	}
	168
5156fd24 FF	169	if (q_num < NUM_EDCA_QUEUES)
	170	common->tx_qinfo[q_num].pkt_contended = 0;
	171
dad0d04f FF	172	/* Adjust the back off values for all queues again */
	173	recontend_queue = rsi_recalculate_weights(common);
	174
	175	q_len = skb_queue_len(&common->tx_queue[q_num]);
	176	if (!q_len) {
	177	/* If any queues are freshly contended and the selected queue
	178	* doesn't have any packets
	179	* then get the queue number again with fresh values
	180	*/
	181	if (recontend_queue)
	182	goto get_queue_num;
	183
	184	q_num = INVALID_QUEUE;
	185	return q_num;
	186	}
	187
	188	common->selected_qnum = q_num;
	189	q_len = skb_queue_len(&common->tx_queue[q_num]);
	190
360accb0 JM	191	if (q_num == VO_Q \|\| q_num == VI_Q) {
	192	common->pkt_cnt = rsi_get_num_pkts_dequeue(common, q_num);
	193	common->pkt_cnt -= 1;
	194	};
dad0d04f FF	195
	196	return q_num;
	197	}
	198
	199	/**
	200	* rsi_core_queue_pkt() - This functions enqueues the packet to the queue
	201	* specified by the queue number.
	202	* @common: Pointer to the driver private structure.
	203	* @skb: Pointer to the socket buffer structure.
	204	*
	205	* Return: None.
	206	*/
	207	static void rsi_core_queue_pkt(struct rsi_common *common,
	208	struct sk_buff *skb)
	209	{
	210	u8 q_num = skb->priority;
	211	if (q_num >= NUM_SOFT_QUEUES) {
	212	rsi_dbg(ERR_ZONE, "%s: Invalid Queue Number: q_num = %d\n",
	213	__func__, q_num);
	214	dev_kfree_skb(skb);
	215	return;
	216	}
	217
	218	skb_queue_tail(&common->tx_queue[q_num], skb);
	219	}
	220
	221	/**
	222	* rsi_core_dequeue_pkt() - This functions dequeues the packet from the queue
	223	* specified by the queue number.
	224	* @common: Pointer to the driver private structure.
	225	* @q_num: Queue number.
	226	*
	227	* Return: Pointer to sk_buff structure.
	228	*/
	229	static struct sk_buff rsi_core_dequeue_pkt(struct rsi_common common,
	230	u8 q_num)
	231	{
	232	if (q_num >= NUM_SOFT_QUEUES) {
	233	rsi_dbg(ERR_ZONE, "%s: Invalid Queue Number: q_num = %d\n",
	234	__func__, q_num);
	235	return NULL;
	236	}
	237
	238	return skb_dequeue(&common->tx_queue[q_num]);
	239	}
	240
	241	/**
	242	* rsi_core_qos_processor() - This function is used to determine the wmm queue
	243	* based on the backoff procedure. Data packets are
	244	* dequeued from the selected hal queue and sent to
	245	* the below layers.
	246	* @common: Pointer to the driver private structure.
	247	*
	248	* Return: None.
	249	*/
	250	void rsi_core_qos_processor(struct rsi_common *common)
	251	{
	252	struct rsi_hw *adapter = common->priv;
	253	struct sk_buff *skb;
	254	unsigned long tstamp_1, tstamp_2;
	255	u8 q_num;
	256	int status;
	257
	258	tstamp_1 = jiffies;
259	while (1) {
260	q_num = rsi_core_determine_hal_queue(common);
261	rsi_dbg(DATA_TX_ZONE,
262	"%s: Queue number = %d\n", __func__, q_num);
263
264	if (q_num == INVALID_QUEUE) {
265	rsi_dbg(DATA_TX_ZONE, "%s: No More Pkt\n", __func__);
266	break;
267	}
268
269	mutex_lock(&common->tx_rxlock);
270
271	status = adapter->check_hw_queue_status(adapter, q_num);
272	if ((status <= 0)) {
273	mutex_unlock(&common->tx_rxlock);
274	break;
275	}
276
277	if ((q_num < MGMT_SOFT_Q) &&
278	((skb_queue_len(&common->tx_queue[q_num])) <=
279	MIN_DATA_QUEUE_WATER_MARK)) {
280	if (ieee80211_queue_stopped(adapter->hw, WME_AC(q_num)))
281	ieee80211_wake_queue(adapter->hw,
282	WME_AC(q_num));
283	}
284
285	skb = rsi_core_dequeue_pkt(common, q_num);
286	if (skb == NULL) {
258587f9	287	rsi_dbg(ERR_ZONE, "skb null\n");
dad0d04f FF	288	mutex_unlock(&common->tx_rxlock);
	289	break;
	290	}
	291
	292	if (q_num == MGMT_SOFT_Q)
	293	status = rsi_send_mgmt_pkt(common, skb);
	294	else
	295	status = rsi_send_data_pkt(common, skb);
	296
	297	if (status) {
	298	mutex_unlock(&common->tx_rxlock);
	299	break;
	300	}
	301
	302	common->tx_stats.total_tx_pkt_send[q_num]++;
	303
	304	tstamp_2 = jiffies;
	305	mutex_unlock(&common->tx_rxlock);
	306
	307	if (tstamp_2 > tstamp_1 + (300 * HZ / 1000))
	308	schedule();
	309	}
	310	}
	311
	312	/**
	313	* rsi_core_xmit() - This function transmits the packets received from mac80211
	314	* @common: Pointer to the driver private structure.
	315	* @skb: Pointer to the socket buffer structure.
	316	*
	317	* Return: None.
	318	*/
	319	void rsi_core_xmit(struct rsi_common common, struct sk_buff skb)
	320	{
	321	struct rsi_hw *adapter = common->priv;
	322	struct ieee80211_tx_info *info;
	323	struct skb_info *tx_params;
	324	struct ieee80211_hdr *tmp_hdr = NULL;
	325	u8 q_num, tid = 0;
	326
	327	if ((!skb) \|\| (!skb->len)) {
	328	rsi_dbg(ERR_ZONE, "%s: Null skb/zero Length packet\n",
	329	__func__);
	330	goto xmit_fail;
	331	}
	332	info = IEEE80211_SKB_CB(skb);
	333	tx_params = (struct skb_info *)info->driver_data;
	334	tmp_hdr = (struct ieee80211_hdr *)&skb->data[0];
	335
	336	if (common->fsm_state != FSM_MAC_INIT_DONE) {
	337	rsi_dbg(ERR_ZONE, "%s: FSM state not open\n", __func__);
	338	goto xmit_fail;
	339	}
	340
	341	if ((ieee80211_is_mgmt(tmp_hdr->frame_control)) \|\|
	342	(ieee80211_is_ctl(tmp_hdr->frame_control))) {
	343	q_num = MGMT_SOFT_Q;
	344	skb->priority = q_num;
	345	} else {
	346	if (ieee80211_is_data_qos(tmp_hdr->frame_control)) {
	347	tid = (skb->data[24] & IEEE80211_QOS_TID);
	348	skb->priority = TID_TO_WME_AC(tid);
	349	} else {
	350	tid = IEEE80211_NONQOS_TID;
	351	skb->priority = BE_Q;
352	}
353	q_num = skb->priority;
354	tx_params->tid = tid;
355	tx_params->sta_id = 0;
356	}
357
358	if ((q_num != MGMT_SOFT_Q) &&
359	((skb_queue_len(&common->tx_queue[q_num]) + 1) >=
360	DATA_QUEUE_WATER_MARK)) {
258587f9	361	rsi_dbg(ERR_ZONE, "%s: sw queue full\n", __func__);
dad0d04f FF	362	if (!ieee80211_queue_stopped(adapter->hw, WME_AC(q_num)))
	363	ieee80211_stop_queue(adapter->hw, WME_AC(q_num));
	364	rsi_set_event(&common->tx_thread.event);
	365	goto xmit_fail;
	366	}
	367
	368	rsi_core_queue_pkt(common, skb);
	369	rsi_dbg(DATA_TX_ZONE, "%s: ===> Scheduling TX thead <===\n", __func__);
	370	rsi_set_event(&common->tx_thread.event);
	371
	372	return;
	373
	374	xmit_fail:
	375	rsi_dbg(ERR_ZONE, "%s: Failed to queue packet\n", __func__);
	376	/* Dropping pkt here */
	377	ieee80211_free_txskb(common->priv->hw, skb);
	378	}