Linux Audio

Check our new training course

Loading...
v3.1
   1/*
   2 * Copyright (c) 2010-2011 Atheros Communications 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 <asm/unaligned.h>
  18#include "htc.h"
  19
  20/* identify firmware images */
  21#define FIRMWARE_AR7010_1_1     "htc_7010.fw"
  22#define FIRMWARE_AR9271         "htc_9271.fw"
  23
  24MODULE_FIRMWARE(FIRMWARE_AR7010_1_1);
  25MODULE_FIRMWARE(FIRMWARE_AR9271);
  26
  27static struct usb_device_id ath9k_hif_usb_ids[] = {
  28	{ USB_DEVICE(0x0cf3, 0x9271) }, /* Atheros */
  29	{ USB_DEVICE(0x0cf3, 0x1006) }, /* Atheros */
  30	{ USB_DEVICE(0x0846, 0x9030) }, /* Netgear N150 */
  31	{ USB_DEVICE(0x07D1, 0x3A10) }, /* Dlink Wireless 150 */
  32	{ USB_DEVICE(0x13D3, 0x3327) }, /* Azurewave */
  33	{ USB_DEVICE(0x13D3, 0x3328) }, /* Azurewave */
  34	{ USB_DEVICE(0x13D3, 0x3346) }, /* IMC Networks */
  35	{ USB_DEVICE(0x13D3, 0x3348) }, /* Azurewave */
  36	{ USB_DEVICE(0x13D3, 0x3349) }, /* Azurewave */
  37	{ USB_DEVICE(0x13D3, 0x3350) }, /* Azurewave */
  38	{ USB_DEVICE(0x04CA, 0x4605) }, /* Liteon */
  39	{ USB_DEVICE(0x040D, 0x3801) }, /* VIA */
  40	{ USB_DEVICE(0x0cf3, 0xb003) }, /* Ubiquiti WifiStation Ext */
 
 
 
  41
  42	{ USB_DEVICE(0x0cf3, 0x7015),
  43	  .driver_info = AR9287_USB },  /* Atheros */
  44	{ USB_DEVICE(0x1668, 0x1200),
  45	  .driver_info = AR9287_USB },  /* Verizon */
  46
  47	{ USB_DEVICE(0x0cf3, 0x7010),
  48	  .driver_info = AR9280_USB },  /* Atheros */
  49	{ USB_DEVICE(0x0846, 0x9018),
  50	  .driver_info = AR9280_USB },  /* Netgear WNDA3200 */
  51	{ USB_DEVICE(0x083A, 0xA704),
  52	  .driver_info = AR9280_USB },  /* SMC Networks */
  53	{ USB_DEVICE(0x0411, 0x017f),
  54	  .driver_info = AR9280_USB },  /* Sony UWA-BR100 */
 
 
 
 
 
 
  55
  56	{ USB_DEVICE(0x0cf3, 0x20ff),
  57	  .driver_info = STORAGE_DEVICE },
  58
  59	{ },
  60};
  61
  62MODULE_DEVICE_TABLE(usb, ath9k_hif_usb_ids);
  63
  64static int __hif_usb_tx(struct hif_device_usb *hif_dev);
  65
  66static void hif_usb_regout_cb(struct urb *urb)
  67{
  68	struct cmd_buf *cmd = (struct cmd_buf *)urb->context;
  69
  70	switch (urb->status) {
  71	case 0:
  72		break;
  73	case -ENOENT:
  74	case -ECONNRESET:
  75	case -ENODEV:
  76	case -ESHUTDOWN:
  77		goto free;
  78	default:
  79		break;
  80	}
  81
  82	if (cmd) {
  83		ath9k_htc_txcompletion_cb(cmd->hif_dev->htc_handle,
  84					  cmd->skb, true);
  85		kfree(cmd);
  86	}
  87
  88	return;
  89free:
  90	kfree_skb(cmd->skb);
  91	kfree(cmd);
  92}
  93
  94static int hif_usb_send_regout(struct hif_device_usb *hif_dev,
  95			       struct sk_buff *skb)
  96{
  97	struct urb *urb;
  98	struct cmd_buf *cmd;
  99	int ret = 0;
 100
 101	urb = usb_alloc_urb(0, GFP_KERNEL);
 102	if (urb == NULL)
 103		return -ENOMEM;
 104
 105	cmd = kzalloc(sizeof(*cmd), GFP_KERNEL);
 106	if (cmd == NULL) {
 107		usb_free_urb(urb);
 108		return -ENOMEM;
 109	}
 110
 111	cmd->skb = skb;
 112	cmd->hif_dev = hif_dev;
 113
 114	usb_fill_bulk_urb(urb, hif_dev->udev,
 115			 usb_sndbulkpipe(hif_dev->udev, USB_REG_OUT_PIPE),
 116			 skb->data, skb->len,
 117			 hif_usb_regout_cb, cmd);
 118
 119	usb_anchor_urb(urb, &hif_dev->regout_submitted);
 120	ret = usb_submit_urb(urb, GFP_KERNEL);
 121	if (ret) {
 122		usb_unanchor_urb(urb);
 123		kfree(cmd);
 124	}
 125	usb_free_urb(urb);
 126
 127	return ret;
 128}
 129
 130static void hif_usb_mgmt_cb(struct urb *urb)
 131{
 132	struct cmd_buf *cmd = (struct cmd_buf *)urb->context;
 133	struct hif_device_usb *hif_dev;
 134	bool txok = true;
 135
 136	if (!cmd || !cmd->skb || !cmd->hif_dev)
 137		return;
 138
 139	hif_dev = cmd->hif_dev;
 140
 141	switch (urb->status) {
 142	case 0:
 143		break;
 144	case -ENOENT:
 145	case -ECONNRESET:
 146	case -ENODEV:
 147	case -ESHUTDOWN:
 148		txok = false;
 149
 150		/*
 151		 * If the URBs are being flushed, no need to complete
 152		 * this packet.
 153		 */
 154		spin_lock(&hif_dev->tx.tx_lock);
 155		if (hif_dev->tx.flags & HIF_USB_TX_FLUSH) {
 156			spin_unlock(&hif_dev->tx.tx_lock);
 157			dev_kfree_skb_any(cmd->skb);
 158			kfree(cmd);
 159			return;
 160		}
 161		spin_unlock(&hif_dev->tx.tx_lock);
 162
 163		break;
 164	default:
 165		txok = false;
 166		break;
 167	}
 168
 169	skb_pull(cmd->skb, 4);
 170	ath9k_htc_txcompletion_cb(cmd->hif_dev->htc_handle,
 171				  cmd->skb, txok);
 172	kfree(cmd);
 173}
 174
 175static int hif_usb_send_mgmt(struct hif_device_usb *hif_dev,
 176			     struct sk_buff *skb)
 177{
 178	struct urb *urb;
 179	struct cmd_buf *cmd;
 180	int ret = 0;
 181	__le16 *hdr;
 182
 183	urb = usb_alloc_urb(0, GFP_ATOMIC);
 184	if (urb == NULL)
 185		return -ENOMEM;
 186
 187	cmd = kzalloc(sizeof(*cmd), GFP_ATOMIC);
 188	if (cmd == NULL) {
 189		usb_free_urb(urb);
 190		return -ENOMEM;
 191	}
 192
 193	cmd->skb = skb;
 194	cmd->hif_dev = hif_dev;
 195
 196	hdr = (__le16 *) skb_push(skb, 4);
 197	*hdr++ = cpu_to_le16(skb->len - 4);
 198	*hdr++ = cpu_to_le16(ATH_USB_TX_STREAM_MODE_TAG);
 199
 200	usb_fill_bulk_urb(urb, hif_dev->udev,
 201			 usb_sndbulkpipe(hif_dev->udev, USB_WLAN_TX_PIPE),
 202			 skb->data, skb->len,
 203			 hif_usb_mgmt_cb, cmd);
 204
 205	usb_anchor_urb(urb, &hif_dev->mgmt_submitted);
 206	ret = usb_submit_urb(urb, GFP_ATOMIC);
 207	if (ret) {
 208		usb_unanchor_urb(urb);
 209		kfree(cmd);
 210	}
 211	usb_free_urb(urb);
 212
 213	return ret;
 214}
 215
 216static inline void ath9k_skb_queue_purge(struct hif_device_usb *hif_dev,
 217					 struct sk_buff_head *list)
 218{
 219	struct sk_buff *skb;
 220
 221	while ((skb = __skb_dequeue(list)) != NULL) {
 222		dev_kfree_skb_any(skb);
 223	}
 224}
 225
 226static inline void ath9k_skb_queue_complete(struct hif_device_usb *hif_dev,
 227					    struct sk_buff_head *queue,
 228					    bool txok)
 229{
 230	struct sk_buff *skb;
 231
 232	while ((skb = __skb_dequeue(queue)) != NULL) {
 
 
 
 233		ath9k_htc_txcompletion_cb(hif_dev->htc_handle,
 234					  skb, txok);
 235		if (txok)
 236			TX_STAT_INC(skb_success);
 
 
 237		else
 238			TX_STAT_INC(skb_failed);
 239	}
 240}
 241
 242static void hif_usb_tx_cb(struct urb *urb)
 243{
 244	struct tx_buf *tx_buf = (struct tx_buf *) urb->context;
 245	struct hif_device_usb *hif_dev;
 246	bool txok = true;
 247
 248	if (!tx_buf || !tx_buf->hif_dev)
 249		return;
 250
 251	hif_dev = tx_buf->hif_dev;
 252
 253	switch (urb->status) {
 254	case 0:
 255		break;
 256	case -ENOENT:
 257	case -ECONNRESET:
 258	case -ENODEV:
 259	case -ESHUTDOWN:
 260		txok = false;
 261
 262		/*
 263		 * If the URBs are being flushed, no need to add this
 264		 * URB to the free list.
 265		 */
 266		spin_lock(&hif_dev->tx.tx_lock);
 267		if (hif_dev->tx.flags & HIF_USB_TX_FLUSH) {
 268			spin_unlock(&hif_dev->tx.tx_lock);
 269			ath9k_skb_queue_purge(hif_dev, &tx_buf->skb_queue);
 270			return;
 271		}
 272		spin_unlock(&hif_dev->tx.tx_lock);
 273
 274		break;
 275	default:
 276		txok = false;
 277		break;
 278	}
 279
 280	ath9k_skb_queue_complete(hif_dev, &tx_buf->skb_queue, txok);
 281
 282	/* Re-initialize the SKB queue */
 283	tx_buf->len = tx_buf->offset = 0;
 284	__skb_queue_head_init(&tx_buf->skb_queue);
 285
 286	/* Add this TX buffer to the free list */
 287	spin_lock(&hif_dev->tx.tx_lock);
 288	list_move_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 289	hif_dev->tx.tx_buf_cnt++;
 290	if (!(hif_dev->tx.flags & HIF_USB_TX_STOP))
 291		__hif_usb_tx(hif_dev); /* Check for pending SKBs */
 292	TX_STAT_INC(buf_completed);
 293	spin_unlock(&hif_dev->tx.tx_lock);
 294}
 295
 296/* TX lock has to be taken */
 297static int __hif_usb_tx(struct hif_device_usb *hif_dev)
 298{
 299	struct tx_buf *tx_buf = NULL;
 300	struct sk_buff *nskb = NULL;
 301	int ret = 0, i;
 302	u16 tx_skb_cnt = 0;
 303	u8 *buf;
 304	__le16 *hdr;
 305
 306	if (hif_dev->tx.tx_skb_cnt == 0)
 307		return 0;
 308
 309	/* Check if a free TX buffer is available */
 310	if (list_empty(&hif_dev->tx.tx_buf))
 311		return 0;
 312
 313	tx_buf = list_first_entry(&hif_dev->tx.tx_buf, struct tx_buf, list);
 314	list_move_tail(&tx_buf->list, &hif_dev->tx.tx_pending);
 315	hif_dev->tx.tx_buf_cnt--;
 316
 317	tx_skb_cnt = min_t(u16, hif_dev->tx.tx_skb_cnt, MAX_TX_AGGR_NUM);
 318
 319	for (i = 0; i < tx_skb_cnt; i++) {
 320		nskb = __skb_dequeue(&hif_dev->tx.tx_skb_queue);
 321
 322		/* Should never be NULL */
 323		BUG_ON(!nskb);
 324
 325		hif_dev->tx.tx_skb_cnt--;
 326
 327		buf = tx_buf->buf;
 328		buf += tx_buf->offset;
 329		hdr = (__le16 *)buf;
 330		*hdr++ = cpu_to_le16(nskb->len);
 331		*hdr++ = cpu_to_le16(ATH_USB_TX_STREAM_MODE_TAG);
 332		buf += 4;
 333		memcpy(buf, nskb->data, nskb->len);
 334		tx_buf->len = nskb->len + 4;
 335
 336		if (i < (tx_skb_cnt - 1))
 337			tx_buf->offset += (((tx_buf->len - 1) / 4) + 1) * 4;
 338
 339		if (i == (tx_skb_cnt - 1))
 340			tx_buf->len += tx_buf->offset;
 341
 342		__skb_queue_tail(&tx_buf->skb_queue, nskb);
 343		TX_STAT_INC(skb_queued);
 344	}
 345
 346	usb_fill_bulk_urb(tx_buf->urb, hif_dev->udev,
 347			  usb_sndbulkpipe(hif_dev->udev, USB_WLAN_TX_PIPE),
 348			  tx_buf->buf, tx_buf->len,
 349			  hif_usb_tx_cb, tx_buf);
 350
 351	ret = usb_submit_urb(tx_buf->urb, GFP_ATOMIC);
 352	if (ret) {
 353		tx_buf->len = tx_buf->offset = 0;
 354		ath9k_skb_queue_complete(hif_dev, &tx_buf->skb_queue, false);
 355		__skb_queue_head_init(&tx_buf->skb_queue);
 356		list_move_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 357		hif_dev->tx.tx_buf_cnt++;
 358	}
 359
 360	if (!ret)
 361		TX_STAT_INC(buf_queued);
 362
 363	return ret;
 364}
 365
 366static int hif_usb_send_tx(struct hif_device_usb *hif_dev, struct sk_buff *skb)
 367{
 368	struct ath9k_htc_tx_ctl *tx_ctl;
 369	unsigned long flags;
 370	int ret = 0;
 371
 372	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 373
 374	if (hif_dev->tx.flags & HIF_USB_TX_STOP) {
 375		spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 376		return -ENODEV;
 377	}
 378
 379	/* Check if the max queue count has been reached */
 380	if (hif_dev->tx.tx_skb_cnt > MAX_TX_BUF_NUM) {
 381		spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 382		return -ENOMEM;
 383	}
 384
 385	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 386
 387	tx_ctl = HTC_SKB_CB(skb);
 388
 389	/* Mgmt/Beacon frames don't use the TX buffer pool */
 390	if ((tx_ctl->type == ATH9K_HTC_MGMT) ||
 391	    (tx_ctl->type == ATH9K_HTC_BEACON)) {
 392		ret = hif_usb_send_mgmt(hif_dev, skb);
 393	}
 394
 395	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 396
 397	if ((tx_ctl->type == ATH9K_HTC_NORMAL) ||
 398	    (tx_ctl->type == ATH9K_HTC_AMPDU)) {
 399		__skb_queue_tail(&hif_dev->tx.tx_skb_queue, skb);
 400		hif_dev->tx.tx_skb_cnt++;
 401	}
 402
 403	/* Check if AMPDUs have to be sent immediately */
 404	if ((hif_dev->tx.tx_buf_cnt == MAX_TX_URB_NUM) &&
 405	    (hif_dev->tx.tx_skb_cnt < 2)) {
 406		__hif_usb_tx(hif_dev);
 407	}
 408
 409	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 410
 411	return ret;
 412}
 413
 414static void hif_usb_start(void *hif_handle)
 415{
 416	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 417	unsigned long flags;
 418
 419	hif_dev->flags |= HIF_USB_START;
 420
 421	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 422	hif_dev->tx.flags &= ~HIF_USB_TX_STOP;
 423	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 424}
 425
 426static void hif_usb_stop(void *hif_handle)
 427{
 428	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 429	struct tx_buf *tx_buf = NULL, *tx_buf_tmp = NULL;
 430	unsigned long flags;
 431
 432	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 433	ath9k_skb_queue_complete(hif_dev, &hif_dev->tx.tx_skb_queue, false);
 434	hif_dev->tx.tx_skb_cnt = 0;
 435	hif_dev->tx.flags |= HIF_USB_TX_STOP;
 436	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 437
 438	/* The pending URBs have to be canceled. */
 439	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 440				 &hif_dev->tx.tx_pending, list) {
 441		usb_kill_urb(tx_buf->urb);
 442	}
 443
 444	usb_kill_anchored_urbs(&hif_dev->mgmt_submitted);
 445}
 446
 447static int hif_usb_send(void *hif_handle, u8 pipe_id, struct sk_buff *skb)
 448{
 449	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 450	int ret = 0;
 451
 452	switch (pipe_id) {
 453	case USB_WLAN_TX_PIPE:
 454		ret = hif_usb_send_tx(hif_dev, skb);
 455		break;
 456	case USB_REG_OUT_PIPE:
 457		ret = hif_usb_send_regout(hif_dev, skb);
 458		break;
 459	default:
 460		dev_err(&hif_dev->udev->dev,
 461			"ath9k_htc: Invalid TX pipe: %d\n", pipe_id);
 462		ret = -EINVAL;
 463		break;
 464	}
 465
 466	return ret;
 467}
 468
 469static inline bool check_index(struct sk_buff *skb, u8 idx)
 470{
 471	struct ath9k_htc_tx_ctl *tx_ctl;
 472
 473	tx_ctl = HTC_SKB_CB(skb);
 474
 475	if ((tx_ctl->type == ATH9K_HTC_AMPDU) &&
 476	    (tx_ctl->sta_idx == idx))
 477		return true;
 478
 479	return false;
 480}
 481
 482static void hif_usb_sta_drain(void *hif_handle, u8 idx)
 483{
 484	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 485	struct sk_buff *skb, *tmp;
 486	unsigned long flags;
 487
 488	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 489
 490	skb_queue_walk_safe(&hif_dev->tx.tx_skb_queue, skb, tmp) {
 491		if (check_index(skb, idx)) {
 492			__skb_unlink(skb, &hif_dev->tx.tx_skb_queue);
 493			ath9k_htc_txcompletion_cb(hif_dev->htc_handle,
 494						  skb, false);
 495			hif_dev->tx.tx_skb_cnt--;
 496			TX_STAT_INC(skb_failed);
 497		}
 498	}
 499
 500	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 501}
 502
 503static struct ath9k_htc_hif hif_usb = {
 504	.transport = ATH9K_HIF_USB,
 505	.name = "ath9k_hif_usb",
 506
 507	.control_ul_pipe = USB_REG_OUT_PIPE,
 508	.control_dl_pipe = USB_REG_IN_PIPE,
 509
 510	.start = hif_usb_start,
 511	.stop = hif_usb_stop,
 512	.sta_drain = hif_usb_sta_drain,
 513	.send = hif_usb_send,
 514};
 515
 516static void ath9k_hif_usb_rx_stream(struct hif_device_usb *hif_dev,
 517				    struct sk_buff *skb)
 518{
 519	struct sk_buff *nskb, *skb_pool[MAX_PKT_NUM_IN_TRANSFER];
 520	int index = 0, i = 0, len = skb->len;
 521	int rx_remain_len, rx_pkt_len;
 522	u16 pool_index = 0;
 523	u8 *ptr;
 524
 525	spin_lock(&hif_dev->rx_lock);
 526
 527	rx_remain_len = hif_dev->rx_remain_len;
 528	rx_pkt_len = hif_dev->rx_transfer_len;
 529
 530	if (rx_remain_len != 0) {
 531		struct sk_buff *remain_skb = hif_dev->remain_skb;
 532
 533		if (remain_skb) {
 534			ptr = (u8 *) remain_skb->data;
 535
 536			index = rx_remain_len;
 537			rx_remain_len -= hif_dev->rx_pad_len;
 538			ptr += rx_pkt_len;
 539
 540			memcpy(ptr, skb->data, rx_remain_len);
 541
 542			rx_pkt_len += rx_remain_len;
 543			hif_dev->rx_remain_len = 0;
 544			skb_put(remain_skb, rx_pkt_len);
 545
 546			skb_pool[pool_index++] = remain_skb;
 547
 548		} else {
 549			index = rx_remain_len;
 550		}
 551	}
 552
 553	spin_unlock(&hif_dev->rx_lock);
 554
 555	while (index < len) {
 556		u16 pkt_len;
 557		u16 pkt_tag;
 558		u16 pad_len;
 559		int chk_idx;
 560
 561		ptr = (u8 *) skb->data;
 562
 563		pkt_len = get_unaligned_le16(ptr + index);
 564		pkt_tag = get_unaligned_le16(ptr + index + 2);
 565
 566		if (pkt_tag != ATH_USB_RX_STREAM_MODE_TAG) {
 567			RX_STAT_INC(skb_dropped);
 568			return;
 569		}
 570
 571		pad_len = 4 - (pkt_len & 0x3);
 572		if (pad_len == 4)
 573			pad_len = 0;
 574
 575		chk_idx = index;
 576		index = index + 4 + pkt_len + pad_len;
 577
 578		if (index > MAX_RX_BUF_SIZE) {
 579			spin_lock(&hif_dev->rx_lock);
 580			hif_dev->rx_remain_len = index - MAX_RX_BUF_SIZE;
 581			hif_dev->rx_transfer_len =
 582				MAX_RX_BUF_SIZE - chk_idx - 4;
 583			hif_dev->rx_pad_len = pad_len;
 584
 585			nskb = __dev_alloc_skb(pkt_len + 32, GFP_ATOMIC);
 586			if (!nskb) {
 587				dev_err(&hif_dev->udev->dev,
 588					"ath9k_htc: RX memory allocation error\n");
 589				spin_unlock(&hif_dev->rx_lock);
 590				goto err;
 591			}
 592			skb_reserve(nskb, 32);
 593			RX_STAT_INC(skb_allocated);
 594
 595			memcpy(nskb->data, &(skb->data[chk_idx+4]),
 596			       hif_dev->rx_transfer_len);
 597
 598			/* Record the buffer pointer */
 599			hif_dev->remain_skb = nskb;
 600			spin_unlock(&hif_dev->rx_lock);
 601		} else {
 602			nskb = __dev_alloc_skb(pkt_len + 32, GFP_ATOMIC);
 603			if (!nskb) {
 604				dev_err(&hif_dev->udev->dev,
 605					"ath9k_htc: RX memory allocation error\n");
 606				goto err;
 607			}
 608			skb_reserve(nskb, 32);
 609			RX_STAT_INC(skb_allocated);
 610
 611			memcpy(nskb->data, &(skb->data[chk_idx+4]), pkt_len);
 612			skb_put(nskb, pkt_len);
 613			skb_pool[pool_index++] = nskb;
 614		}
 615	}
 616
 617err:
 618	for (i = 0; i < pool_index; i++) {
 
 619		ath9k_htc_rx_msg(hif_dev->htc_handle, skb_pool[i],
 620				 skb_pool[i]->len, USB_WLAN_RX_PIPE);
 621		RX_STAT_INC(skb_completed);
 622	}
 623}
 624
 625static void ath9k_hif_usb_rx_cb(struct urb *urb)
 626{
 627	struct sk_buff *skb = (struct sk_buff *) urb->context;
 628	struct hif_device_usb *hif_dev =
 629		usb_get_intfdata(usb_ifnum_to_if(urb->dev, 0));
 630	int ret;
 631
 632	if (!skb)
 633		return;
 634
 635	if (!hif_dev)
 636		goto free;
 637
 638	switch (urb->status) {
 639	case 0:
 640		break;
 641	case -ENOENT:
 642	case -ECONNRESET:
 643	case -ENODEV:
 644	case -ESHUTDOWN:
 645		goto free;
 646	default:
 647		goto resubmit;
 648	}
 649
 650	if (likely(urb->actual_length != 0)) {
 651		skb_put(skb, urb->actual_length);
 652		ath9k_hif_usb_rx_stream(hif_dev, skb);
 653	}
 654
 655resubmit:
 656	skb_reset_tail_pointer(skb);
 657	skb_trim(skb, 0);
 658
 659	usb_anchor_urb(urb, &hif_dev->rx_submitted);
 660	ret = usb_submit_urb(urb, GFP_ATOMIC);
 661	if (ret) {
 662		usb_unanchor_urb(urb);
 663		goto free;
 664	}
 665
 666	return;
 667free:
 668	kfree_skb(skb);
 669}
 670
 671static void ath9k_hif_usb_reg_in_cb(struct urb *urb)
 672{
 673	struct sk_buff *skb = (struct sk_buff *) urb->context;
 674	struct sk_buff *nskb;
 675	struct hif_device_usb *hif_dev =
 676		usb_get_intfdata(usb_ifnum_to_if(urb->dev, 0));
 677	int ret;
 678
 679	if (!skb)
 680		return;
 681
 682	if (!hif_dev)
 683		goto free;
 684
 685	switch (urb->status) {
 686	case 0:
 687		break;
 688	case -ENOENT:
 689	case -ECONNRESET:
 690	case -ENODEV:
 691	case -ESHUTDOWN:
 692		goto free;
 693	default:
 694		skb_reset_tail_pointer(skb);
 695		skb_trim(skb, 0);
 696
 697		goto resubmit;
 698	}
 699
 700	if (likely(urb->actual_length != 0)) {
 701		skb_put(skb, urb->actual_length);
 702
 703		/* Process the command first */
 704		ath9k_htc_rx_msg(hif_dev->htc_handle, skb,
 705				 skb->len, USB_REG_IN_PIPE);
 706
 707
 708		nskb = alloc_skb(MAX_REG_IN_BUF_SIZE, GFP_ATOMIC);
 709		if (!nskb) {
 710			dev_err(&hif_dev->udev->dev,
 711				"ath9k_htc: REG_IN memory allocation failure\n");
 712			urb->context = NULL;
 713			return;
 714		}
 715
 716		usb_fill_bulk_urb(urb, hif_dev->udev,
 717				 usb_rcvbulkpipe(hif_dev->udev,
 718						 USB_REG_IN_PIPE),
 719				 nskb->data, MAX_REG_IN_BUF_SIZE,
 720				 ath9k_hif_usb_reg_in_cb, nskb);
 721	}
 722
 723resubmit:
 724	usb_anchor_urb(urb, &hif_dev->reg_in_submitted);
 725	ret = usb_submit_urb(urb, GFP_ATOMIC);
 726	if (ret) {
 727		usb_unanchor_urb(urb);
 728		goto free;
 729	}
 730
 731	return;
 732free:
 733	kfree_skb(skb);
 734	urb->context = NULL;
 735}
 736
 737static void ath9k_hif_usb_dealloc_tx_urbs(struct hif_device_usb *hif_dev)
 738{
 739	struct tx_buf *tx_buf = NULL, *tx_buf_tmp = NULL;
 740	unsigned long flags;
 741
 742	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 743				 &hif_dev->tx.tx_buf, list) {
 744		usb_kill_urb(tx_buf->urb);
 745		list_del(&tx_buf->list);
 746		usb_free_urb(tx_buf->urb);
 747		kfree(tx_buf->buf);
 748		kfree(tx_buf);
 749	}
 750
 751	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 752	hif_dev->tx.flags |= HIF_USB_TX_FLUSH;
 753	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 754
 755	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 756				 &hif_dev->tx.tx_pending, list) {
 757		usb_kill_urb(tx_buf->urb);
 758		list_del(&tx_buf->list);
 759		usb_free_urb(tx_buf->urb);
 760		kfree(tx_buf->buf);
 761		kfree(tx_buf);
 762	}
 763
 764	usb_kill_anchored_urbs(&hif_dev->mgmt_submitted);
 765}
 766
 767static int ath9k_hif_usb_alloc_tx_urbs(struct hif_device_usb *hif_dev)
 768{
 769	struct tx_buf *tx_buf;
 770	int i;
 771
 772	INIT_LIST_HEAD(&hif_dev->tx.tx_buf);
 773	INIT_LIST_HEAD(&hif_dev->tx.tx_pending);
 774	spin_lock_init(&hif_dev->tx.tx_lock);
 775	__skb_queue_head_init(&hif_dev->tx.tx_skb_queue);
 776	init_usb_anchor(&hif_dev->mgmt_submitted);
 777
 778	for (i = 0; i < MAX_TX_URB_NUM; i++) {
 779		tx_buf = kzalloc(sizeof(struct tx_buf), GFP_KERNEL);
 780		if (!tx_buf)
 781			goto err;
 782
 783		tx_buf->buf = kzalloc(MAX_TX_BUF_SIZE, GFP_KERNEL);
 784		if (!tx_buf->buf)
 785			goto err;
 786
 787		tx_buf->urb = usb_alloc_urb(0, GFP_KERNEL);
 788		if (!tx_buf->urb)
 789			goto err;
 790
 791		tx_buf->hif_dev = hif_dev;
 792		__skb_queue_head_init(&tx_buf->skb_queue);
 793
 794		list_add_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 795	}
 796
 797	hif_dev->tx.tx_buf_cnt = MAX_TX_URB_NUM;
 798
 799	return 0;
 800err:
 801	if (tx_buf) {
 802		kfree(tx_buf->buf);
 803		kfree(tx_buf);
 804	}
 805	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 806	return -ENOMEM;
 807}
 808
 809static void ath9k_hif_usb_dealloc_rx_urbs(struct hif_device_usb *hif_dev)
 810{
 811	usb_kill_anchored_urbs(&hif_dev->rx_submitted);
 812}
 813
 814static int ath9k_hif_usb_alloc_rx_urbs(struct hif_device_usb *hif_dev)
 815{
 816	struct urb *urb = NULL;
 817	struct sk_buff *skb = NULL;
 818	int i, ret;
 819
 820	init_usb_anchor(&hif_dev->rx_submitted);
 821	spin_lock_init(&hif_dev->rx_lock);
 822
 823	for (i = 0; i < MAX_RX_URB_NUM; i++) {
 824
 825		/* Allocate URB */
 826		urb = usb_alloc_urb(0, GFP_KERNEL);
 827		if (urb == NULL) {
 828			ret = -ENOMEM;
 829			goto err_urb;
 830		}
 831
 832		/* Allocate buffer */
 833		skb = alloc_skb(MAX_RX_BUF_SIZE, GFP_KERNEL);
 834		if (!skb) {
 835			ret = -ENOMEM;
 836			goto err_skb;
 837		}
 838
 839		usb_fill_bulk_urb(urb, hif_dev->udev,
 840				  usb_rcvbulkpipe(hif_dev->udev,
 841						  USB_WLAN_RX_PIPE),
 842				  skb->data, MAX_RX_BUF_SIZE,
 843				  ath9k_hif_usb_rx_cb, skb);
 844
 845		/* Anchor URB */
 846		usb_anchor_urb(urb, &hif_dev->rx_submitted);
 847
 848		/* Submit URB */
 849		ret = usb_submit_urb(urb, GFP_KERNEL);
 850		if (ret) {
 851			usb_unanchor_urb(urb);
 852			goto err_submit;
 853		}
 854
 855		/*
 856		 * Drop reference count.
 857		 * This ensures that the URB is freed when killing them.
 858		 */
 859		usb_free_urb(urb);
 860	}
 861
 862	return 0;
 863
 864err_submit:
 865	kfree_skb(skb);
 866err_skb:
 867	usb_free_urb(urb);
 868err_urb:
 869	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 870	return ret;
 871}
 872
 873static void ath9k_hif_usb_dealloc_reg_in_urbs(struct hif_device_usb *hif_dev)
 874{
 875	usb_kill_anchored_urbs(&hif_dev->reg_in_submitted);
 876}
 877
 878static int ath9k_hif_usb_alloc_reg_in_urbs(struct hif_device_usb *hif_dev)
 879{
 880	struct urb *urb = NULL;
 881	struct sk_buff *skb = NULL;
 882	int i, ret;
 883
 884	init_usb_anchor(&hif_dev->reg_in_submitted);
 885
 886	for (i = 0; i < MAX_REG_IN_URB_NUM; i++) {
 887
 888		/* Allocate URB */
 889		urb = usb_alloc_urb(0, GFP_KERNEL);
 890		if (urb == NULL) {
 891			ret = -ENOMEM;
 892			goto err_urb;
 893		}
 894
 895		/* Allocate buffer */
 896		skb = alloc_skb(MAX_REG_IN_BUF_SIZE, GFP_KERNEL);
 897		if (!skb) {
 898			ret = -ENOMEM;
 899			goto err_skb;
 900		}
 901
 902		usb_fill_bulk_urb(urb, hif_dev->udev,
 903				  usb_rcvbulkpipe(hif_dev->udev,
 904						  USB_REG_IN_PIPE),
 905				  skb->data, MAX_REG_IN_BUF_SIZE,
 906				  ath9k_hif_usb_reg_in_cb, skb);
 907
 908		/* Anchor URB */
 909		usb_anchor_urb(urb, &hif_dev->reg_in_submitted);
 910
 911		/* Submit URB */
 912		ret = usb_submit_urb(urb, GFP_KERNEL);
 913		if (ret) {
 914			usb_unanchor_urb(urb);
 915			goto err_submit;
 916		}
 917
 918		/*
 919		 * Drop reference count.
 920		 * This ensures that the URB is freed when killing them.
 921		 */
 922		usb_free_urb(urb);
 923	}
 924
 925	return 0;
 926
 927err_submit:
 928	kfree_skb(skb);
 929err_skb:
 930	usb_free_urb(urb);
 931err_urb:
 932	ath9k_hif_usb_dealloc_reg_in_urbs(hif_dev);
 933	return ret;
 934}
 935
 936static int ath9k_hif_usb_alloc_urbs(struct hif_device_usb *hif_dev)
 937{
 938	/* Register Write */
 939	init_usb_anchor(&hif_dev->regout_submitted);
 940
 941	/* TX */
 942	if (ath9k_hif_usb_alloc_tx_urbs(hif_dev) < 0)
 943		goto err;
 944
 945	/* RX */
 946	if (ath9k_hif_usb_alloc_rx_urbs(hif_dev) < 0)
 947		goto err_rx;
 948
 949	/* Register Read */
 950	if (ath9k_hif_usb_alloc_reg_in_urbs(hif_dev) < 0)
 951		goto err_reg;
 952
 953	return 0;
 954err_reg:
 955	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 956err_rx:
 957	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 958err:
 959	return -ENOMEM;
 960}
 961
 962static void ath9k_hif_usb_dealloc_urbs(struct hif_device_usb *hif_dev)
 963{
 964	usb_kill_anchored_urbs(&hif_dev->regout_submitted);
 965	ath9k_hif_usb_dealloc_reg_in_urbs(hif_dev);
 966	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 967	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 968}
 969
 970static int ath9k_hif_usb_download_fw(struct hif_device_usb *hif_dev,
 971				     u32 drv_info)
 972{
 973	int transfer, err;
 974	const void *data = hif_dev->firmware->data;
 975	size_t len = hif_dev->firmware->size;
 976	u32 addr = AR9271_FIRMWARE;
 977	u8 *buf = kzalloc(4096, GFP_KERNEL);
 978	u32 firm_offset;
 979
 980	if (!buf)
 981		return -ENOMEM;
 982
 983	while (len) {
 984		transfer = min_t(int, len, 4096);
 985		memcpy(buf, data, transfer);
 986
 987		err = usb_control_msg(hif_dev->udev,
 988				      usb_sndctrlpipe(hif_dev->udev, 0),
 989				      FIRMWARE_DOWNLOAD, 0x40 | USB_DIR_OUT,
 990				      addr >> 8, 0, buf, transfer, HZ);
 991		if (err < 0) {
 992			kfree(buf);
 993			return err;
 994		}
 995
 996		len -= transfer;
 997		data += transfer;
 998		addr += transfer;
 999	}
1000	kfree(buf);
1001
1002	if (IS_AR7010_DEVICE(drv_info))
1003		firm_offset = AR7010_FIRMWARE_TEXT;
1004	else
1005		firm_offset = AR9271_FIRMWARE_TEXT;
1006
1007	/*
1008	 * Issue FW download complete command to firmware.
1009	 */
1010	err = usb_control_msg(hif_dev->udev, usb_sndctrlpipe(hif_dev->udev, 0),
1011			      FIRMWARE_DOWNLOAD_COMP,
1012			      0x40 | USB_DIR_OUT,
1013			      firm_offset >> 8, 0, NULL, 0, HZ);
1014	if (err)
1015		return -EIO;
1016
1017	dev_info(&hif_dev->udev->dev, "ath9k_htc: Transferred FW: %s, size: %ld\n",
1018		 hif_dev->fw_name, (unsigned long) hif_dev->firmware->size);
1019
1020	return 0;
1021}
1022
1023static int ath9k_hif_usb_dev_init(struct hif_device_usb *hif_dev, u32 drv_info)
1024{
1025	int ret, idx;
1026	struct usb_host_interface *alt = &hif_dev->interface->altsetting[0];
1027	struct usb_endpoint_descriptor *endp;
1028
1029	/* Request firmware */
1030	ret = request_firmware(&hif_dev->firmware, hif_dev->fw_name,
1031			       &hif_dev->udev->dev);
1032	if (ret) {
1033		dev_err(&hif_dev->udev->dev,
1034			"ath9k_htc: Firmware - %s not found\n", hif_dev->fw_name);
1035		goto err_fw_req;
1036	}
1037
1038	/* Download firmware */
1039	ret = ath9k_hif_usb_download_fw(hif_dev, drv_info);
1040	if (ret) {
1041		dev_err(&hif_dev->udev->dev,
1042			"ath9k_htc: Firmware - %s download failed\n",
1043			hif_dev->fw_name);
1044		goto err_fw_download;
1045	}
1046
1047	/* On downloading the firmware to the target, the USB descriptor of EP4
1048	 * is 'patched' to change the type of the endpoint to Bulk. This will
1049	 * bring down CPU usage during the scan period.
1050	 */
1051	for (idx = 0; idx < alt->desc.bNumEndpoints; idx++) {
1052		endp = &alt->endpoint[idx].desc;
1053		if ((endp->bmAttributes & USB_ENDPOINT_XFERTYPE_MASK)
1054				== USB_ENDPOINT_XFER_INT) {
1055			endp->bmAttributes &= ~USB_ENDPOINT_XFERTYPE_MASK;
1056			endp->bmAttributes |= USB_ENDPOINT_XFER_BULK;
1057			endp->bInterval = 0;
1058		}
1059	}
1060
1061	/* Alloc URBs */
1062	ret = ath9k_hif_usb_alloc_urbs(hif_dev);
1063	if (ret) {
1064		dev_err(&hif_dev->udev->dev,
1065			"ath9k_htc: Unable to allocate URBs\n");
1066		goto err_fw_download;
1067	}
1068
1069	return 0;
1070
1071err_fw_download:
1072	release_firmware(hif_dev->firmware);
1073err_fw_req:
1074	hif_dev->firmware = NULL;
1075	return ret;
1076}
1077
1078static void ath9k_hif_usb_dev_deinit(struct hif_device_usb *hif_dev)
1079{
1080	ath9k_hif_usb_dealloc_urbs(hif_dev);
1081	if (hif_dev->firmware)
1082		release_firmware(hif_dev->firmware);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1083}
1084
1085/*
1086 * An exact copy of the function from zd1211rw.
1087 */
1088static int send_eject_command(struct usb_interface *interface)
1089{
1090	struct usb_device *udev = interface_to_usbdev(interface);
1091	struct usb_host_interface *iface_desc = &interface->altsetting[0];
1092	struct usb_endpoint_descriptor *endpoint;
1093	unsigned char *cmd;
1094	u8 bulk_out_ep;
1095	int r;
1096
1097	/* Find bulk out endpoint */
1098	for (r = 1; r >= 0; r--) {
1099		endpoint = &iface_desc->endpoint[r].desc;
1100		if (usb_endpoint_dir_out(endpoint) &&
1101		    usb_endpoint_xfer_bulk(endpoint)) {
1102			bulk_out_ep = endpoint->bEndpointAddress;
1103			break;
1104		}
1105	}
1106	if (r == -1) {
1107		dev_err(&udev->dev,
1108			"ath9k_htc: Could not find bulk out endpoint\n");
1109		return -ENODEV;
1110	}
1111
1112	cmd = kzalloc(31, GFP_KERNEL);
1113	if (cmd == NULL)
1114		return -ENODEV;
1115
1116	/* USB bulk command block */
1117	cmd[0] = 0x55;	/* bulk command signature */
1118	cmd[1] = 0x53;	/* bulk command signature */
1119	cmd[2] = 0x42;	/* bulk command signature */
1120	cmd[3] = 0x43;	/* bulk command signature */
1121	cmd[14] = 6;	/* command length */
1122
1123	cmd[15] = 0x1b;	/* SCSI command: START STOP UNIT */
1124	cmd[19] = 0x2;	/* eject disc */
1125
1126	dev_info(&udev->dev, "Ejecting storage device...\n");
1127	r = usb_bulk_msg(udev, usb_sndbulkpipe(udev, bulk_out_ep),
1128		cmd, 31, NULL, 2000);
1129	kfree(cmd);
1130	if (r)
1131		return r;
1132
1133	/* At this point, the device disconnects and reconnects with the real
1134	 * ID numbers. */
1135
1136	usb_set_intfdata(interface, NULL);
1137	return 0;
1138}
1139
1140static int ath9k_hif_usb_probe(struct usb_interface *interface,
1141			       const struct usb_device_id *id)
1142{
1143	struct usb_device *udev = interface_to_usbdev(interface);
1144	struct hif_device_usb *hif_dev;
1145	int ret = 0;
1146
1147	if (id->driver_info == STORAGE_DEVICE)
1148		return send_eject_command(interface);
1149
1150	hif_dev = kzalloc(sizeof(struct hif_device_usb), GFP_KERNEL);
1151	if (!hif_dev) {
1152		ret = -ENOMEM;
1153		goto err_alloc;
1154	}
1155
1156	usb_get_dev(udev);
 
1157	hif_dev->udev = udev;
1158	hif_dev->interface = interface;
1159	hif_dev->device_id = id->idProduct;
1160#ifdef CONFIG_PM
1161	udev->reset_resume = 1;
1162#endif
1163	usb_set_intfdata(interface, hif_dev);
1164
1165	hif_dev->htc_handle = ath9k_htc_hw_alloc(hif_dev, &hif_usb,
1166						 &hif_dev->udev->dev);
1167	if (hif_dev->htc_handle == NULL) {
1168		ret = -ENOMEM;
1169		goto err_htc_hw_alloc;
1170	}
1171
1172	/* Find out which firmware to load */
1173
1174	if (IS_AR7010_DEVICE(id->driver_info))
1175		hif_dev->fw_name = FIRMWARE_AR7010_1_1;
1176	else
1177		hif_dev->fw_name = FIRMWARE_AR9271;
1178
1179	ret = ath9k_hif_usb_dev_init(hif_dev, id->driver_info);
1180	if (ret) {
1181		ret = -EINVAL;
1182		goto err_hif_init_usb;
1183	}
1184
1185	ret = ath9k_htc_hw_init(hif_dev->htc_handle,
1186				&interface->dev, hif_dev->device_id,
1187				hif_dev->udev->product, id->driver_info);
1188	if (ret) {
1189		ret = -EINVAL;
1190		goto err_htc_hw_init;
1191	}
1192
1193	dev_info(&hif_dev->udev->dev, "ath9k_htc: USB layer initialized\n");
 
 
1194
1195	return 0;
1196
1197err_htc_hw_init:
1198	ath9k_hif_usb_dev_deinit(hif_dev);
1199err_hif_init_usb:
1200	ath9k_htc_hw_free(hif_dev->htc_handle);
1201err_htc_hw_alloc:
1202	usb_set_intfdata(interface, NULL);
1203	kfree(hif_dev);
1204	usb_put_dev(udev);
1205err_alloc:
1206	return ret;
1207}
1208
1209static void ath9k_hif_usb_reboot(struct usb_device *udev)
1210{
1211	u32 reboot_cmd = 0xffffffff;
1212	void *buf;
1213	int ret;
1214
1215	buf = kmemdup(&reboot_cmd, 4, GFP_KERNEL);
1216	if (!buf)
1217		return;
1218
1219	ret = usb_bulk_msg(udev, usb_sndbulkpipe(udev, USB_REG_OUT_PIPE),
1220			   buf, 4, NULL, HZ);
1221	if (ret)
1222		dev_err(&udev->dev, "ath9k_htc: USB reboot failed\n");
1223
1224	kfree(buf);
1225}
1226
1227static void ath9k_hif_usb_disconnect(struct usb_interface *interface)
1228{
1229	struct usb_device *udev = interface_to_usbdev(interface);
1230	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1231	bool unplugged = (udev->state == USB_STATE_NOTATTACHED) ? true : false;
1232
1233	if (!hif_dev)
1234		return;
1235
1236	ath9k_htc_hw_deinit(hif_dev->htc_handle, unplugged);
1237	ath9k_htc_hw_free(hif_dev->htc_handle);
1238	ath9k_hif_usb_dev_deinit(hif_dev);
 
 
 
 
 
1239	usb_set_intfdata(interface, NULL);
1240
1241	if (!unplugged && (hif_dev->flags & HIF_USB_START))
 
 
1242		ath9k_hif_usb_reboot(udev);
1243
1244	kfree(hif_dev);
1245	dev_info(&udev->dev, "ath9k_htc: USB layer deinitialized\n");
1246	usb_put_dev(udev);
1247}
1248
1249#ifdef CONFIG_PM
1250static int ath9k_hif_usb_suspend(struct usb_interface *interface,
1251				 pm_message_t message)
1252{
1253	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1254
1255	/*
1256	 * The device has to be set to FULLSLEEP mode in case no
1257	 * interface is up.
1258	 */
1259	if (!(hif_dev->flags & HIF_USB_START))
1260		ath9k_htc_suspend(hif_dev->htc_handle);
1261
1262	ath9k_hif_usb_dealloc_urbs(hif_dev);
 
 
 
1263
1264	return 0;
1265}
1266
1267static int ath9k_hif_usb_resume(struct usb_interface *interface)
1268{
1269	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1270	struct htc_target *htc_handle = hif_dev->htc_handle;
1271	int ret;
 
1272
1273	ret = ath9k_hif_usb_alloc_urbs(hif_dev);
1274	if (ret)
1275		return ret;
1276
1277	if (hif_dev->firmware) {
1278		ret = ath9k_hif_usb_download_fw(hif_dev,
1279				htc_handle->drv_priv->ah->hw_version.usbdev);
 
 
 
 
 
 
 
 
1280		if (ret)
1281			goto fail_resume;
1282	} else {
1283		ath9k_hif_usb_dealloc_urbs(hif_dev);
1284		return -EIO;
1285	}
1286
1287	mdelay(100);
1288
1289	ret = ath9k_htc_resume(htc_handle);
1290
1291	if (ret)
1292		goto fail_resume;
1293
1294	return 0;
1295
1296fail_resume:
1297	ath9k_hif_usb_dealloc_urbs(hif_dev);
1298
1299	return ret;
1300}
1301#endif
1302
1303static struct usb_driver ath9k_hif_usb_driver = {
1304	.name = KBUILD_MODNAME,
1305	.probe = ath9k_hif_usb_probe,
1306	.disconnect = ath9k_hif_usb_disconnect,
1307#ifdef CONFIG_PM
1308	.suspend = ath9k_hif_usb_suspend,
1309	.resume = ath9k_hif_usb_resume,
1310	.reset_resume = ath9k_hif_usb_resume,
1311#endif
1312	.id_table = ath9k_hif_usb_ids,
1313	.soft_unbind = 1,
 
1314};
1315
1316int ath9k_hif_usb_init(void)
1317{
1318	return usb_register(&ath9k_hif_usb_driver);
1319}
1320
1321void ath9k_hif_usb_exit(void)
1322{
1323	usb_deregister(&ath9k_hif_usb_driver);
1324}
v4.6
   1/*
   2 * Copyright (c) 2010-2011 Atheros Communications 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 <asm/unaligned.h>
  18#include "htc.h"
  19
  20MODULE_FIRMWARE(HTC_7010_MODULE_FW);
  21MODULE_FIRMWARE(HTC_9271_MODULE_FW);
 
 
 
 
  22
  23static struct usb_device_id ath9k_hif_usb_ids[] = {
  24	{ USB_DEVICE(0x0cf3, 0x9271) }, /* Atheros */
  25	{ USB_DEVICE(0x0cf3, 0x1006) }, /* Atheros */
  26	{ USB_DEVICE(0x0846, 0x9030) }, /* Netgear N150 */
  27	{ USB_DEVICE(0x07D1, 0x3A10) }, /* Dlink Wireless 150 */
  28	{ USB_DEVICE(0x13D3, 0x3327) }, /* Azurewave */
  29	{ USB_DEVICE(0x13D3, 0x3328) }, /* Azurewave */
  30	{ USB_DEVICE(0x13D3, 0x3346) }, /* IMC Networks */
  31	{ USB_DEVICE(0x13D3, 0x3348) }, /* Azurewave */
  32	{ USB_DEVICE(0x13D3, 0x3349) }, /* Azurewave */
  33	{ USB_DEVICE(0x13D3, 0x3350) }, /* Azurewave */
  34	{ USB_DEVICE(0x04CA, 0x4605) }, /* Liteon */
  35	{ USB_DEVICE(0x040D, 0x3801) }, /* VIA */
  36	{ USB_DEVICE(0x0cf3, 0xb003) }, /* Ubiquiti WifiStation Ext */
  37	{ USB_DEVICE(0x0cf3, 0xb002) }, /* Ubiquiti WifiStation */
  38	{ USB_DEVICE(0x057c, 0x8403) }, /* AVM FRITZ!WLAN 11N v2 USB */
  39	{ USB_DEVICE(0x0471, 0x209e) }, /* Philips (or NXP) PTA01 */
  40
  41	{ USB_DEVICE(0x0cf3, 0x7015),
  42	  .driver_info = AR9287_USB },  /* Atheros */
  43	{ USB_DEVICE(0x1668, 0x1200),
  44	  .driver_info = AR9287_USB },  /* Verizon */
  45
  46	{ USB_DEVICE(0x0cf3, 0x7010),
  47	  .driver_info = AR9280_USB },  /* Atheros */
  48	{ USB_DEVICE(0x0846, 0x9018),
  49	  .driver_info = AR9280_USB },  /* Netgear WNDA3200 */
  50	{ USB_DEVICE(0x083A, 0xA704),
  51	  .driver_info = AR9280_USB },  /* SMC Networks */
  52	{ USB_DEVICE(0x0411, 0x017f),
  53	  .driver_info = AR9280_USB },  /* Sony UWA-BR100 */
  54	{ USB_DEVICE(0x0411, 0x0197),
  55	  .driver_info = AR9280_USB },  /* Buffalo WLI-UV-AG300P */
  56	{ USB_DEVICE(0x04da, 0x3904),
  57	  .driver_info = AR9280_USB },
  58	{ USB_DEVICE(0x0930, 0x0a08),
  59	  .driver_info = AR9280_USB },  /* Toshiba WLM-20U2 and GN-1080 */
  60
  61	{ USB_DEVICE(0x0cf3, 0x20ff),
  62	  .driver_info = STORAGE_DEVICE },
  63
  64	{ },
  65};
  66
  67MODULE_DEVICE_TABLE(usb, ath9k_hif_usb_ids);
  68
  69static int __hif_usb_tx(struct hif_device_usb *hif_dev);
  70
  71static void hif_usb_regout_cb(struct urb *urb)
  72{
  73	struct cmd_buf *cmd = (struct cmd_buf *)urb->context;
  74
  75	switch (urb->status) {
  76	case 0:
  77		break;
  78	case -ENOENT:
  79	case -ECONNRESET:
  80	case -ENODEV:
  81	case -ESHUTDOWN:
  82		goto free;
  83	default:
  84		break;
  85	}
  86
  87	if (cmd) {
  88		ath9k_htc_txcompletion_cb(cmd->hif_dev->htc_handle,
  89					  cmd->skb, true);
  90		kfree(cmd);
  91	}
  92
  93	return;
  94free:
  95	kfree_skb(cmd->skb);
  96	kfree(cmd);
  97}
  98
  99static int hif_usb_send_regout(struct hif_device_usb *hif_dev,
 100			       struct sk_buff *skb)
 101{
 102	struct urb *urb;
 103	struct cmd_buf *cmd;
 104	int ret = 0;
 105
 106	urb = usb_alloc_urb(0, GFP_KERNEL);
 107	if (urb == NULL)
 108		return -ENOMEM;
 109
 110	cmd = kzalloc(sizeof(*cmd), GFP_KERNEL);
 111	if (cmd == NULL) {
 112		usb_free_urb(urb);
 113		return -ENOMEM;
 114	}
 115
 116	cmd->skb = skb;
 117	cmd->hif_dev = hif_dev;
 118
 119	usb_fill_int_urb(urb, hif_dev->udev,
 120			 usb_sndintpipe(hif_dev->udev, USB_REG_OUT_PIPE),
 121			 skb->data, skb->len,
 122			 hif_usb_regout_cb, cmd, 1);
 123
 124	usb_anchor_urb(urb, &hif_dev->regout_submitted);
 125	ret = usb_submit_urb(urb, GFP_KERNEL);
 126	if (ret) {
 127		usb_unanchor_urb(urb);
 128		kfree(cmd);
 129	}
 130	usb_free_urb(urb);
 131
 132	return ret;
 133}
 134
 135static void hif_usb_mgmt_cb(struct urb *urb)
 136{
 137	struct cmd_buf *cmd = (struct cmd_buf *)urb->context;
 138	struct hif_device_usb *hif_dev;
 139	bool txok = true;
 140
 141	if (!cmd || !cmd->skb || !cmd->hif_dev)
 142		return;
 143
 144	hif_dev = cmd->hif_dev;
 145
 146	switch (urb->status) {
 147	case 0:
 148		break;
 149	case -ENOENT:
 150	case -ECONNRESET:
 151	case -ENODEV:
 152	case -ESHUTDOWN:
 153		txok = false;
 154
 155		/*
 156		 * If the URBs are being flushed, no need to complete
 157		 * this packet.
 158		 */
 159		spin_lock(&hif_dev->tx.tx_lock);
 160		if (hif_dev->tx.flags & HIF_USB_TX_FLUSH) {
 161			spin_unlock(&hif_dev->tx.tx_lock);
 162			dev_kfree_skb_any(cmd->skb);
 163			kfree(cmd);
 164			return;
 165		}
 166		spin_unlock(&hif_dev->tx.tx_lock);
 167
 168		break;
 169	default:
 170		txok = false;
 171		break;
 172	}
 173
 174	skb_pull(cmd->skb, 4);
 175	ath9k_htc_txcompletion_cb(cmd->hif_dev->htc_handle,
 176				  cmd->skb, txok);
 177	kfree(cmd);
 178}
 179
 180static int hif_usb_send_mgmt(struct hif_device_usb *hif_dev,
 181			     struct sk_buff *skb)
 182{
 183	struct urb *urb;
 184	struct cmd_buf *cmd;
 185	int ret = 0;
 186	__le16 *hdr;
 187
 188	urb = usb_alloc_urb(0, GFP_ATOMIC);
 189	if (urb == NULL)
 190		return -ENOMEM;
 191
 192	cmd = kzalloc(sizeof(*cmd), GFP_ATOMIC);
 193	if (cmd == NULL) {
 194		usb_free_urb(urb);
 195		return -ENOMEM;
 196	}
 197
 198	cmd->skb = skb;
 199	cmd->hif_dev = hif_dev;
 200
 201	hdr = (__le16 *) skb_push(skb, 4);
 202	*hdr++ = cpu_to_le16(skb->len - 4);
 203	*hdr++ = cpu_to_le16(ATH_USB_TX_STREAM_MODE_TAG);
 204
 205	usb_fill_bulk_urb(urb, hif_dev->udev,
 206			 usb_sndbulkpipe(hif_dev->udev, USB_WLAN_TX_PIPE),
 207			 skb->data, skb->len,
 208			 hif_usb_mgmt_cb, cmd);
 209
 210	usb_anchor_urb(urb, &hif_dev->mgmt_submitted);
 211	ret = usb_submit_urb(urb, GFP_ATOMIC);
 212	if (ret) {
 213		usb_unanchor_urb(urb);
 214		kfree(cmd);
 215	}
 216	usb_free_urb(urb);
 217
 218	return ret;
 219}
 220
 221static inline void ath9k_skb_queue_purge(struct hif_device_usb *hif_dev,
 222					 struct sk_buff_head *list)
 223{
 224	struct sk_buff *skb;
 225
 226	while ((skb = __skb_dequeue(list)) != NULL) {
 227		dev_kfree_skb_any(skb);
 228	}
 229}
 230
 231static inline void ath9k_skb_queue_complete(struct hif_device_usb *hif_dev,
 232					    struct sk_buff_head *queue,
 233					    bool txok)
 234{
 235	struct sk_buff *skb;
 236
 237	while ((skb = __skb_dequeue(queue)) != NULL) {
 238#ifdef CONFIG_ATH9K_HTC_DEBUGFS
 239		int ln = skb->len;
 240#endif
 241		ath9k_htc_txcompletion_cb(hif_dev->htc_handle,
 242					  skb, txok);
 243		if (txok) {
 244			TX_STAT_INC(skb_success);
 245			TX_STAT_ADD(skb_success_bytes, ln);
 246		}
 247		else
 248			TX_STAT_INC(skb_failed);
 249	}
 250}
 251
 252static void hif_usb_tx_cb(struct urb *urb)
 253{
 254	struct tx_buf *tx_buf = (struct tx_buf *) urb->context;
 255	struct hif_device_usb *hif_dev;
 256	bool txok = true;
 257
 258	if (!tx_buf || !tx_buf->hif_dev)
 259		return;
 260
 261	hif_dev = tx_buf->hif_dev;
 262
 263	switch (urb->status) {
 264	case 0:
 265		break;
 266	case -ENOENT:
 267	case -ECONNRESET:
 268	case -ENODEV:
 269	case -ESHUTDOWN:
 270		txok = false;
 271
 272		/*
 273		 * If the URBs are being flushed, no need to add this
 274		 * URB to the free list.
 275		 */
 276		spin_lock(&hif_dev->tx.tx_lock);
 277		if (hif_dev->tx.flags & HIF_USB_TX_FLUSH) {
 278			spin_unlock(&hif_dev->tx.tx_lock);
 279			ath9k_skb_queue_purge(hif_dev, &tx_buf->skb_queue);
 280			return;
 281		}
 282		spin_unlock(&hif_dev->tx.tx_lock);
 283
 284		break;
 285	default:
 286		txok = false;
 287		break;
 288	}
 289
 290	ath9k_skb_queue_complete(hif_dev, &tx_buf->skb_queue, txok);
 291
 292	/* Re-initialize the SKB queue */
 293	tx_buf->len = tx_buf->offset = 0;
 294	__skb_queue_head_init(&tx_buf->skb_queue);
 295
 296	/* Add this TX buffer to the free list */
 297	spin_lock(&hif_dev->tx.tx_lock);
 298	list_move_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 299	hif_dev->tx.tx_buf_cnt++;
 300	if (!(hif_dev->tx.flags & HIF_USB_TX_STOP))
 301		__hif_usb_tx(hif_dev); /* Check for pending SKBs */
 302	TX_STAT_INC(buf_completed);
 303	spin_unlock(&hif_dev->tx.tx_lock);
 304}
 305
 306/* TX lock has to be taken */
 307static int __hif_usb_tx(struct hif_device_usb *hif_dev)
 308{
 309	struct tx_buf *tx_buf = NULL;
 310	struct sk_buff *nskb = NULL;
 311	int ret = 0, i;
 312	u16 tx_skb_cnt = 0;
 313	u8 *buf;
 314	__le16 *hdr;
 315
 316	if (hif_dev->tx.tx_skb_cnt == 0)
 317		return 0;
 318
 319	/* Check if a free TX buffer is available */
 320	if (list_empty(&hif_dev->tx.tx_buf))
 321		return 0;
 322
 323	tx_buf = list_first_entry(&hif_dev->tx.tx_buf, struct tx_buf, list);
 324	list_move_tail(&tx_buf->list, &hif_dev->tx.tx_pending);
 325	hif_dev->tx.tx_buf_cnt--;
 326
 327	tx_skb_cnt = min_t(u16, hif_dev->tx.tx_skb_cnt, MAX_TX_AGGR_NUM);
 328
 329	for (i = 0; i < tx_skb_cnt; i++) {
 330		nskb = __skb_dequeue(&hif_dev->tx.tx_skb_queue);
 331
 332		/* Should never be NULL */
 333		BUG_ON(!nskb);
 334
 335		hif_dev->tx.tx_skb_cnt--;
 336
 337		buf = tx_buf->buf;
 338		buf += tx_buf->offset;
 339		hdr = (__le16 *)buf;
 340		*hdr++ = cpu_to_le16(nskb->len);
 341		*hdr++ = cpu_to_le16(ATH_USB_TX_STREAM_MODE_TAG);
 342		buf += 4;
 343		memcpy(buf, nskb->data, nskb->len);
 344		tx_buf->len = nskb->len + 4;
 345
 346		if (i < (tx_skb_cnt - 1))
 347			tx_buf->offset += (((tx_buf->len - 1) / 4) + 1) * 4;
 348
 349		if (i == (tx_skb_cnt - 1))
 350			tx_buf->len += tx_buf->offset;
 351
 352		__skb_queue_tail(&tx_buf->skb_queue, nskb);
 353		TX_STAT_INC(skb_queued);
 354	}
 355
 356	usb_fill_bulk_urb(tx_buf->urb, hif_dev->udev,
 357			  usb_sndbulkpipe(hif_dev->udev, USB_WLAN_TX_PIPE),
 358			  tx_buf->buf, tx_buf->len,
 359			  hif_usb_tx_cb, tx_buf);
 360
 361	ret = usb_submit_urb(tx_buf->urb, GFP_ATOMIC);
 362	if (ret) {
 363		tx_buf->len = tx_buf->offset = 0;
 364		ath9k_skb_queue_complete(hif_dev, &tx_buf->skb_queue, false);
 365		__skb_queue_head_init(&tx_buf->skb_queue);
 366		list_move_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 367		hif_dev->tx.tx_buf_cnt++;
 368	}
 369
 370	if (!ret)
 371		TX_STAT_INC(buf_queued);
 372
 373	return ret;
 374}
 375
 376static int hif_usb_send_tx(struct hif_device_usb *hif_dev, struct sk_buff *skb)
 377{
 378	struct ath9k_htc_tx_ctl *tx_ctl;
 379	unsigned long flags;
 380	int ret = 0;
 381
 382	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 383
 384	if (hif_dev->tx.flags & HIF_USB_TX_STOP) {
 385		spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 386		return -ENODEV;
 387	}
 388
 389	/* Check if the max queue count has been reached */
 390	if (hif_dev->tx.tx_skb_cnt > MAX_TX_BUF_NUM) {
 391		spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 392		return -ENOMEM;
 393	}
 394
 395	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 396
 397	tx_ctl = HTC_SKB_CB(skb);
 398
 399	/* Mgmt/Beacon frames don't use the TX buffer pool */
 400	if ((tx_ctl->type == ATH9K_HTC_MGMT) ||
 401	    (tx_ctl->type == ATH9K_HTC_BEACON)) {
 402		ret = hif_usb_send_mgmt(hif_dev, skb);
 403	}
 404
 405	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 406
 407	if ((tx_ctl->type == ATH9K_HTC_NORMAL) ||
 408	    (tx_ctl->type == ATH9K_HTC_AMPDU)) {
 409		__skb_queue_tail(&hif_dev->tx.tx_skb_queue, skb);
 410		hif_dev->tx.tx_skb_cnt++;
 411	}
 412
 413	/* Check if AMPDUs have to be sent immediately */
 414	if ((hif_dev->tx.tx_buf_cnt == MAX_TX_URB_NUM) &&
 415	    (hif_dev->tx.tx_skb_cnt < 2)) {
 416		__hif_usb_tx(hif_dev);
 417	}
 418
 419	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 420
 421	return ret;
 422}
 423
 424static void hif_usb_start(void *hif_handle)
 425{
 426	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 427	unsigned long flags;
 428
 429	hif_dev->flags |= HIF_USB_START;
 430
 431	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 432	hif_dev->tx.flags &= ~HIF_USB_TX_STOP;
 433	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 434}
 435
 436static void hif_usb_stop(void *hif_handle)
 437{
 438	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 439	struct tx_buf *tx_buf = NULL, *tx_buf_tmp = NULL;
 440	unsigned long flags;
 441
 442	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 443	ath9k_skb_queue_complete(hif_dev, &hif_dev->tx.tx_skb_queue, false);
 444	hif_dev->tx.tx_skb_cnt = 0;
 445	hif_dev->tx.flags |= HIF_USB_TX_STOP;
 446	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 447
 448	/* The pending URBs have to be canceled. */
 449	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 450				 &hif_dev->tx.tx_pending, list) {
 451		usb_kill_urb(tx_buf->urb);
 452	}
 453
 454	usb_kill_anchored_urbs(&hif_dev->mgmt_submitted);
 455}
 456
 457static int hif_usb_send(void *hif_handle, u8 pipe_id, struct sk_buff *skb)
 458{
 459	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 460	int ret = 0;
 461
 462	switch (pipe_id) {
 463	case USB_WLAN_TX_PIPE:
 464		ret = hif_usb_send_tx(hif_dev, skb);
 465		break;
 466	case USB_REG_OUT_PIPE:
 467		ret = hif_usb_send_regout(hif_dev, skb);
 468		break;
 469	default:
 470		dev_err(&hif_dev->udev->dev,
 471			"ath9k_htc: Invalid TX pipe: %d\n", pipe_id);
 472		ret = -EINVAL;
 473		break;
 474	}
 475
 476	return ret;
 477}
 478
 479static inline bool check_index(struct sk_buff *skb, u8 idx)
 480{
 481	struct ath9k_htc_tx_ctl *tx_ctl;
 482
 483	tx_ctl = HTC_SKB_CB(skb);
 484
 485	if ((tx_ctl->type == ATH9K_HTC_AMPDU) &&
 486	    (tx_ctl->sta_idx == idx))
 487		return true;
 488
 489	return false;
 490}
 491
 492static void hif_usb_sta_drain(void *hif_handle, u8 idx)
 493{
 494	struct hif_device_usb *hif_dev = (struct hif_device_usb *)hif_handle;
 495	struct sk_buff *skb, *tmp;
 496	unsigned long flags;
 497
 498	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 499
 500	skb_queue_walk_safe(&hif_dev->tx.tx_skb_queue, skb, tmp) {
 501		if (check_index(skb, idx)) {
 502			__skb_unlink(skb, &hif_dev->tx.tx_skb_queue);
 503			ath9k_htc_txcompletion_cb(hif_dev->htc_handle,
 504						  skb, false);
 505			hif_dev->tx.tx_skb_cnt--;
 506			TX_STAT_INC(skb_failed);
 507		}
 508	}
 509
 510	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 511}
 512
 513static struct ath9k_htc_hif hif_usb = {
 514	.transport = ATH9K_HIF_USB,
 515	.name = "ath9k_hif_usb",
 516
 517	.control_ul_pipe = USB_REG_OUT_PIPE,
 518	.control_dl_pipe = USB_REG_IN_PIPE,
 519
 520	.start = hif_usb_start,
 521	.stop = hif_usb_stop,
 522	.sta_drain = hif_usb_sta_drain,
 523	.send = hif_usb_send,
 524};
 525
 526static void ath9k_hif_usb_rx_stream(struct hif_device_usb *hif_dev,
 527				    struct sk_buff *skb)
 528{
 529	struct sk_buff *nskb, *skb_pool[MAX_PKT_NUM_IN_TRANSFER];
 530	int index = 0, i = 0, len = skb->len;
 531	int rx_remain_len, rx_pkt_len;
 532	u16 pool_index = 0;
 533	u8 *ptr;
 534
 535	spin_lock(&hif_dev->rx_lock);
 536
 537	rx_remain_len = hif_dev->rx_remain_len;
 538	rx_pkt_len = hif_dev->rx_transfer_len;
 539
 540	if (rx_remain_len != 0) {
 541		struct sk_buff *remain_skb = hif_dev->remain_skb;
 542
 543		if (remain_skb) {
 544			ptr = (u8 *) remain_skb->data;
 545
 546			index = rx_remain_len;
 547			rx_remain_len -= hif_dev->rx_pad_len;
 548			ptr += rx_pkt_len;
 549
 550			memcpy(ptr, skb->data, rx_remain_len);
 551
 552			rx_pkt_len += rx_remain_len;
 553			hif_dev->rx_remain_len = 0;
 554			skb_put(remain_skb, rx_pkt_len);
 555
 556			skb_pool[pool_index++] = remain_skb;
 557
 558		} else {
 559			index = rx_remain_len;
 560		}
 561	}
 562
 563	spin_unlock(&hif_dev->rx_lock);
 564
 565	while (index < len) {
 566		u16 pkt_len;
 567		u16 pkt_tag;
 568		u16 pad_len;
 569		int chk_idx;
 570
 571		ptr = (u8 *) skb->data;
 572
 573		pkt_len = get_unaligned_le16(ptr + index);
 574		pkt_tag = get_unaligned_le16(ptr + index + 2);
 575
 576		if (pkt_tag != ATH_USB_RX_STREAM_MODE_TAG) {
 577			RX_STAT_INC(skb_dropped);
 578			return;
 579		}
 580
 581		pad_len = 4 - (pkt_len & 0x3);
 582		if (pad_len == 4)
 583			pad_len = 0;
 584
 585		chk_idx = index;
 586		index = index + 4 + pkt_len + pad_len;
 587
 588		if (index > MAX_RX_BUF_SIZE) {
 589			spin_lock(&hif_dev->rx_lock);
 590			hif_dev->rx_remain_len = index - MAX_RX_BUF_SIZE;
 591			hif_dev->rx_transfer_len =
 592				MAX_RX_BUF_SIZE - chk_idx - 4;
 593			hif_dev->rx_pad_len = pad_len;
 594
 595			nskb = __dev_alloc_skb(pkt_len + 32, GFP_ATOMIC);
 596			if (!nskb) {
 597				dev_err(&hif_dev->udev->dev,
 598					"ath9k_htc: RX memory allocation error\n");
 599				spin_unlock(&hif_dev->rx_lock);
 600				goto err;
 601			}
 602			skb_reserve(nskb, 32);
 603			RX_STAT_INC(skb_allocated);
 604
 605			memcpy(nskb->data, &(skb->data[chk_idx+4]),
 606			       hif_dev->rx_transfer_len);
 607
 608			/* Record the buffer pointer */
 609			hif_dev->remain_skb = nskb;
 610			spin_unlock(&hif_dev->rx_lock);
 611		} else {
 612			nskb = __dev_alloc_skb(pkt_len + 32, GFP_ATOMIC);
 613			if (!nskb) {
 614				dev_err(&hif_dev->udev->dev,
 615					"ath9k_htc: RX memory allocation error\n");
 616				goto err;
 617			}
 618			skb_reserve(nskb, 32);
 619			RX_STAT_INC(skb_allocated);
 620
 621			memcpy(nskb->data, &(skb->data[chk_idx+4]), pkt_len);
 622			skb_put(nskb, pkt_len);
 623			skb_pool[pool_index++] = nskb;
 624		}
 625	}
 626
 627err:
 628	for (i = 0; i < pool_index; i++) {
 629		RX_STAT_ADD(skb_completed_bytes, skb_pool[i]->len);
 630		ath9k_htc_rx_msg(hif_dev->htc_handle, skb_pool[i],
 631				 skb_pool[i]->len, USB_WLAN_RX_PIPE);
 632		RX_STAT_INC(skb_completed);
 633	}
 634}
 635
 636static void ath9k_hif_usb_rx_cb(struct urb *urb)
 637{
 638	struct sk_buff *skb = (struct sk_buff *) urb->context;
 639	struct hif_device_usb *hif_dev =
 640		usb_get_intfdata(usb_ifnum_to_if(urb->dev, 0));
 641	int ret;
 642
 643	if (!skb)
 644		return;
 645
 646	if (!hif_dev)
 647		goto free;
 648
 649	switch (urb->status) {
 650	case 0:
 651		break;
 652	case -ENOENT:
 653	case -ECONNRESET:
 654	case -ENODEV:
 655	case -ESHUTDOWN:
 656		goto free;
 657	default:
 658		goto resubmit;
 659	}
 660
 661	if (likely(urb->actual_length != 0)) {
 662		skb_put(skb, urb->actual_length);
 663		ath9k_hif_usb_rx_stream(hif_dev, skb);
 664	}
 665
 666resubmit:
 667	skb_reset_tail_pointer(skb);
 668	skb_trim(skb, 0);
 669
 670	usb_anchor_urb(urb, &hif_dev->rx_submitted);
 671	ret = usb_submit_urb(urb, GFP_ATOMIC);
 672	if (ret) {
 673		usb_unanchor_urb(urb);
 674		goto free;
 675	}
 676
 677	return;
 678free:
 679	kfree_skb(skb);
 680}
 681
 682static void ath9k_hif_usb_reg_in_cb(struct urb *urb)
 683{
 684	struct sk_buff *skb = (struct sk_buff *) urb->context;
 685	struct sk_buff *nskb;
 686	struct hif_device_usb *hif_dev =
 687		usb_get_intfdata(usb_ifnum_to_if(urb->dev, 0));
 688	int ret;
 689
 690	if (!skb)
 691		return;
 692
 693	if (!hif_dev)
 694		goto free;
 695
 696	switch (urb->status) {
 697	case 0:
 698		break;
 699	case -ENOENT:
 700	case -ECONNRESET:
 701	case -ENODEV:
 702	case -ESHUTDOWN:
 703		goto free;
 704	default:
 705		skb_reset_tail_pointer(skb);
 706		skb_trim(skb, 0);
 707
 708		goto resubmit;
 709	}
 710
 711	if (likely(urb->actual_length != 0)) {
 712		skb_put(skb, urb->actual_length);
 713
 714		/* Process the command first */
 715		ath9k_htc_rx_msg(hif_dev->htc_handle, skb,
 716				 skb->len, USB_REG_IN_PIPE);
 717
 718
 719		nskb = alloc_skb(MAX_REG_IN_BUF_SIZE, GFP_ATOMIC);
 720		if (!nskb) {
 721			dev_err(&hif_dev->udev->dev,
 722				"ath9k_htc: REG_IN memory allocation failure\n");
 723			urb->context = NULL;
 724			return;
 725		}
 726
 727		usb_fill_int_urb(urb, hif_dev->udev,
 728				 usb_rcvintpipe(hif_dev->udev,
 729						 USB_REG_IN_PIPE),
 730				 nskb->data, MAX_REG_IN_BUF_SIZE,
 731				 ath9k_hif_usb_reg_in_cb, nskb, 1);
 732	}
 733
 734resubmit:
 735	usb_anchor_urb(urb, &hif_dev->reg_in_submitted);
 736	ret = usb_submit_urb(urb, GFP_ATOMIC);
 737	if (ret) {
 738		usb_unanchor_urb(urb);
 739		goto free;
 740	}
 741
 742	return;
 743free:
 744	kfree_skb(skb);
 745	urb->context = NULL;
 746}
 747
 748static void ath9k_hif_usb_dealloc_tx_urbs(struct hif_device_usb *hif_dev)
 749{
 750	struct tx_buf *tx_buf = NULL, *tx_buf_tmp = NULL;
 751	unsigned long flags;
 752
 753	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 754				 &hif_dev->tx.tx_buf, list) {
 755		usb_kill_urb(tx_buf->urb);
 756		list_del(&tx_buf->list);
 757		usb_free_urb(tx_buf->urb);
 758		kfree(tx_buf->buf);
 759		kfree(tx_buf);
 760	}
 761
 762	spin_lock_irqsave(&hif_dev->tx.tx_lock, flags);
 763	hif_dev->tx.flags |= HIF_USB_TX_FLUSH;
 764	spin_unlock_irqrestore(&hif_dev->tx.tx_lock, flags);
 765
 766	list_for_each_entry_safe(tx_buf, tx_buf_tmp,
 767				 &hif_dev->tx.tx_pending, list) {
 768		usb_kill_urb(tx_buf->urb);
 769		list_del(&tx_buf->list);
 770		usb_free_urb(tx_buf->urb);
 771		kfree(tx_buf->buf);
 772		kfree(tx_buf);
 773	}
 774
 775	usb_kill_anchored_urbs(&hif_dev->mgmt_submitted);
 776}
 777
 778static int ath9k_hif_usb_alloc_tx_urbs(struct hif_device_usb *hif_dev)
 779{
 780	struct tx_buf *tx_buf;
 781	int i;
 782
 783	INIT_LIST_HEAD(&hif_dev->tx.tx_buf);
 784	INIT_LIST_HEAD(&hif_dev->tx.tx_pending);
 785	spin_lock_init(&hif_dev->tx.tx_lock);
 786	__skb_queue_head_init(&hif_dev->tx.tx_skb_queue);
 787	init_usb_anchor(&hif_dev->mgmt_submitted);
 788
 789	for (i = 0; i < MAX_TX_URB_NUM; i++) {
 790		tx_buf = kzalloc(sizeof(struct tx_buf), GFP_KERNEL);
 791		if (!tx_buf)
 792			goto err;
 793
 794		tx_buf->buf = kzalloc(MAX_TX_BUF_SIZE, GFP_KERNEL);
 795		if (!tx_buf->buf)
 796			goto err;
 797
 798		tx_buf->urb = usb_alloc_urb(0, GFP_KERNEL);
 799		if (!tx_buf->urb)
 800			goto err;
 801
 802		tx_buf->hif_dev = hif_dev;
 803		__skb_queue_head_init(&tx_buf->skb_queue);
 804
 805		list_add_tail(&tx_buf->list, &hif_dev->tx.tx_buf);
 806	}
 807
 808	hif_dev->tx.tx_buf_cnt = MAX_TX_URB_NUM;
 809
 810	return 0;
 811err:
 812	if (tx_buf) {
 813		kfree(tx_buf->buf);
 814		kfree(tx_buf);
 815	}
 816	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 817	return -ENOMEM;
 818}
 819
 820static void ath9k_hif_usb_dealloc_rx_urbs(struct hif_device_usb *hif_dev)
 821{
 822	usb_kill_anchored_urbs(&hif_dev->rx_submitted);
 823}
 824
 825static int ath9k_hif_usb_alloc_rx_urbs(struct hif_device_usb *hif_dev)
 826{
 827	struct urb *urb = NULL;
 828	struct sk_buff *skb = NULL;
 829	int i, ret;
 830
 831	init_usb_anchor(&hif_dev->rx_submitted);
 832	spin_lock_init(&hif_dev->rx_lock);
 833
 834	for (i = 0; i < MAX_RX_URB_NUM; i++) {
 835
 836		/* Allocate URB */
 837		urb = usb_alloc_urb(0, GFP_KERNEL);
 838		if (urb == NULL) {
 839			ret = -ENOMEM;
 840			goto err_urb;
 841		}
 842
 843		/* Allocate buffer */
 844		skb = alloc_skb(MAX_RX_BUF_SIZE, GFP_KERNEL);
 845		if (!skb) {
 846			ret = -ENOMEM;
 847			goto err_skb;
 848		}
 849
 850		usb_fill_bulk_urb(urb, hif_dev->udev,
 851				  usb_rcvbulkpipe(hif_dev->udev,
 852						  USB_WLAN_RX_PIPE),
 853				  skb->data, MAX_RX_BUF_SIZE,
 854				  ath9k_hif_usb_rx_cb, skb);
 855
 856		/* Anchor URB */
 857		usb_anchor_urb(urb, &hif_dev->rx_submitted);
 858
 859		/* Submit URB */
 860		ret = usb_submit_urb(urb, GFP_KERNEL);
 861		if (ret) {
 862			usb_unanchor_urb(urb);
 863			goto err_submit;
 864		}
 865
 866		/*
 867		 * Drop reference count.
 868		 * This ensures that the URB is freed when killing them.
 869		 */
 870		usb_free_urb(urb);
 871	}
 872
 873	return 0;
 874
 875err_submit:
 876	kfree_skb(skb);
 877err_skb:
 878	usb_free_urb(urb);
 879err_urb:
 880	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 881	return ret;
 882}
 883
 884static void ath9k_hif_usb_dealloc_reg_in_urbs(struct hif_device_usb *hif_dev)
 885{
 886	usb_kill_anchored_urbs(&hif_dev->reg_in_submitted);
 887}
 888
 889static int ath9k_hif_usb_alloc_reg_in_urbs(struct hif_device_usb *hif_dev)
 890{
 891	struct urb *urb = NULL;
 892	struct sk_buff *skb = NULL;
 893	int i, ret;
 894
 895	init_usb_anchor(&hif_dev->reg_in_submitted);
 896
 897	for (i = 0; i < MAX_REG_IN_URB_NUM; i++) {
 898
 899		/* Allocate URB */
 900		urb = usb_alloc_urb(0, GFP_KERNEL);
 901		if (urb == NULL) {
 902			ret = -ENOMEM;
 903			goto err_urb;
 904		}
 905
 906		/* Allocate buffer */
 907		skb = alloc_skb(MAX_REG_IN_BUF_SIZE, GFP_KERNEL);
 908		if (!skb) {
 909			ret = -ENOMEM;
 910			goto err_skb;
 911		}
 912
 913		usb_fill_int_urb(urb, hif_dev->udev,
 914				  usb_rcvintpipe(hif_dev->udev,
 915						  USB_REG_IN_PIPE),
 916				  skb->data, MAX_REG_IN_BUF_SIZE,
 917				  ath9k_hif_usb_reg_in_cb, skb, 1);
 918
 919		/* Anchor URB */
 920		usb_anchor_urb(urb, &hif_dev->reg_in_submitted);
 921
 922		/* Submit URB */
 923		ret = usb_submit_urb(urb, GFP_KERNEL);
 924		if (ret) {
 925			usb_unanchor_urb(urb);
 926			goto err_submit;
 927		}
 928
 929		/*
 930		 * Drop reference count.
 931		 * This ensures that the URB is freed when killing them.
 932		 */
 933		usb_free_urb(urb);
 934	}
 935
 936	return 0;
 937
 938err_submit:
 939	kfree_skb(skb);
 940err_skb:
 941	usb_free_urb(urb);
 942err_urb:
 943	ath9k_hif_usb_dealloc_reg_in_urbs(hif_dev);
 944	return ret;
 945}
 946
 947static int ath9k_hif_usb_alloc_urbs(struct hif_device_usb *hif_dev)
 948{
 949	/* Register Write */
 950	init_usb_anchor(&hif_dev->regout_submitted);
 951
 952	/* TX */
 953	if (ath9k_hif_usb_alloc_tx_urbs(hif_dev) < 0)
 954		goto err;
 955
 956	/* RX */
 957	if (ath9k_hif_usb_alloc_rx_urbs(hif_dev) < 0)
 958		goto err_rx;
 959
 960	/* Register Read */
 961	if (ath9k_hif_usb_alloc_reg_in_urbs(hif_dev) < 0)
 962		goto err_reg;
 963
 964	return 0;
 965err_reg:
 966	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 967err_rx:
 968	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 969err:
 970	return -ENOMEM;
 971}
 972
 973static void ath9k_hif_usb_dealloc_urbs(struct hif_device_usb *hif_dev)
 974{
 975	usb_kill_anchored_urbs(&hif_dev->regout_submitted);
 976	ath9k_hif_usb_dealloc_reg_in_urbs(hif_dev);
 977	ath9k_hif_usb_dealloc_tx_urbs(hif_dev);
 978	ath9k_hif_usb_dealloc_rx_urbs(hif_dev);
 979}
 980
 981static int ath9k_hif_usb_download_fw(struct hif_device_usb *hif_dev)
 
 982{
 983	int transfer, err;
 984	const void *data = hif_dev->fw_data;
 985	size_t len = hif_dev->fw_size;
 986	u32 addr = AR9271_FIRMWARE;
 987	u8 *buf = kzalloc(4096, GFP_KERNEL);
 988	u32 firm_offset;
 989
 990	if (!buf)
 991		return -ENOMEM;
 992
 993	while (len) {
 994		transfer = min_t(size_t, len, 4096);
 995		memcpy(buf, data, transfer);
 996
 997		err = usb_control_msg(hif_dev->udev,
 998				      usb_sndctrlpipe(hif_dev->udev, 0),
 999				      FIRMWARE_DOWNLOAD, 0x40 | USB_DIR_OUT,
1000				      addr >> 8, 0, buf, transfer, HZ);
1001		if (err < 0) {
1002			kfree(buf);
1003			return err;
1004		}
1005
1006		len -= transfer;
1007		data += transfer;
1008		addr += transfer;
1009	}
1010	kfree(buf);
1011
1012	if (IS_AR7010_DEVICE(hif_dev->usb_device_id->driver_info))
1013		firm_offset = AR7010_FIRMWARE_TEXT;
1014	else
1015		firm_offset = AR9271_FIRMWARE_TEXT;
1016
1017	/*
1018	 * Issue FW download complete command to firmware.
1019	 */
1020	err = usb_control_msg(hif_dev->udev, usb_sndctrlpipe(hif_dev->udev, 0),
1021			      FIRMWARE_DOWNLOAD_COMP,
1022			      0x40 | USB_DIR_OUT,
1023			      firm_offset >> 8, 0, NULL, 0, HZ);
1024	if (err)
1025		return -EIO;
1026
1027	dev_info(&hif_dev->udev->dev, "ath9k_htc: Transferred FW: %s, size: %ld\n",
1028		 hif_dev->fw_name, (unsigned long) hif_dev->fw_size);
1029
1030	return 0;
1031}
1032
1033static int ath9k_hif_usb_dev_init(struct hif_device_usb *hif_dev)
1034{
1035	int ret;
 
 
 
 
 
 
 
 
 
 
 
1036
1037	ret = ath9k_hif_usb_download_fw(hif_dev);
 
1038	if (ret) {
1039		dev_err(&hif_dev->udev->dev,
1040			"ath9k_htc: Firmware - %s download failed\n",
1041			hif_dev->fw_name);
1042		return ret;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1043	}
1044
1045	/* Alloc URBs */
1046	ret = ath9k_hif_usb_alloc_urbs(hif_dev);
1047	if (ret) {
1048		dev_err(&hif_dev->udev->dev,
1049			"ath9k_htc: Unable to allocate URBs\n");
1050		return ret;
1051	}
1052
1053	return 0;
 
 
 
 
 
 
1054}
1055
1056static void ath9k_hif_usb_dev_deinit(struct hif_device_usb *hif_dev)
1057{
1058	ath9k_hif_usb_dealloc_urbs(hif_dev);
1059}
1060
1061/*
1062 * If initialization fails or the FW cannot be retrieved,
1063 * detach the device.
1064 */
1065static void ath9k_hif_usb_firmware_fail(struct hif_device_usb *hif_dev)
1066{
1067	struct device *dev = &hif_dev->udev->dev;
1068	struct device *parent = dev->parent;
1069
1070	complete_all(&hif_dev->fw_done);
1071
1072	if (parent)
1073		device_lock(parent);
1074
1075	device_release_driver(dev);
1076
1077	if (parent)
1078		device_unlock(parent);
1079}
1080
1081static void ath9k_hif_usb_firmware_cb(const struct firmware *fw, void *context);
1082
1083/* taken from iwlwifi */
1084static int ath9k_hif_request_firmware(struct hif_device_usb *hif_dev,
1085				      bool first)
1086{
1087	char index[8], *chip;
1088	int ret;
1089
1090	if (first) {
1091		if (htc_use_dev_fw) {
1092			hif_dev->fw_minor_index = FIRMWARE_MINOR_IDX_MAX + 1;
1093			sprintf(index, "%s", "dev");
1094		} else {
1095			hif_dev->fw_minor_index = FIRMWARE_MINOR_IDX_MAX;
1096			sprintf(index, "%d", hif_dev->fw_minor_index);
1097		}
1098	} else {
1099		hif_dev->fw_minor_index--;
1100		sprintf(index, "%d", hif_dev->fw_minor_index);
1101	}
1102
1103	/* test for FW 1.3 */
1104	if (MAJOR_VERSION_REQ == 1 && hif_dev->fw_minor_index == 3) {
1105		const char *filename;
1106
1107		if (IS_AR7010_DEVICE(hif_dev->usb_device_id->driver_info))
1108			filename = FIRMWARE_AR7010_1_1;
1109		else
1110			filename = FIRMWARE_AR9271;
1111
1112		/* expected fw locations:
1113		 * - htc_9271.fw   (stable version 1.3, depricated)
1114		 */
1115		snprintf(hif_dev->fw_name, sizeof(hif_dev->fw_name),
1116			 "%s", filename);
1117
1118	} else if (hif_dev->fw_minor_index < FIRMWARE_MINOR_IDX_MIN) {
1119		dev_err(&hif_dev->udev->dev, "no suitable firmware found!\n");
1120
1121		return -ENOENT;
1122	} else {
1123		if (IS_AR7010_DEVICE(hif_dev->usb_device_id->driver_info))
1124			chip = "7010";
1125		else
1126			chip = "9271";
1127
1128		/* expected fw locations:
1129		 * - ath9k_htc/htc_9271-1.dev.0.fw (development version)
1130		 * - ath9k_htc/htc_9271-1.4.0.fw   (stable version)
1131		 */
1132		snprintf(hif_dev->fw_name, sizeof(hif_dev->fw_name),
1133			 "%s/htc_%s-%d.%s.0.fw", HTC_FW_PATH,
1134			 chip, MAJOR_VERSION_REQ, index);
1135	}
1136
1137	ret = request_firmware_nowait(THIS_MODULE, true, hif_dev->fw_name,
1138				      &hif_dev->udev->dev, GFP_KERNEL,
1139				      hif_dev, ath9k_hif_usb_firmware_cb);
1140	if (ret) {
1141		dev_err(&hif_dev->udev->dev,
1142			"ath9k_htc: Async request for firmware %s failed\n",
1143			hif_dev->fw_name);
1144		return ret;
1145	}
1146
1147	dev_info(&hif_dev->udev->dev, "ath9k_htc: Firmware %s requested\n",
1148		 hif_dev->fw_name);
1149
1150	return ret;
1151}
1152
1153static void ath9k_hif_usb_firmware_cb(const struct firmware *fw, void *context)
1154{
1155	struct hif_device_usb *hif_dev = context;
1156	int ret;
1157
1158	if (!fw) {
1159		ret = ath9k_hif_request_firmware(hif_dev, false);
1160		if (!ret)
1161			return;
1162
1163		dev_err(&hif_dev->udev->dev,
1164			"ath9k_htc: Failed to get firmware %s\n",
1165			hif_dev->fw_name);
1166		goto err_fw;
1167	}
1168
1169	hif_dev->htc_handle = ath9k_htc_hw_alloc(hif_dev, &hif_usb,
1170						 &hif_dev->udev->dev);
1171	if (hif_dev->htc_handle == NULL)
1172		goto err_dev_alloc;
1173
1174	hif_dev->fw_data = fw->data;
1175	hif_dev->fw_size = fw->size;
1176
1177	/* Proceed with initialization */
1178
1179	ret = ath9k_hif_usb_dev_init(hif_dev);
1180	if (ret)
1181		goto err_dev_init;
1182
1183	ret = ath9k_htc_hw_init(hif_dev->htc_handle,
1184				&hif_dev->interface->dev,
1185				hif_dev->usb_device_id->idProduct,
1186				hif_dev->udev->product,
1187				hif_dev->usb_device_id->driver_info);
1188	if (ret) {
1189		ret = -EINVAL;
1190		goto err_htc_hw_init;
1191	}
1192
1193	release_firmware(fw);
1194	hif_dev->flags |= HIF_USB_READY;
1195	complete_all(&hif_dev->fw_done);
1196
1197	return;
1198
1199err_htc_hw_init:
1200	ath9k_hif_usb_dev_deinit(hif_dev);
1201err_dev_init:
1202	ath9k_htc_hw_free(hif_dev->htc_handle);
1203err_dev_alloc:
1204	release_firmware(fw);
1205err_fw:
1206	ath9k_hif_usb_firmware_fail(hif_dev);
1207}
1208
1209/*
1210 * An exact copy of the function from zd1211rw.
1211 */
1212static int send_eject_command(struct usb_interface *interface)
1213{
1214	struct usb_device *udev = interface_to_usbdev(interface);
1215	struct usb_host_interface *iface_desc = &interface->altsetting[0];
1216	struct usb_endpoint_descriptor *endpoint;
1217	unsigned char *cmd;
1218	u8 bulk_out_ep;
1219	int r;
1220
1221	/* Find bulk out endpoint */
1222	for (r = 1; r >= 0; r--) {
1223		endpoint = &iface_desc->endpoint[r].desc;
1224		if (usb_endpoint_dir_out(endpoint) &&
1225		    usb_endpoint_xfer_bulk(endpoint)) {
1226			bulk_out_ep = endpoint->bEndpointAddress;
1227			break;
1228		}
1229	}
1230	if (r == -1) {
1231		dev_err(&udev->dev,
1232			"ath9k_htc: Could not find bulk out endpoint\n");
1233		return -ENODEV;
1234	}
1235
1236	cmd = kzalloc(31, GFP_KERNEL);
1237	if (cmd == NULL)
1238		return -ENODEV;
1239
1240	/* USB bulk command block */
1241	cmd[0] = 0x55;	/* bulk command signature */
1242	cmd[1] = 0x53;	/* bulk command signature */
1243	cmd[2] = 0x42;	/* bulk command signature */
1244	cmd[3] = 0x43;	/* bulk command signature */
1245	cmd[14] = 6;	/* command length */
1246
1247	cmd[15] = 0x1b;	/* SCSI command: START STOP UNIT */
1248	cmd[19] = 0x2;	/* eject disc */
1249
1250	dev_info(&udev->dev, "Ejecting storage device...\n");
1251	r = usb_bulk_msg(udev, usb_sndbulkpipe(udev, bulk_out_ep),
1252		cmd, 31, NULL, 2000);
1253	kfree(cmd);
1254	if (r)
1255		return r;
1256
1257	/* At this point, the device disconnects and reconnects with the real
1258	 * ID numbers. */
1259
1260	usb_set_intfdata(interface, NULL);
1261	return 0;
1262}
1263
1264static int ath9k_hif_usb_probe(struct usb_interface *interface,
1265			       const struct usb_device_id *id)
1266{
1267	struct usb_device *udev = interface_to_usbdev(interface);
1268	struct hif_device_usb *hif_dev;
1269	int ret = 0;
1270
1271	if (id->driver_info == STORAGE_DEVICE)
1272		return send_eject_command(interface);
1273
1274	hif_dev = kzalloc(sizeof(struct hif_device_usb), GFP_KERNEL);
1275	if (!hif_dev) {
1276		ret = -ENOMEM;
1277		goto err_alloc;
1278	}
1279
1280	usb_get_dev(udev);
1281
1282	hif_dev->udev = udev;
1283	hif_dev->interface = interface;
1284	hif_dev->usb_device_id = id;
1285#ifdef CONFIG_PM
1286	udev->reset_resume = 1;
1287#endif
1288	usb_set_intfdata(interface, hif_dev);
1289
1290	init_completion(&hif_dev->fw_done);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1291
1292	ret = ath9k_hif_request_firmware(hif_dev, true);
1293	if (ret)
1294		goto err_fw_req;
1295
1296	return ret;
1297
1298err_fw_req:
 
 
 
 
1299	usb_set_intfdata(interface, NULL);
1300	kfree(hif_dev);
1301	usb_put_dev(udev);
1302err_alloc:
1303	return ret;
1304}
1305
1306static void ath9k_hif_usb_reboot(struct usb_device *udev)
1307{
1308	u32 reboot_cmd = 0xffffffff;
1309	void *buf;
1310	int ret;
1311
1312	buf = kmemdup(&reboot_cmd, 4, GFP_KERNEL);
1313	if (!buf)
1314		return;
1315
1316	ret = usb_interrupt_msg(udev, usb_sndintpipe(udev, USB_REG_OUT_PIPE),
1317			   buf, 4, NULL, HZ);
1318	if (ret)
1319		dev_err(&udev->dev, "ath9k_htc: USB reboot failed\n");
1320
1321	kfree(buf);
1322}
1323
1324static void ath9k_hif_usb_disconnect(struct usb_interface *interface)
1325{
1326	struct usb_device *udev = interface_to_usbdev(interface);
1327	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1328	bool unplugged = (udev->state == USB_STATE_NOTATTACHED) ? true : false;
1329
1330	if (!hif_dev)
1331		return;
1332
1333	wait_for_completion(&hif_dev->fw_done);
1334
1335	if (hif_dev->flags & HIF_USB_READY) {
1336		ath9k_htc_hw_deinit(hif_dev->htc_handle, unplugged);
1337		ath9k_htc_hw_free(hif_dev->htc_handle);
1338		ath9k_hif_usb_dev_deinit(hif_dev);
1339	}
1340
1341	usb_set_intfdata(interface, NULL);
1342
1343	/* If firmware was loaded we should drop it
1344	 * go back to first stage bootloader. */
1345	if (!unplugged && (hif_dev->flags & HIF_USB_READY))
1346		ath9k_hif_usb_reboot(udev);
1347
1348	kfree(hif_dev);
1349	dev_info(&udev->dev, "ath9k_htc: USB layer deinitialized\n");
1350	usb_put_dev(udev);
1351}
1352
1353#ifdef CONFIG_PM
1354static int ath9k_hif_usb_suspend(struct usb_interface *interface,
1355				 pm_message_t message)
1356{
1357	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1358
1359	/*
1360	 * The device has to be set to FULLSLEEP mode in case no
1361	 * interface is up.
1362	 */
1363	if (!(hif_dev->flags & HIF_USB_START))
1364		ath9k_htc_suspend(hif_dev->htc_handle);
1365
1366	wait_for_completion(&hif_dev->fw_done);
1367
1368	if (hif_dev->flags & HIF_USB_READY)
1369		ath9k_hif_usb_dealloc_urbs(hif_dev);
1370
1371	return 0;
1372}
1373
1374static int ath9k_hif_usb_resume(struct usb_interface *interface)
1375{
1376	struct hif_device_usb *hif_dev = usb_get_intfdata(interface);
1377	struct htc_target *htc_handle = hif_dev->htc_handle;
1378	int ret;
1379	const struct firmware *fw;
1380
1381	ret = ath9k_hif_usb_alloc_urbs(hif_dev);
1382	if (ret)
1383		return ret;
1384
1385	if (hif_dev->flags & HIF_USB_READY) {
1386		/* request cached firmware during suspend/resume cycle */
1387		ret = request_firmware(&fw, hif_dev->fw_name,
1388				       &hif_dev->udev->dev);
1389		if (ret)
1390			goto fail_resume;
1391
1392		hif_dev->fw_data = fw->data;
1393		hif_dev->fw_size = fw->size;
1394		ret = ath9k_hif_usb_download_fw(hif_dev);
1395		release_firmware(fw);
1396		if (ret)
1397			goto fail_resume;
1398	} else {
1399		ath9k_hif_usb_dealloc_urbs(hif_dev);
1400		return -EIO;
1401	}
1402
1403	mdelay(100);
1404
1405	ret = ath9k_htc_resume(htc_handle);
1406
1407	if (ret)
1408		goto fail_resume;
1409
1410	return 0;
1411
1412fail_resume:
1413	ath9k_hif_usb_dealloc_urbs(hif_dev);
1414
1415	return ret;
1416}
1417#endif
1418
1419static struct usb_driver ath9k_hif_usb_driver = {
1420	.name = KBUILD_MODNAME,
1421	.probe = ath9k_hif_usb_probe,
1422	.disconnect = ath9k_hif_usb_disconnect,
1423#ifdef CONFIG_PM
1424	.suspend = ath9k_hif_usb_suspend,
1425	.resume = ath9k_hif_usb_resume,
1426	.reset_resume = ath9k_hif_usb_resume,
1427#endif
1428	.id_table = ath9k_hif_usb_ids,
1429	.soft_unbind = 1,
1430	.disable_hub_initiated_lpm = 1,
1431};
1432
1433int ath9k_hif_usb_init(void)
1434{
1435	return usb_register(&ath9k_hif_usb_driver);
1436}
1437
1438void ath9k_hif_usb_exit(void)
1439{
1440	usb_deregister(&ath9k_hif_usb_driver);
1441}