tx.c 18.1 KB
Newer Older
L
Luciano Coelho 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
/*
 * This file is part of wl1271
 *
 * Copyright (C) 2009 Nokia Corporation
 *
 * Contact: Luciano Coelho <luciano.coelho@nokia.com>
 *
 * 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.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA
 *
 */

#include <linux/kernel.h>
#include <linux/module.h>
26
#include <linux/etherdevice.h>
L
Luciano Coelho 已提交
27

S
Shahar Levi 已提交
28 29 30 31 32
#include "wl12xx.h"
#include "io.h"
#include "reg.h"
#include "ps.h"
#include "tx.h"
L
Luciano Coelho 已提交
33

34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
static int wl1271_set_default_wep_key(struct wl1271 *wl, u8 id)
{
	int ret;
	bool is_ap = (wl->bss_type == BSS_TYPE_AP_BSS);

	if (is_ap)
		ret = wl1271_cmd_set_ap_default_wep_key(wl, id);
	else
		ret = wl1271_cmd_set_sta_default_wep_key(wl, id);

	if (ret < 0)
		return ret;

	wl1271_debug(DEBUG_CRYPT, "default wep key idx: %d", (int)id);
	return 0;
}

51
static int wl1271_alloc_tx_id(struct wl1271 *wl, struct sk_buff *skb)
L
Luciano Coelho 已提交
52
{
53 54 55 56 57 58 59 60 61 62 63
	int id;

	id = find_first_zero_bit(wl->tx_frames_map, ACX_TX_DESCRIPTORS);
	if (id >= ACX_TX_DESCRIPTORS)
		return -EBUSY;

	__set_bit(id, wl->tx_frames_map);
	wl->tx_frames[id] = skb;
	wl->tx_frames_cnt++;
	return id;
}
L
Luciano Coelho 已提交
64

65 66 67 68 69 70
static void wl1271_free_tx_id(struct wl1271 *wl, int id)
{
	if (__test_and_clear_bit(id, wl->tx_frames_map)) {
		wl->tx_frames[id] = NULL;
		wl->tx_frames_cnt--;
	}
L
Luciano Coelho 已提交
71 72
}

73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88
static void wl1271_tx_ap_update_inconnection_sta(struct wl1271 *wl,
						 struct sk_buff *skb)
{
	struct ieee80211_hdr *hdr;

	/*
	 * add the station to the known list before transmitting the
	 * authentication response. this way it won't get de-authed by FW
	 * when transmitting too soon.
	 */
	hdr = (struct ieee80211_hdr *)(skb->data +
				       sizeof(struct wl1271_tx_hw_descr));
	if (ieee80211_is_auth(hdr->frame_control))
		wl1271_acx_set_inconnection_sta(wl, hdr->addr1);
}

89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109
u8 wl1271_tx_get_hlid(struct sk_buff *skb)
{
	struct ieee80211_tx_info *control = IEEE80211_SKB_CB(skb);

	if (control->control.sta) {
		struct wl1271_station *wl_sta;

		wl_sta = (struct wl1271_station *)
				control->control.sta->drv_priv;
		return wl_sta->hlid;
	} else {
		struct ieee80211_hdr *hdr;

		hdr = (struct ieee80211_hdr *)skb->data;
		if (ieee80211_is_mgmt(hdr->frame_control))
			return WL1271_AP_GLOBAL_HLID;
		else
			return WL1271_AP_BROADCAST_HLID;
	}
}

110 111
static int wl1271_tx_allocate(struct wl1271 *wl, struct sk_buff *skb, u32 extra,
				u32 buf_offset)
L
Luciano Coelho 已提交
112 113 114
{
	struct wl1271_tx_hw_descr *desc;
	u32 total_len = skb->len + sizeof(struct wl1271_tx_hw_descr) + extra;
115
	u32 total_blocks;
L
Luciano Coelho 已提交
116 117
	int id, ret = -EBUSY;

118
	if (buf_offset + total_len > WL1271_AGGR_BUFFER_SIZE)
I
Ido Yariv 已提交
119
		return -EAGAIN;
120

L
Luciano Coelho 已提交
121
	/* allocate free identifier for the packet */
122
	id = wl1271_alloc_tx_id(wl, skb);
L
Luciano Coelho 已提交
123 124 125 126 127
	if (id < 0)
		return id;

	/* approximate the number of blocks required for this packet
	   in the firmware */
128 129
	total_blocks = total_len + TX_HW_BLOCK_SIZE - 1;
	total_blocks = total_blocks / TX_HW_BLOCK_SIZE + TX_HW_BLOCK_SPARE;
L
Luciano Coelho 已提交
130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
	if (total_blocks <= wl->tx_blocks_available) {
		desc = (struct wl1271_tx_hw_descr *)skb_push(
			skb, total_len - skb->len);

		desc->extra_mem_blocks = TX_HW_BLOCK_SPARE;
		desc->total_mem_blocks = total_blocks;
		desc->id = id;

		wl->tx_blocks_available -= total_blocks;

		ret = 0;

		wl1271_debug(DEBUG_TX,
			     "tx_allocate: size: %d, blocks: %d, id: %d",
			     total_len, total_blocks, id);
145
	} else {
146
		wl1271_free_tx_id(wl, id);
147
	}
L
Luciano Coelho 已提交
148 149 150 151

	return ret;
}

152
static void wl1271_tx_fill_hdr(struct wl1271 *wl, struct sk_buff *skb,
L
Luciano Coelho 已提交
153 154
			      u32 extra, struct ieee80211_tx_info *control)
{
155
	struct timespec ts;
L
Luciano Coelho 已提交
156
	struct wl1271_tx_hw_descr *desc;
157
	int pad, ac, rate_idx;
158
	s64 hosttime;
L
Luciano Coelho 已提交
159
	u16 tx_attr;
L
Luciano Coelho 已提交
160 161 162

	desc = (struct wl1271_tx_hw_descr *) skb->data;

163 164 165 166
	/* relocate space for security header */
	if (extra) {
		void *framestart = skb->data + sizeof(*desc);
		u16 fc = *(u16 *)(framestart + extra);
L
Luciano Coelho 已提交
167
		int hdrlen = ieee80211_hdrlen(cpu_to_le16(fc));
168 169 170
		memmove(framestart, framestart + extra, hdrlen);
	}

L
Luciano Coelho 已提交
171
	/* configure packet life time */
172 173 174
	getnstimeofday(&ts);
	hosttime = (timespec_to_ns(&ts) >> 10);
	desc->start_time = cpu_to_le32(hosttime - wl->time_offset);
175 176 177 178 179

	if (wl->bss_type != BSS_TYPE_AP_BSS)
		desc->life_time = cpu_to_le16(TX_HW_MGMT_PKT_LIFETIME_TU);
	else
		desc->life_time = cpu_to_le16(TX_HW_AP_MODE_PKT_LIFETIME_TU);
L
Luciano Coelho 已提交
180 181

	/* configure the tx attributes */
L
Luciano Coelho 已提交
182
	tx_attr = wl->session_counter << TX_HW_ATTR_OFST_SESSION_COUNTER;
K
Kalle Valo 已提交
183

184
	/* queue (we use same identifiers for tid's and ac's */
K
Kalle Valo 已提交
185
	ac = wl1271_tx_get_queue(skb_get_queue_mapping(skb));
186
	desc->tid = ac;
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221

	if (wl->bss_type != BSS_TYPE_AP_BSS) {
		desc->aid = TX_HW_DEFAULT_AID;

		/* if the packets are destined for AP (have a STA entry)
		   send them with AP rate policies, otherwise use default
		   basic rates */
		if (control->control.sta)
			rate_idx = ACX_TX_AP_FULL_RATE;
		else
			rate_idx = ACX_TX_BASIC_RATE;
	} else {
		if (control->control.sta) {
			struct wl1271_station *wl_sta;

			wl_sta = (struct wl1271_station *)
					control->control.sta->drv_priv;
			desc->hlid = wl_sta->hlid;
			rate_idx = ac;
		} else {
			struct ieee80211_hdr *hdr;

			hdr = (struct ieee80211_hdr *)
						(skb->data + sizeof(*desc));
			if (ieee80211_is_mgmt(hdr->frame_control)) {
				desc->hlid = WL1271_AP_GLOBAL_HLID;
				rate_idx = ACX_TX_AP_MODE_MGMT_RATE;
			} else {
				desc->hlid = WL1271_AP_BROADCAST_HLID;
				rate_idx = ACX_TX_AP_MODE_BCST_RATE;
			}
		}
	}

	tx_attr |= rate_idx << TX_HW_ATTR_OFST_RATE_POLICY;
L
Luciano Coelho 已提交
222 223 224
	desc->reserved = 0;

	/* align the length (and store in terms of words) */
225
	pad = ALIGN(skb->len, WL1271_TX_ALIGN_TO);
L
Luciano Coelho 已提交
226
	desc->length = cpu_to_le16(pad >> 2);
L
Luciano Coelho 已提交
227 228 229

	/* calculate number of padding bytes */
	pad = pad - skb->len;
L
Luciano Coelho 已提交
230 231 232
	tx_attr |= pad << TX_HW_ATTR_OFST_LAST_WORD_PAD;

	desc->tx_attr = cpu_to_le16(tx_attr);
L
Luciano Coelho 已提交
233

234
	wl1271_debug(DEBUG_TX, "tx_fill_hdr: pad: %d hlid: %d "
E
Eliad Peller 已提交
235 236 237
		"tx_attr: 0x%x len: %d life: %d mem: %d", pad, desc->hlid,
		le16_to_cpu(desc->tx_attr), le16_to_cpu(desc->length),
		le16_to_cpu(desc->life_time), desc->total_mem_blocks);
L
Luciano Coelho 已提交
238 239 240
}

/* caller must hold wl->mutex */
241 242
static int wl1271_prepare_tx_frame(struct wl1271 *wl, struct sk_buff *skb,
							u32 buf_offset)
L
Luciano Coelho 已提交
243 244 245 246
{
	struct ieee80211_tx_info *info;
	u32 extra = 0;
	int ret = 0;
247
	u32 total_len;
L
Luciano Coelho 已提交
248 249 250 251 252 253 254

	if (!skb)
		return -EINVAL;

	info = IEEE80211_SKB_CB(skb);

	if (info->control.hw_key &&
255
	    info->control.hw_key->cipher == WLAN_CIPHER_SUITE_TKIP)
L
Luciano Coelho 已提交
256 257 258
		extra = WL1271_TKIP_IV_SPACE;

	if (info->control.hw_key) {
259 260 261 262 263 264
		bool is_wep;
		u8 idx = info->control.hw_key->hw_key_idx;
		u32 cipher = info->control.hw_key->cipher;

		is_wep = (cipher == WLAN_CIPHER_SUITE_WEP40) ||
			 (cipher == WLAN_CIPHER_SUITE_WEP104);
L
Luciano Coelho 已提交
265

266 267
		if (unlikely(is_wep && wl->default_key != idx)) {
			ret = wl1271_set_default_wep_key(wl, idx);
L
Luciano Coelho 已提交
268 269
			if (ret < 0)
				return ret;
J
Juuso Oikarinen 已提交
270
			wl->default_key = idx;
L
Luciano Coelho 已提交
271 272 273
		}
	}

274
	ret = wl1271_tx_allocate(wl, skb, extra, buf_offset);
L
Luciano Coelho 已提交
275 276 277
	if (ret < 0)
		return ret;

278 279 280
	if (wl->bss_type == BSS_TYPE_AP_BSS)
		wl1271_tx_ap_update_inconnection_sta(wl, skb);

281
	wl1271_tx_fill_hdr(wl, skb, extra, info);
L
Luciano Coelho 已提交
282

283 284 285 286 287
	/*
	 * The length of each packet is stored in terms of words. Thus, we must
	 * pad the skb data to make sure its length is aligned.
	 * The number of padding bytes is computed and set in wl1271_tx_fill_hdr
	 */
288
	total_len = ALIGN(skb->len, WL1271_TX_ALIGN_TO);
289 290
	memcpy(wl->aggr_buf + buf_offset, skb->data, skb->len);
	memset(wl->aggr_buf + buf_offset + skb->len, 0, total_len - skb->len);
L
Luciano Coelho 已提交
291

292
	return total_len;
L
Luciano Coelho 已提交
293 294
}

295
u32 wl1271_tx_enabled_rates_get(struct wl1271 *wl, u32 rate_set)
296 297 298 299 300 301 302 303 304 305 306 307
{
	struct ieee80211_supported_band *band;
	u32 enabled_rates = 0;
	int bit;

	band = wl->hw->wiphy->bands[wl->band];
	for (bit = 0; bit < band->n_bitrates; bit++) {
		if (rate_set & 0x1)
			enabled_rates |= band->bitrates[bit].hw_value;
		rate_set >>= 1;
	}

S
Shahar Levi 已提交
308
#ifdef CONFIG_WL12XX_HT
309 310 311 312 313 314 315 316 317 318
	/* MCS rates indication are on bits 16 - 23 */
	rate_set >>= HW_HT_RATES_OFFSET - band->n_bitrates;

	for (bit = 0; bit < 8; bit++) {
		if (rate_set & 0x1)
			enabled_rates |= (CONF_HW_BIT_RATE_MCS_0 << bit);
		rate_set >>= 1;
	}
#endif

319 320 321
	return enabled_rates;
}

322
void wl1271_handle_tx_low_watermark(struct wl1271 *wl)
323 324 325 326
{
	unsigned long flags;

	if (test_bit(WL1271_FLAG_TX_QUEUE_STOPPED, &wl->flags) &&
327
	    wl->tx_queue_count <= WL1271_TX_QUEUE_LOW_WATERMARK) {
328 329 330 331 332 333 334 335
		/* firmware buffer has space, restart queues */
		spin_lock_irqsave(&wl->wl_lock, flags);
		ieee80211_wake_queues(wl->hw);
		clear_bit(WL1271_FLAG_TX_QUEUE_STOPPED, &wl->flags);
		spin_unlock_irqrestore(&wl->wl_lock, flags);
	}
}

336
static struct sk_buff *wl1271_sta_skb_dequeue(struct wl1271 *wl)
337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361
{
	struct sk_buff *skb = NULL;
	unsigned long flags;

	skb = skb_dequeue(&wl->tx_queue[CONF_TX_AC_VO]);
	if (skb)
		goto out;
	skb = skb_dequeue(&wl->tx_queue[CONF_TX_AC_VI]);
	if (skb)
		goto out;
	skb = skb_dequeue(&wl->tx_queue[CONF_TX_AC_BE]);
	if (skb)
		goto out;
	skb = skb_dequeue(&wl->tx_queue[CONF_TX_AC_BK]);

out:
	if (skb) {
		spin_lock_irqsave(&wl->wl_lock, flags);
		wl->tx_queue_count--;
		spin_unlock_irqrestore(&wl->wl_lock, flags);
	}

	return skb;
}

362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409
static struct sk_buff *wl1271_ap_skb_dequeue(struct wl1271 *wl)
{
	struct sk_buff *skb = NULL;
	unsigned long flags;
	int i, h, start_hlid;

	/* start from the link after the last one */
	start_hlid = (wl->last_tx_hlid + 1) % AP_MAX_LINKS;

	/* dequeue according to AC, round robin on each link */
	for (i = 0; i < AP_MAX_LINKS; i++) {
		h = (start_hlid + i) % AP_MAX_LINKS;

		skb = skb_dequeue(&wl->links[h].tx_queue[CONF_TX_AC_VO]);
		if (skb)
			goto out;
		skb = skb_dequeue(&wl->links[h].tx_queue[CONF_TX_AC_VI]);
		if (skb)
			goto out;
		skb = skb_dequeue(&wl->links[h].tx_queue[CONF_TX_AC_BE]);
		if (skb)
			goto out;
		skb = skb_dequeue(&wl->links[h].tx_queue[CONF_TX_AC_BK]);
		if (skb)
			goto out;
	}

out:
	if (skb) {
		wl->last_tx_hlid = h;
		spin_lock_irqsave(&wl->wl_lock, flags);
		wl->tx_queue_count--;
		spin_unlock_irqrestore(&wl->wl_lock, flags);
	} else {
		wl->last_tx_hlid = 0;
	}

	return skb;
}

static struct sk_buff *wl1271_skb_dequeue(struct wl1271 *wl)
{
	if (wl->bss_type == BSS_TYPE_AP_BSS)
		return wl1271_ap_skb_dequeue(wl);

	return wl1271_sta_skb_dequeue(wl);
}

410 411 412 413 414
static void wl1271_skb_queue_head(struct wl1271 *wl, struct sk_buff *skb)
{
	unsigned long flags;
	int q = wl1271_tx_get_queue(skb_get_queue_mapping(skb));

415 416 417 418 419 420 421 422 423 424
	if (wl->bss_type == BSS_TYPE_AP_BSS) {
		u8 hlid = wl1271_tx_get_hlid(skb);
		skb_queue_head(&wl->links[hlid].tx_queue[q], skb);

		/* make sure we dequeue the same packet next time */
		wl->last_tx_hlid = (hlid + AP_MAX_LINKS - 1) % AP_MAX_LINKS;
	} else {
		skb_queue_head(&wl->tx_queue[q], skb);
	}

425 426 427 428 429
	spin_lock_irqsave(&wl->wl_lock, flags);
	wl->tx_queue_count++;
	spin_unlock_irqrestore(&wl->wl_lock, flags);
}

I
Ido Yariv 已提交
430
void wl1271_tx_work_locked(struct wl1271 *wl)
L
Luciano Coelho 已提交
431 432 433
{
	struct sk_buff *skb;
	bool woken_up = false;
I
Ido Yariv 已提交
434 435
	u32 buf_offset = 0;
	bool sent_packets = false;
L
Luciano Coelho 已提交
436 437 438 439 440
	int ret;

	if (unlikely(wl->state == WL1271_STATE_OFF))
		goto out;

441
	while ((skb = wl1271_skb_dequeue(wl))) {
L
Luciano Coelho 已提交
442 443 444
		if (!woken_up) {
			ret = wl1271_ps_elp_wakeup(wl, false);
			if (ret < 0)
445
				goto out_ack;
L
Luciano Coelho 已提交
446 447 448
			woken_up = true;
		}

449
		ret = wl1271_prepare_tx_frame(wl, skb, buf_offset);
I
Ido Yariv 已提交
450
		if (ret == -EAGAIN) {
451
			/*
I
Ido Yariv 已提交
452 453 454
			 * Aggregation buffer is full.
			 * Flush buffer and try again.
			 */
455
			wl1271_skb_queue_head(wl, skb);
I
Ido Yariv 已提交
456
			wl1271_write(wl, WL1271_SLV_MEM_DATA, wl->aggr_buf,
457
				     buf_offset, true);
I
Ido Yariv 已提交
458 459 460 461 462 463
			sent_packets = true;
			buf_offset = 0;
			continue;
		} else if (ret == -EBUSY) {
			/*
			 * Firmware buffer is full.
464 465
			 * Queue back last skb, and stop aggregating.
			 */
466
			wl1271_skb_queue_head(wl, skb);
I
Ido Yariv 已提交
467 468
			/* No work left, avoid scheduling redundant tx work */
			set_bit(WL1271_FLAG_FW_TX_BUSY, &wl->flags);
469
			goto out_ack;
L
Luciano Coelho 已提交
470 471
		} else if (ret < 0) {
			dev_kfree_skb(skb);
472
			goto out_ack;
L
Luciano Coelho 已提交
473
		}
474 475
		buf_offset += ret;
		wl->tx_packets_count++;
L
Luciano Coelho 已提交
476 477
	}

478
out_ack:
479 480 481
	if (buf_offset) {
		wl1271_write(wl, WL1271_SLV_MEM_DATA, wl->aggr_buf,
				buf_offset, true);
I
Ido Yariv 已提交
482 483 484
		sent_packets = true;
	}
	if (sent_packets) {
485
		/* interrupt the firmware with the new packets */
486
		wl1271_write32(wl, WL1271_HOST_WR_ACCESS, wl->tx_packets_count);
487
		wl1271_handle_tx_low_watermark(wl);
488
	}
489

L
Luciano Coelho 已提交
490 491 492
out:
	if (woken_up)
		wl1271_ps_elp_sleep(wl);
I
Ido Yariv 已提交
493
}
L
Luciano Coelho 已提交
494

I
Ido Yariv 已提交
495 496 497 498 499 500
void wl1271_tx_work(struct work_struct *work)
{
	struct wl1271 *wl = container_of(work, struct wl1271, tx_work);

	mutex_lock(&wl->mutex);
	wl1271_tx_work_locked(wl);
L
Luciano Coelho 已提交
501 502 503 504 505 506 507 508 509
	mutex_unlock(&wl->mutex);
}

static void wl1271_tx_complete_packet(struct wl1271 *wl,
				      struct wl1271_tx_hw_res_descr *result)
{
	struct ieee80211_tx_info *info;
	struct sk_buff *skb;
	int id = result->id;
J
Juuso Oikarinen 已提交
510 511
	int rate = -1;
	u8 retries = 0;
L
Luciano Coelho 已提交
512 513

	/* check for id legality */
514
	if (unlikely(id >= ACX_TX_DESCRIPTORS || wl->tx_frames[id] == NULL)) {
L
Luciano Coelho 已提交
515 516 517 518 519 520 521
		wl1271_warning("TX result illegal id: %d", id);
		return;
	}

	skb = wl->tx_frames[id];
	info = IEEE80211_SKB_CB(skb);

J
Juuso Oikarinen 已提交
522 523 524
	/* update the TX status info */
	if (result->status == TX_SUCCESS) {
		if (!(info->flags & IEEE80211_TX_CTL_NO_ACK))
L
Luciano Coelho 已提交
525
			info->flags |= IEEE80211_TX_STAT_ACK;
526
		rate = wl1271_rate_to_idx(result->rate_class_index, wl->band);
J
Juuso Oikarinen 已提交
527 528 529 530
		retries = result->ack_failures;
	} else if (result->status == TX_RETRY_EXCEEDED) {
		wl->stats.excessive_retries++;
		retries = result->ack_failures;
L
Luciano Coelho 已提交
531 532
	}

J
Juuso Oikarinen 已提交
533 534 535 536 537
	info->status.rates[0].idx = rate;
	info->status.rates[0].count = retries;
	info->status.rates[0].flags = 0;
	info->status.ack_signal = -1;

L
Luciano Coelho 已提交
538 539
	wl->stats.retry_count += result->ack_failures;

540
	/* update security sequence number */
541 542
	wl->tx_security_seq += (result->lsb_security_sequence_number -
				wl->tx_security_last_seq);
543 544
	wl->tx_security_last_seq = result->lsb_security_sequence_number;

545 546 547 548
	/* remove private header from packet */
	skb_pull(skb, sizeof(struct wl1271_tx_hw_descr));

	/* remove TKIP header space if present */
L
Luciano Coelho 已提交
549
	if (info->control.hw_key &&
550
	    info->control.hw_key->cipher == WLAN_CIPHER_SUITE_TKIP) {
551 552 553 554
		int hdrlen = ieee80211_get_hdrlen_from_skb(skb);
		memmove(skb->data + WL1271_TKIP_IV_SPACE, skb->data, hdrlen);
		skb_pull(skb, WL1271_TKIP_IV_SPACE);
	}
L
Luciano Coelho 已提交
555 556 557 558 559 560 561 562

	wl1271_debug(DEBUG_TX, "tx status id %u skb 0x%p failures %u rate 0x%x"
		     " status 0x%x",
		     result->id, skb, result->ack_failures,
		     result->rate_class_index, result->status);

	/* return the packet to the stack */
	ieee80211_tx_status(wl->hw, skb);
563
	wl1271_free_tx_id(wl, result->id);
L
Luciano Coelho 已提交
564 565 566
}

/* Called upon reception of a TX complete interrupt */
567
void wl1271_tx_complete(struct wl1271 *wl)
L
Luciano Coelho 已提交
568 569 570
{
	struct wl1271_acx_mem_map *memmap =
		(struct wl1271_acx_mem_map *)wl->target_mem_map;
571
	u32 count, fw_counter;
L
Luciano Coelho 已提交
572 573 574
	u32 i;

	/* read the tx results from the chipset */
T
Teemu Paasikivi 已提交
575 576
	wl1271_read(wl, le32_to_cpu(memmap->tx_result),
		    wl->tx_res_if, sizeof(*wl->tx_res_if), false);
577 578 579 580 581 582 583 584
	fw_counter = le32_to_cpu(wl->tx_res_if->tx_result_fw_counter);

	/* write host counter to chipset (to ack) */
	wl1271_write32(wl, le32_to_cpu(memmap->tx_result) +
		       offsetof(struct wl1271_tx_hw_res_if,
				tx_result_host_counter), fw_counter);

	count = fw_counter - wl->tx_results_count;
585
	wl1271_debug(DEBUG_TX, "tx_complete received, packets: %d", count);
L
Luciano Coelho 已提交
586 587

	/* verify that the result buffer is not getting overrun */
588
	if (unlikely(count > TX_HW_RESULT_QUEUE_LEN))
L
Luciano Coelho 已提交
589 590 591 592 593 594 595 596 597 598 599 600 601 602 603
		wl1271_warning("TX result overflow from chipset: %d", count);

	/* process the results */
	for (i = 0; i < count; i++) {
		struct wl1271_tx_hw_res_descr *result;
		u8 offset = wl->tx_results_count & TX_HW_RESULT_QUEUE_LEN_MASK;

		/* process the packet */
		result =  &(wl->tx_res_if->tx_results_queue[offset]);
		wl1271_tx_complete_packet(wl, result);

		wl->tx_results_count++;
	}
}

604 605 606 607 608
void wl1271_tx_reset_link_queues(struct wl1271 *wl, u8 hlid)
{
	struct sk_buff *skb;
	int i, total = 0;
	unsigned long flags;
609
	struct ieee80211_tx_info *info;
610 611 612 613

	for (i = 0; i < NUM_TX_QUEUES; i++) {
		while ((skb = skb_dequeue(&wl->links[hlid].tx_queue[i]))) {
			wl1271_debug(DEBUG_TX, "link freeing skb 0x%p", skb);
614 615 616
			info = IEEE80211_SKB_CB(skb);
			info->status.rates[0].idx = -1;
			info->status.rates[0].count = 0;
617 618 619 620 621 622 623 624 625 626 627 628
			ieee80211_tx_status(wl->hw, skb);
			total++;
		}
	}

	spin_lock_irqsave(&wl->wl_lock, flags);
	wl->tx_queue_count -= total;
	spin_unlock_irqrestore(&wl->wl_lock, flags);

	wl1271_handle_tx_low_watermark(wl);
}

L
Luciano Coelho 已提交
629
/* caller must hold wl->mutex */
630
void wl1271_tx_reset(struct wl1271 *wl)
L
Luciano Coelho 已提交
631 632 633
{
	int i;
	struct sk_buff *skb;
634
	struct ieee80211_tx_info *info;
L
Luciano Coelho 已提交
635 636

	/* TX failure */
637 638 639 640 641 642 643 644 645 646
	if (wl->bss_type == BSS_TYPE_AP_BSS) {
		for (i = 0; i < AP_MAX_LINKS; i++)
			wl1271_tx_reset_link_queues(wl, i);

		wl->last_tx_hlid = 0;
	} else {
		for (i = 0; i < NUM_TX_QUEUES; i++) {
			while ((skb = skb_dequeue(&wl->tx_queue[i]))) {
				wl1271_debug(DEBUG_TX, "freeing skb 0x%p",
					     skb);
647 648 649
				info = IEEE80211_SKB_CB(skb);
				info->status.rates[0].idx = -1;
				info->status.rates[0].count = 0;
650 651
				ieee80211_tx_status(wl->hw, skb);
			}
652
		}
L
Luciano Coelho 已提交
653
	}
654

655
	wl->tx_queue_count = 0;
L
Luciano Coelho 已提交
656

657 658 659 660
	/*
	 * Make sure the driver is at a consistent state, in case this
	 * function is called from a context other than interface removal.
	 */
661
	wl1271_handle_tx_low_watermark(wl);
662

J
Juuso Oikarinen 已提交
663
	for (i = 0; i < ACX_TX_DESCRIPTORS; i++)
L
Luciano Coelho 已提交
664 665
		if (wl->tx_frames[i] != NULL) {
			skb = wl->tx_frames[i];
666
			wl1271_free_tx_id(wl, i);
667
			wl1271_debug(DEBUG_TX, "freeing skb 0x%p", skb);
668 669 670
			info = IEEE80211_SKB_CB(skb);
			info->status.rates[0].idx = -1;
			info->status.rates[0].count = 0;
J
Juuso Oikarinen 已提交
671
			ieee80211_tx_status(wl->hw, skb);
L
Luciano Coelho 已提交
672
		}
673 674 675 676 677 678 679 680 681 682 683 684
}

#define WL1271_TX_FLUSH_TIMEOUT 500000

/* caller must *NOT* hold wl->mutex */
void wl1271_tx_flush(struct wl1271 *wl)
{
	unsigned long timeout;
	timeout = jiffies + usecs_to_jiffies(WL1271_TX_FLUSH_TIMEOUT);

	while (!time_after(jiffies, timeout)) {
		mutex_lock(&wl->mutex);
685 686
		wl1271_debug(DEBUG_TX, "flushing tx buffer: %d %d",
			     wl->tx_frames_cnt, wl->tx_queue_count);
687
		if ((wl->tx_frames_cnt == 0) && (wl->tx_queue_count == 0)) {
688 689 690 691 692 693 694 695
			mutex_unlock(&wl->mutex);
			return;
		}
		mutex_unlock(&wl->mutex);
		msleep(1);
	}

	wl1271_warning("Unable to flush all TX buffers, timed out.");
L
Luciano Coelho 已提交
696
}
A
Arik Nemtsov 已提交
697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714

u32 wl1271_tx_min_rate_get(struct wl1271 *wl)
{
	int i;
	u32 rate = 0;

	if (!wl->basic_rate_set) {
		WARN_ON(1);
		wl->basic_rate_set = wl->conf.tx.basic_rate;
	}

	for (i = 0; !rate; i++) {
		if ((wl->basic_rate_set >> i) & 0x1)
			rate = 1 << i;
	}

	return rate;
}