1 /*
2  * Copyright (c) 2007-2011 Atheros Communications Inc.
3  * Copyright (c) 2011-2012 Qualcomm Atheros, Inc.
4  *
5  * Permission to use, copy, modify, and/or distribute this software for any
6  * purpose with or without fee is hereby granted, provided that the above
7  * copyright notice and this permission notice appear in all copies.
8  *
9  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
16  */
17 
18 #include <linux/module.h>
19 #include <linux/usb.h>
20 
21 #include "debug.h"
22 #include "core.h"
23 
24 /* constants */
25 #define TX_URB_COUNT            32
26 #define RX_URB_COUNT            32
27 #define ATH6KL_USB_RX_BUFFER_SIZE  4096
28 
29 /* tx/rx pipes for usb */
30 enum ATH6KL_USB_PIPE_ID {
31 	ATH6KL_USB_PIPE_TX_CTRL = 0,
32 	ATH6KL_USB_PIPE_TX_DATA_LP,
33 	ATH6KL_USB_PIPE_TX_DATA_MP,
34 	ATH6KL_USB_PIPE_TX_DATA_HP,
35 	ATH6KL_USB_PIPE_RX_CTRL,
36 	ATH6KL_USB_PIPE_RX_DATA,
37 	ATH6KL_USB_PIPE_RX_DATA2,
38 	ATH6KL_USB_PIPE_RX_INT,
39 	ATH6KL_USB_PIPE_MAX
40 };
41 
42 #define ATH6KL_USB_PIPE_INVALID ATH6KL_USB_PIPE_MAX
43 
44 struct ath6kl_usb_pipe {
45 	struct list_head urb_list_head;
46 	struct usb_anchor urb_submitted;
47 	u32 urb_alloc;
48 	u32 urb_cnt;
49 	u32 urb_cnt_thresh;
50 	unsigned int usb_pipe_handle;
51 	u32 flags;
52 	u8 ep_address;
53 	u8 logical_pipe_num;
54 	struct ath6kl_usb *ar_usb;
55 	u16 max_packet_size;
56 	struct work_struct io_complete_work;
57 	struct sk_buff_head io_comp_queue;
58 	struct usb_endpoint_descriptor *ep_desc;
59 };
60 
61 #define ATH6KL_USB_PIPE_FLAG_TX    (1 << 0)
62 
63 /* usb device object */
64 struct ath6kl_usb {
65 	/* protects pipe->urb_list_head and  pipe->urb_cnt */
66 	spinlock_t cs_lock;
67 
68 	struct usb_device *udev;
69 	struct usb_interface *interface;
70 	struct ath6kl_usb_pipe pipes[ATH6KL_USB_PIPE_MAX];
71 	u8 *diag_cmd_buffer;
72 	u8 *diag_resp_buffer;
73 	struct ath6kl *ar;
74 };
75 
76 /* usb urb object */
77 struct ath6kl_urb_context {
78 	struct list_head link;
79 	struct ath6kl_usb_pipe *pipe;
80 	struct sk_buff *skb;
81 	struct ath6kl *ar;
82 };
83 
84 /* USB endpoint definitions */
85 #define ATH6KL_USB_EP_ADDR_APP_CTRL_IN          0x81
86 #define ATH6KL_USB_EP_ADDR_APP_DATA_IN          0x82
87 #define ATH6KL_USB_EP_ADDR_APP_DATA2_IN         0x83
88 #define ATH6KL_USB_EP_ADDR_APP_INT_IN           0x84
89 
90 #define ATH6KL_USB_EP_ADDR_APP_CTRL_OUT         0x01
91 #define ATH6KL_USB_EP_ADDR_APP_DATA_LP_OUT      0x02
92 #define ATH6KL_USB_EP_ADDR_APP_DATA_MP_OUT      0x03
93 #define ATH6KL_USB_EP_ADDR_APP_DATA_HP_OUT      0x04
94 
95 /* diagnostic command defnitions */
96 #define ATH6KL_USB_CONTROL_REQ_SEND_BMI_CMD        1
97 #define ATH6KL_USB_CONTROL_REQ_RECV_BMI_RESP       2
98 #define ATH6KL_USB_CONTROL_REQ_DIAG_CMD            3
99 #define ATH6KL_USB_CONTROL_REQ_DIAG_RESP           4
100 
101 #define ATH6KL_USB_CTRL_DIAG_CC_READ               0
102 #define ATH6KL_USB_CTRL_DIAG_CC_WRITE              1
103 
104 struct ath6kl_usb_ctrl_diag_cmd_write {
105 	__le32 cmd;
106 	__le32 address;
107 	__le32 value;
108 	__le32 _pad[1];
109 } __packed;
110 
111 struct ath6kl_usb_ctrl_diag_cmd_read {
112 	__le32 cmd;
113 	__le32 address;
114 } __packed;
115 
116 struct ath6kl_usb_ctrl_diag_resp_read {
117 	__le32 value;
118 } __packed;
119 
120 /* function declarations */
121 static void ath6kl_usb_recv_complete(struct urb *urb);
122 
123 #define ATH6KL_USB_IS_BULK_EP(attr) (((attr) & 3) == 0x02)
124 #define ATH6KL_USB_IS_INT_EP(attr)  (((attr) & 3) == 0x03)
125 #define ATH6KL_USB_IS_ISOC_EP(attr)  (((attr) & 3) == 0x01)
126 #define ATH6KL_USB_IS_DIR_IN(addr)  ((addr) & 0x80)
127 
128 /* pipe/urb operations */
129 static struct ath6kl_urb_context *
ath6kl_usb_alloc_urb_from_pipe(struct ath6kl_usb_pipe * pipe)130 ath6kl_usb_alloc_urb_from_pipe(struct ath6kl_usb_pipe *pipe)
131 {
132 	struct ath6kl_urb_context *urb_context = NULL;
133 	unsigned long flags;
134 
135 	/* bail if this pipe is not initialized */
136 	if (!pipe->ar_usb)
137 		return NULL;
138 
139 	spin_lock_irqsave(&pipe->ar_usb->cs_lock, flags);
140 	if (!list_empty(&pipe->urb_list_head)) {
141 		urb_context =
142 		    list_first_entry(&pipe->urb_list_head,
143 				     struct ath6kl_urb_context, link);
144 		list_del(&urb_context->link);
145 		pipe->urb_cnt--;
146 	}
147 	spin_unlock_irqrestore(&pipe->ar_usb->cs_lock, flags);
148 
149 	return urb_context;
150 }
151 
ath6kl_usb_free_urb_to_pipe(struct ath6kl_usb_pipe * pipe,struct ath6kl_urb_context * urb_context)152 static void ath6kl_usb_free_urb_to_pipe(struct ath6kl_usb_pipe *pipe,
153 					struct ath6kl_urb_context *urb_context)
154 {
155 	unsigned long flags;
156 
157 	/* bail if this pipe is not initialized */
158 	if (!pipe->ar_usb)
159 		return;
160 
161 	spin_lock_irqsave(&pipe->ar_usb->cs_lock, flags);
162 	pipe->urb_cnt++;
163 
164 	list_add(&urb_context->link, &pipe->urb_list_head);
165 	spin_unlock_irqrestore(&pipe->ar_usb->cs_lock, flags);
166 }
167 
ath6kl_usb_cleanup_recv_urb(struct ath6kl_urb_context * urb_context)168 static void ath6kl_usb_cleanup_recv_urb(struct ath6kl_urb_context *urb_context)
169 {
170 	dev_kfree_skb(urb_context->skb);
171 	urb_context->skb = NULL;
172 
173 	ath6kl_usb_free_urb_to_pipe(urb_context->pipe, urb_context);
174 }
175 
ath6kl_usb_priv(struct ath6kl * ar)176 static inline struct ath6kl_usb *ath6kl_usb_priv(struct ath6kl *ar)
177 {
178 	return ar->hif_priv;
179 }
180 
181 /* pipe resource allocation/cleanup */
ath6kl_usb_alloc_pipe_resources(struct ath6kl_usb_pipe * pipe,int urb_cnt)182 static int ath6kl_usb_alloc_pipe_resources(struct ath6kl_usb_pipe *pipe,
183 					   int urb_cnt)
184 {
185 	struct ath6kl_urb_context *urb_context;
186 	int status = 0, i;
187 
188 	INIT_LIST_HEAD(&pipe->urb_list_head);
189 	init_usb_anchor(&pipe->urb_submitted);
190 
191 	for (i = 0; i < urb_cnt; i++) {
192 		urb_context = kzalloc(sizeof(struct ath6kl_urb_context),
193 				      GFP_KERNEL);
194 		if (urb_context == NULL) {
195 			status = -ENOMEM;
196 			goto fail_alloc_pipe_resources;
197 		}
198 
199 		urb_context->pipe = pipe;
200 
201 		/*
202 		 * we are only allocate the urb contexts here, the actual URB
203 		 * is allocated from the kernel as needed to do a transaction
204 		 */
205 		pipe->urb_alloc++;
206 		ath6kl_usb_free_urb_to_pipe(pipe, urb_context);
207 	}
208 
209 	ath6kl_dbg(ATH6KL_DBG_USB,
210 		   "ath6kl usb: alloc resources lpipe:%d hpipe:0x%X urbs:%d\n",
211 		   pipe->logical_pipe_num, pipe->usb_pipe_handle,
212 		   pipe->urb_alloc);
213 
214 fail_alloc_pipe_resources:
215 	return status;
216 }
217 
ath6kl_usb_free_pipe_resources(struct ath6kl_usb_pipe * pipe)218 static void ath6kl_usb_free_pipe_resources(struct ath6kl_usb_pipe *pipe)
219 {
220 	struct ath6kl_urb_context *urb_context;
221 
222 	if (pipe->ar_usb == NULL) {
223 		/* nothing allocated for this pipe */
224 		return;
225 	}
226 
227 	ath6kl_dbg(ATH6KL_DBG_USB,
228 		   "ath6kl usb: free resources lpipe:%d"
229 		   "hpipe:0x%X urbs:%d avail:%d\n",
230 		   pipe->logical_pipe_num, pipe->usb_pipe_handle,
231 		   pipe->urb_alloc, pipe->urb_cnt);
232 
233 	if (pipe->urb_alloc != pipe->urb_cnt) {
234 		ath6kl_dbg(ATH6KL_DBG_USB,
235 			   "ath6kl usb: urb leak! lpipe:%d"
236 			   "hpipe:0x%X urbs:%d avail:%d\n",
237 			   pipe->logical_pipe_num, pipe->usb_pipe_handle,
238 			   pipe->urb_alloc, pipe->urb_cnt);
239 	}
240 
241 	while (true) {
242 		urb_context = ath6kl_usb_alloc_urb_from_pipe(pipe);
243 		if (urb_context == NULL)
244 			break;
245 		kfree(urb_context);
246 	}
247 }
248 
ath6kl_usb_cleanup_pipe_resources(struct ath6kl_usb * ar_usb)249 static void ath6kl_usb_cleanup_pipe_resources(struct ath6kl_usb *ar_usb)
250 {
251 	int i;
252 
253 	for (i = 0; i < ATH6KL_USB_PIPE_MAX; i++)
254 		ath6kl_usb_free_pipe_resources(&ar_usb->pipes[i]);
255 }
256 
ath6kl_usb_get_logical_pipe_num(struct ath6kl_usb * ar_usb,u8 ep_address,int * urb_count)257 static u8 ath6kl_usb_get_logical_pipe_num(struct ath6kl_usb *ar_usb,
258 					  u8 ep_address, int *urb_count)
259 {
260 	u8 pipe_num = ATH6KL_USB_PIPE_INVALID;
261 
262 	switch (ep_address) {
263 	case ATH6KL_USB_EP_ADDR_APP_CTRL_IN:
264 		pipe_num = ATH6KL_USB_PIPE_RX_CTRL;
265 		*urb_count = RX_URB_COUNT;
266 		break;
267 	case ATH6KL_USB_EP_ADDR_APP_DATA_IN:
268 		pipe_num = ATH6KL_USB_PIPE_RX_DATA;
269 		*urb_count = RX_URB_COUNT;
270 		break;
271 	case ATH6KL_USB_EP_ADDR_APP_INT_IN:
272 		pipe_num = ATH6KL_USB_PIPE_RX_INT;
273 		*urb_count = RX_URB_COUNT;
274 		break;
275 	case ATH6KL_USB_EP_ADDR_APP_DATA2_IN:
276 		pipe_num = ATH6KL_USB_PIPE_RX_DATA2;
277 		*urb_count = RX_URB_COUNT;
278 		break;
279 	case ATH6KL_USB_EP_ADDR_APP_CTRL_OUT:
280 		pipe_num = ATH6KL_USB_PIPE_TX_CTRL;
281 		*urb_count = TX_URB_COUNT;
282 		break;
283 	case ATH6KL_USB_EP_ADDR_APP_DATA_LP_OUT:
284 		pipe_num = ATH6KL_USB_PIPE_TX_DATA_LP;
285 		*urb_count = TX_URB_COUNT;
286 		break;
287 	case ATH6KL_USB_EP_ADDR_APP_DATA_MP_OUT:
288 		pipe_num = ATH6KL_USB_PIPE_TX_DATA_MP;
289 		*urb_count = TX_URB_COUNT;
290 		break;
291 	case ATH6KL_USB_EP_ADDR_APP_DATA_HP_OUT:
292 		pipe_num = ATH6KL_USB_PIPE_TX_DATA_HP;
293 		*urb_count = TX_URB_COUNT;
294 		break;
295 	default:
296 		/* note: there may be endpoints not currently used */
297 		break;
298 	}
299 
300 	return pipe_num;
301 }
302 
ath6kl_usb_setup_pipe_resources(struct ath6kl_usb * ar_usb)303 static int ath6kl_usb_setup_pipe_resources(struct ath6kl_usb *ar_usb)
304 {
305 	struct usb_interface *interface = ar_usb->interface;
306 	struct usb_host_interface *iface_desc = interface->cur_altsetting;
307 	struct usb_endpoint_descriptor *endpoint;
308 	struct ath6kl_usb_pipe *pipe;
309 	int i, urbcount, status = 0;
310 	u8 pipe_num;
311 
312 	ath6kl_dbg(ATH6KL_DBG_USB, "setting up USB Pipes using interface\n");
313 
314 	/* walk descriptors and setup pipes */
315 	for (i = 0; i < iface_desc->desc.bNumEndpoints; ++i) {
316 		endpoint = &iface_desc->endpoint[i].desc;
317 
318 		if (ATH6KL_USB_IS_BULK_EP(endpoint->bmAttributes)) {
319 			ath6kl_dbg(ATH6KL_DBG_USB,
320 				   "%s Bulk Ep:0x%2.2X maxpktsz:%d\n",
321 				   ATH6KL_USB_IS_DIR_IN
322 				   (endpoint->bEndpointAddress) ?
323 				   "RX" : "TX", endpoint->bEndpointAddress,
324 				   le16_to_cpu(endpoint->wMaxPacketSize));
325 		} else if (ATH6KL_USB_IS_INT_EP(endpoint->bmAttributes)) {
326 			ath6kl_dbg(ATH6KL_DBG_USB,
327 				   "%s Int Ep:0x%2.2X maxpktsz:%d interval:%d\n",
328 				   ATH6KL_USB_IS_DIR_IN
329 				   (endpoint->bEndpointAddress) ?
330 				   "RX" : "TX", endpoint->bEndpointAddress,
331 				   le16_to_cpu(endpoint->wMaxPacketSize),
332 				   endpoint->bInterval);
333 		} else if (ATH6KL_USB_IS_ISOC_EP(endpoint->bmAttributes)) {
334 			/* TODO for ISO */
335 			ath6kl_dbg(ATH6KL_DBG_USB,
336 				   "%s ISOC Ep:0x%2.2X maxpktsz:%d interval:%d\n",
337 				   ATH6KL_USB_IS_DIR_IN
338 				   (endpoint->bEndpointAddress) ?
339 				   "RX" : "TX", endpoint->bEndpointAddress,
340 				   le16_to_cpu(endpoint->wMaxPacketSize),
341 				   endpoint->bInterval);
342 		}
343 		urbcount = 0;
344 
345 		pipe_num =
346 		    ath6kl_usb_get_logical_pipe_num(ar_usb,
347 						    endpoint->bEndpointAddress,
348 						    &urbcount);
349 		if (pipe_num == ATH6KL_USB_PIPE_INVALID)
350 			continue;
351 
352 		pipe = &ar_usb->pipes[pipe_num];
353 		if (pipe->ar_usb != NULL) {
354 			/* hmmm..pipe was already setup */
355 			continue;
356 		}
357 
358 		pipe->ar_usb = ar_usb;
359 		pipe->logical_pipe_num = pipe_num;
360 		pipe->ep_address = endpoint->bEndpointAddress;
361 		pipe->max_packet_size = le16_to_cpu(endpoint->wMaxPacketSize);
362 
363 		if (ATH6KL_USB_IS_BULK_EP(endpoint->bmAttributes)) {
364 			if (ATH6KL_USB_IS_DIR_IN(pipe->ep_address)) {
365 				pipe->usb_pipe_handle =
366 				    usb_rcvbulkpipe(ar_usb->udev,
367 						    pipe->ep_address);
368 			} else {
369 				pipe->usb_pipe_handle =
370 				    usb_sndbulkpipe(ar_usb->udev,
371 						    pipe->ep_address);
372 			}
373 		} else if (ATH6KL_USB_IS_INT_EP(endpoint->bmAttributes)) {
374 			if (ATH6KL_USB_IS_DIR_IN(pipe->ep_address)) {
375 				pipe->usb_pipe_handle =
376 				    usb_rcvintpipe(ar_usb->udev,
377 						   pipe->ep_address);
378 			} else {
379 				pipe->usb_pipe_handle =
380 				    usb_sndintpipe(ar_usb->udev,
381 						   pipe->ep_address);
382 			}
383 		} else if (ATH6KL_USB_IS_ISOC_EP(endpoint->bmAttributes)) {
384 			/* TODO for ISO */
385 			if (ATH6KL_USB_IS_DIR_IN(pipe->ep_address)) {
386 				pipe->usb_pipe_handle =
387 				    usb_rcvisocpipe(ar_usb->udev,
388 						    pipe->ep_address);
389 			} else {
390 				pipe->usb_pipe_handle =
391 				    usb_sndisocpipe(ar_usb->udev,
392 						    pipe->ep_address);
393 			}
394 		}
395 
396 		pipe->ep_desc = endpoint;
397 
398 		if (!ATH6KL_USB_IS_DIR_IN(pipe->ep_address))
399 			pipe->flags |= ATH6KL_USB_PIPE_FLAG_TX;
400 
401 		status = ath6kl_usb_alloc_pipe_resources(pipe, urbcount);
402 		if (status != 0)
403 			break;
404 	}
405 
406 	return status;
407 }
408 
409 /* pipe operations */
ath6kl_usb_post_recv_transfers(struct ath6kl_usb_pipe * recv_pipe,int buffer_length)410 static void ath6kl_usb_post_recv_transfers(struct ath6kl_usb_pipe *recv_pipe,
411 					   int buffer_length)
412 {
413 	struct ath6kl_urb_context *urb_context;
414 	struct urb *urb;
415 	int usb_status;
416 
417 	while (true) {
418 		urb_context = ath6kl_usb_alloc_urb_from_pipe(recv_pipe);
419 		if (urb_context == NULL)
420 			break;
421 
422 		urb_context->skb = dev_alloc_skb(buffer_length);
423 		if (urb_context->skb == NULL)
424 			goto err_cleanup_urb;
425 
426 		urb = usb_alloc_urb(0, GFP_ATOMIC);
427 		if (urb == NULL)
428 			goto err_cleanup_urb;
429 
430 		usb_fill_bulk_urb(urb,
431 				  recv_pipe->ar_usb->udev,
432 				  recv_pipe->usb_pipe_handle,
433 				  urb_context->skb->data,
434 				  buffer_length,
435 				  ath6kl_usb_recv_complete, urb_context);
436 
437 		ath6kl_dbg(ATH6KL_DBG_USB_BULK,
438 			   "ath6kl usb: bulk recv submit:%d, 0x%X (ep:0x%2.2X), %d bytes buf:0x%p\n",
439 			   recv_pipe->logical_pipe_num,
440 			   recv_pipe->usb_pipe_handle, recv_pipe->ep_address,
441 			   buffer_length, urb_context->skb);
442 
443 		usb_anchor_urb(urb, &recv_pipe->urb_submitted);
444 		usb_status = usb_submit_urb(urb, GFP_ATOMIC);
445 
446 		if (usb_status) {
447 			ath6kl_dbg(ATH6KL_DBG_USB_BULK,
448 				   "ath6kl usb : usb bulk recv failed %d\n",
449 				   usb_status);
450 			usb_unanchor_urb(urb);
451 			usb_free_urb(urb);
452 			goto err_cleanup_urb;
453 		}
454 		usb_free_urb(urb);
455 	}
456 	return;
457 
458 err_cleanup_urb:
459 	ath6kl_usb_cleanup_recv_urb(urb_context);
460 	return;
461 }
462 
ath6kl_usb_flush_all(struct ath6kl_usb * ar_usb)463 static void ath6kl_usb_flush_all(struct ath6kl_usb *ar_usb)
464 {
465 	int i;
466 
467 	for (i = 0; i < ATH6KL_USB_PIPE_MAX; i++) {
468 		if (ar_usb->pipes[i].ar_usb != NULL)
469 			usb_kill_anchored_urbs(&ar_usb->pipes[i].urb_submitted);
470 	}
471 
472 	/*
473 	 * Flushing any pending I/O may schedule work this call will block
474 	 * until all scheduled work runs to completion.
475 	 */
476 	flush_scheduled_work();
477 }
478 
ath6kl_usb_start_recv_pipes(struct ath6kl_usb * ar_usb)479 static void ath6kl_usb_start_recv_pipes(struct ath6kl_usb *ar_usb)
480 {
481 	/*
482 	 * note: control pipe is no longer used
483 	 * ar_usb->pipes[ATH6KL_USB_PIPE_RX_CTRL].urb_cnt_thresh =
484 	 *      ar_usb->pipes[ATH6KL_USB_PIPE_RX_CTRL].urb_alloc/2;
485 	 * ath6kl_usb_post_recv_transfers(&ar_usb->
486 	 *		pipes[ATH6KL_USB_PIPE_RX_CTRL],
487 	 *		ATH6KL_USB_RX_BUFFER_SIZE);
488 	 */
489 
490 	ar_usb->pipes[ATH6KL_USB_PIPE_RX_DATA].urb_cnt_thresh = 1;
491 
492 	ath6kl_usb_post_recv_transfers(&ar_usb->pipes[ATH6KL_USB_PIPE_RX_DATA],
493 				       ATH6KL_USB_RX_BUFFER_SIZE);
494 }
495 
496 /* hif usb rx/tx completion functions */
ath6kl_usb_recv_complete(struct urb * urb)497 static void ath6kl_usb_recv_complete(struct urb *urb)
498 {
499 	struct ath6kl_urb_context *urb_context = urb->context;
500 	struct ath6kl_usb_pipe *pipe = urb_context->pipe;
501 	struct sk_buff *skb = NULL;
502 	int status = 0;
503 
504 	ath6kl_dbg(ATH6KL_DBG_USB_BULK,
505 		   "%s: recv pipe: %d, stat:%d, len:%d urb:0x%p\n", __func__,
506 		   pipe->logical_pipe_num, urb->status, urb->actual_length,
507 		   urb);
508 
509 	if (urb->status != 0) {
510 		status = -EIO;
511 		switch (urb->status) {
512 		case -ECONNRESET:
513 		case -ENOENT:
514 		case -ESHUTDOWN:
515 			/*
516 			 * no need to spew these errors when device
517 			 * removed or urb killed due to driver shutdown
518 			 */
519 			status = -ECANCELED;
520 			break;
521 		default:
522 			ath6kl_dbg(ATH6KL_DBG_USB_BULK,
523 				   "%s recv pipe: %d (ep:0x%2.2X), failed:%d\n",
524 				   __func__, pipe->logical_pipe_num,
525 				   pipe->ep_address, urb->status);
526 			break;
527 		}
528 		goto cleanup_recv_urb;
529 	}
530 
531 	if (urb->actual_length == 0)
532 		goto cleanup_recv_urb;
533 
534 	skb = urb_context->skb;
535 
536 	/* we are going to pass it up */
537 	urb_context->skb = NULL;
538 	skb_put(skb, urb->actual_length);
539 
540 	/* note: queue implements a lock */
541 	skb_queue_tail(&pipe->io_comp_queue, skb);
542 	schedule_work(&pipe->io_complete_work);
543 
544 cleanup_recv_urb:
545 	ath6kl_usb_cleanup_recv_urb(urb_context);
546 
547 	if (status == 0 &&
548 	    pipe->urb_cnt >= pipe->urb_cnt_thresh) {
549 		/* our free urbs are piling up, post more transfers */
550 		ath6kl_usb_post_recv_transfers(pipe, ATH6KL_USB_RX_BUFFER_SIZE);
551 	}
552 }
553 
ath6kl_usb_usb_transmit_complete(struct urb * urb)554 static void ath6kl_usb_usb_transmit_complete(struct urb *urb)
555 {
556 	struct ath6kl_urb_context *urb_context = urb->context;
557 	struct ath6kl_usb_pipe *pipe = urb_context->pipe;
558 	struct sk_buff *skb;
559 
560 	ath6kl_dbg(ATH6KL_DBG_USB_BULK,
561 		   "%s: pipe: %d, stat:%d, len:%d\n",
562 		   __func__, pipe->logical_pipe_num, urb->status,
563 		   urb->actual_length);
564 
565 	if (urb->status != 0) {
566 		ath6kl_dbg(ATH6KL_DBG_USB_BULK,
567 			   "%s:  pipe: %d, failed:%d\n",
568 			   __func__, pipe->logical_pipe_num, urb->status);
569 	}
570 
571 	skb = urb_context->skb;
572 	urb_context->skb = NULL;
573 	ath6kl_usb_free_urb_to_pipe(urb_context->pipe, urb_context);
574 
575 	/* note: queue implements a lock */
576 	skb_queue_tail(&pipe->io_comp_queue, skb);
577 	schedule_work(&pipe->io_complete_work);
578 }
579 
ath6kl_usb_io_comp_work(struct work_struct * work)580 static void ath6kl_usb_io_comp_work(struct work_struct *work)
581 {
582 	struct ath6kl_usb_pipe *pipe = container_of(work,
583 						    struct ath6kl_usb_pipe,
584 						    io_complete_work);
585 	struct ath6kl_usb *ar_usb;
586 	struct sk_buff *skb;
587 
588 	ar_usb = pipe->ar_usb;
589 
590 	while ((skb = skb_dequeue(&pipe->io_comp_queue))) {
591 		if (pipe->flags & ATH6KL_USB_PIPE_FLAG_TX) {
592 			ath6kl_dbg(ATH6KL_DBG_USB_BULK,
593 				   "ath6kl usb xmit callback buf:0x%p\n", skb);
594 			ath6kl_core_tx_complete(ar_usb->ar, skb);
595 		} else {
596 			ath6kl_dbg(ATH6KL_DBG_USB_BULK,
597 				   "ath6kl usb recv callback buf:0x%p\n", skb);
598 			ath6kl_core_rx_complete(ar_usb->ar, skb,
599 						pipe->logical_pipe_num);
600 		}
601 	}
602 }
603 
604 #define ATH6KL_USB_MAX_DIAG_CMD (sizeof(struct ath6kl_usb_ctrl_diag_cmd_write))
605 #define ATH6KL_USB_MAX_DIAG_RESP (sizeof(struct ath6kl_usb_ctrl_diag_resp_read))
606 
ath6kl_usb_destroy(struct ath6kl_usb * ar_usb)607 static void ath6kl_usb_destroy(struct ath6kl_usb *ar_usb)
608 {
609 	ath6kl_usb_flush_all(ar_usb);
610 
611 	ath6kl_usb_cleanup_pipe_resources(ar_usb);
612 
613 	usb_set_intfdata(ar_usb->interface, NULL);
614 
615 	kfree(ar_usb->diag_cmd_buffer);
616 	kfree(ar_usb->diag_resp_buffer);
617 
618 	kfree(ar_usb);
619 }
620 
ath6kl_usb_create(struct usb_interface * interface)621 static struct ath6kl_usb *ath6kl_usb_create(struct usb_interface *interface)
622 {
623 	struct usb_device *dev = interface_to_usbdev(interface);
624 	struct ath6kl_usb *ar_usb;
625 	struct ath6kl_usb_pipe *pipe;
626 	int status = 0;
627 	int i;
628 
629 	ar_usb = kzalloc(sizeof(struct ath6kl_usb), GFP_KERNEL);
630 	if (ar_usb == NULL)
631 		goto fail_ath6kl_usb_create;
632 
633 	usb_set_intfdata(interface, ar_usb);
634 	spin_lock_init(&(ar_usb->cs_lock));
635 	ar_usb->udev = dev;
636 	ar_usb->interface = interface;
637 
638 	for (i = 0; i < ATH6KL_USB_PIPE_MAX; i++) {
639 		pipe = &ar_usb->pipes[i];
640 		INIT_WORK(&pipe->io_complete_work,
641 			  ath6kl_usb_io_comp_work);
642 		skb_queue_head_init(&pipe->io_comp_queue);
643 	}
644 
645 	ar_usb->diag_cmd_buffer = kzalloc(ATH6KL_USB_MAX_DIAG_CMD, GFP_KERNEL);
646 	if (ar_usb->diag_cmd_buffer == NULL) {
647 		status = -ENOMEM;
648 		goto fail_ath6kl_usb_create;
649 	}
650 
651 	ar_usb->diag_resp_buffer = kzalloc(ATH6KL_USB_MAX_DIAG_RESP,
652 					   GFP_KERNEL);
653 	if (ar_usb->diag_resp_buffer == NULL) {
654 		status = -ENOMEM;
655 		goto fail_ath6kl_usb_create;
656 	}
657 
658 	status = ath6kl_usb_setup_pipe_resources(ar_usb);
659 
660 fail_ath6kl_usb_create:
661 	if (status != 0) {
662 		ath6kl_usb_destroy(ar_usb);
663 		ar_usb = NULL;
664 	}
665 	return ar_usb;
666 }
667 
ath6kl_usb_device_detached(struct usb_interface * interface)668 static void ath6kl_usb_device_detached(struct usb_interface *interface)
669 {
670 	struct ath6kl_usb *ar_usb;
671 
672 	ar_usb = usb_get_intfdata(interface);
673 	if (ar_usb == NULL)
674 		return;
675 
676 	ath6kl_stop_txrx(ar_usb->ar);
677 
678 	/* Delay to wait for the target to reboot */
679 	mdelay(20);
680 	ath6kl_core_cleanup(ar_usb->ar);
681 	ath6kl_usb_destroy(ar_usb);
682 }
683 
684 /* exported hif usb APIs for htc pipe */
hif_start(struct ath6kl * ar)685 static void hif_start(struct ath6kl *ar)
686 {
687 	struct ath6kl_usb *device = ath6kl_usb_priv(ar);
688 	int i;
689 
690 	ath6kl_usb_start_recv_pipes(device);
691 
692 	/* set the TX resource avail threshold for each TX pipe */
693 	for (i = ATH6KL_USB_PIPE_TX_CTRL;
694 	     i <= ATH6KL_USB_PIPE_TX_DATA_HP; i++) {
695 		device->pipes[i].urb_cnt_thresh =
696 		    device->pipes[i].urb_alloc / 2;
697 	}
698 }
699 
ath6kl_usb_send(struct ath6kl * ar,u8 PipeID,struct sk_buff * hdr_skb,struct sk_buff * skb)700 static int ath6kl_usb_send(struct ath6kl *ar, u8 PipeID,
701 			   struct sk_buff *hdr_skb, struct sk_buff *skb)
702 {
703 	struct ath6kl_usb *device = ath6kl_usb_priv(ar);
704 	struct ath6kl_usb_pipe *pipe = &device->pipes[PipeID];
705 	struct ath6kl_urb_context *urb_context;
706 	int usb_status, status = 0;
707 	struct urb *urb;
708 	u8 *data;
709 	u32 len;
710 
711 	ath6kl_dbg(ATH6KL_DBG_USB_BULK, "+%s pipe : %d, buf:0x%p\n",
712 		   __func__, PipeID, skb);
713 
714 	urb_context = ath6kl_usb_alloc_urb_from_pipe(pipe);
715 
716 	if (urb_context == NULL) {
717 		/*
718 		 * TODO: it is possible to run out of urbs if
719 		 * 2 endpoints map to the same pipe ID
720 		 */
721 		ath6kl_dbg(ATH6KL_DBG_USB_BULK,
722 			   "%s pipe:%d no urbs left. URB Cnt : %d\n",
723 			   __func__, PipeID, pipe->urb_cnt);
724 		status = -ENOMEM;
725 		goto fail_hif_send;
726 	}
727 
728 	urb_context->skb = skb;
729 
730 	data = skb->data;
731 	len = skb->len;
732 
733 	urb = usb_alloc_urb(0, GFP_ATOMIC);
734 	if (urb == NULL) {
735 		status = -ENOMEM;
736 		ath6kl_usb_free_urb_to_pipe(urb_context->pipe,
737 					    urb_context);
738 		goto fail_hif_send;
739 	}
740 
741 	usb_fill_bulk_urb(urb,
742 			  device->udev,
743 			  pipe->usb_pipe_handle,
744 			  data,
745 			  len,
746 			  ath6kl_usb_usb_transmit_complete, urb_context);
747 
748 	if ((len % pipe->max_packet_size) == 0) {
749 		/* hit a max packet boundary on this pipe */
750 		urb->transfer_flags |= URB_ZERO_PACKET;
751 	}
752 
753 	ath6kl_dbg(ATH6KL_DBG_USB_BULK,
754 		   "athusb bulk send submit:%d, 0x%X (ep:0x%2.2X), %d bytes\n",
755 		   pipe->logical_pipe_num, pipe->usb_pipe_handle,
756 		   pipe->ep_address, len);
757 
758 	usb_anchor_urb(urb, &pipe->urb_submitted);
759 	usb_status = usb_submit_urb(urb, GFP_ATOMIC);
760 
761 	if (usb_status) {
762 		ath6kl_dbg(ATH6KL_DBG_USB_BULK,
763 			   "ath6kl usb : usb bulk transmit failed %d\n",
764 			   usb_status);
765 		usb_unanchor_urb(urb);
766 		ath6kl_usb_free_urb_to_pipe(urb_context->pipe,
767 					    urb_context);
768 		status = -EINVAL;
769 	}
770 	usb_free_urb(urb);
771 
772 fail_hif_send:
773 	return status;
774 }
775 
hif_stop(struct ath6kl * ar)776 static void hif_stop(struct ath6kl *ar)
777 {
778 	struct ath6kl_usb *device = ath6kl_usb_priv(ar);
779 
780 	ath6kl_usb_flush_all(device);
781 }
782 
ath6kl_usb_get_default_pipe(struct ath6kl * ar,u8 * ul_pipe,u8 * dl_pipe)783 static void ath6kl_usb_get_default_pipe(struct ath6kl *ar,
784 					u8 *ul_pipe, u8 *dl_pipe)
785 {
786 	*ul_pipe = ATH6KL_USB_PIPE_TX_CTRL;
787 	*dl_pipe = ATH6KL_USB_PIPE_RX_CTRL;
788 }
789 
ath6kl_usb_map_service_pipe(struct ath6kl * ar,u16 svc_id,u8 * ul_pipe,u8 * dl_pipe)790 static int ath6kl_usb_map_service_pipe(struct ath6kl *ar, u16 svc_id,
791 				       u8 *ul_pipe, u8 *dl_pipe)
792 {
793 	int status = 0;
794 
795 	switch (svc_id) {
796 	case HTC_CTRL_RSVD_SVC:
797 	case WMI_CONTROL_SVC:
798 		*ul_pipe = ATH6KL_USB_PIPE_TX_CTRL;
799 		/* due to large control packets, shift to data pipe */
800 		*dl_pipe = ATH6KL_USB_PIPE_RX_DATA;
801 		break;
802 	case WMI_DATA_BE_SVC:
803 	case WMI_DATA_BK_SVC:
804 		*ul_pipe = ATH6KL_USB_PIPE_TX_DATA_LP;
805 		/*
806 		* Disable rxdata2 directly, it will be enabled
807 		* if FW enable rxdata2
808 		*/
809 		*dl_pipe = ATH6KL_USB_PIPE_RX_DATA;
810 		break;
811 	case WMI_DATA_VI_SVC:
812 
813 		if (test_bit(ATH6KL_FW_CAPABILITY_MAP_LP_ENDPOINT,
814 			     ar->fw_capabilities))
815 			*ul_pipe = ATH6KL_USB_PIPE_TX_DATA_LP;
816 		else
817 			*ul_pipe = ATH6KL_USB_PIPE_TX_DATA_MP;
818 		/*
819 		* Disable rxdata2 directly, it will be enabled
820 		* if FW enable rxdata2
821 		*/
822 		*dl_pipe = ATH6KL_USB_PIPE_RX_DATA;
823 		break;
824 	case WMI_DATA_VO_SVC:
825 
826 		if (test_bit(ATH6KL_FW_CAPABILITY_MAP_LP_ENDPOINT,
827 			     ar->fw_capabilities))
828 			*ul_pipe = ATH6KL_USB_PIPE_TX_DATA_LP;
829 		else
830 			*ul_pipe = ATH6KL_USB_PIPE_TX_DATA_MP;
831 		/*
832 		* Disable rxdata2 directly, it will be enabled
833 		* if FW enable rxdata2
834 		*/
835 		*dl_pipe = ATH6KL_USB_PIPE_RX_DATA;
836 		break;
837 	default:
838 		status = -EPERM;
839 		break;
840 	}
841 
842 	return status;
843 }
844 
ath6kl_usb_get_free_queue_number(struct ath6kl * ar,u8 pipe_id)845 static u16 ath6kl_usb_get_free_queue_number(struct ath6kl *ar, u8 pipe_id)
846 {
847 	struct ath6kl_usb *device = ath6kl_usb_priv(ar);
848 
849 	return device->pipes[pipe_id].urb_cnt;
850 }
851 
hif_detach_htc(struct ath6kl * ar)852 static void hif_detach_htc(struct ath6kl *ar)
853 {
854 	struct ath6kl_usb *device = ath6kl_usb_priv(ar);
855 
856 	ath6kl_usb_flush_all(device);
857 }
858 
ath6kl_usb_submit_ctrl_out(struct ath6kl_usb * ar_usb,u8 req,u16 value,u16 index,void * data,u32 size)859 static int ath6kl_usb_submit_ctrl_out(struct ath6kl_usb *ar_usb,
860 				   u8 req, u16 value, u16 index, void *data,
861 				   u32 size)
862 {
863 	u8 *buf = NULL;
864 	int ret;
865 
866 	if (size > 0) {
867 		buf = kmemdup(data, size, GFP_KERNEL);
868 		if (buf == NULL)
869 			return -ENOMEM;
870 	}
871 
872 	/* note: if successful returns number of bytes transfered */
873 	ret = usb_control_msg(ar_usb->udev,
874 			      usb_sndctrlpipe(ar_usb->udev, 0),
875 			      req,
876 			      USB_DIR_OUT | USB_TYPE_VENDOR |
877 			      USB_RECIP_DEVICE, value, index, buf,
878 			      size, 1000);
879 
880 	if (ret < 0) {
881 		ath6kl_warn("Failed to submit usb control message: %d\n", ret);
882 		kfree(buf);
883 		return ret;
884 	}
885 
886 	kfree(buf);
887 
888 	return 0;
889 }
890 
ath6kl_usb_submit_ctrl_in(struct ath6kl_usb * ar_usb,u8 req,u16 value,u16 index,void * data,u32 size)891 static int ath6kl_usb_submit_ctrl_in(struct ath6kl_usb *ar_usb,
892 				  u8 req, u16 value, u16 index, void *data,
893 				  u32 size)
894 {
895 	u8 *buf = NULL;
896 	int ret;
897 
898 	if (size > 0) {
899 		buf = kmalloc(size, GFP_KERNEL);
900 		if (buf == NULL)
901 			return -ENOMEM;
902 	}
903 
904 	/* note: if successful returns number of bytes transfered */
905 	ret = usb_control_msg(ar_usb->udev,
906 				 usb_rcvctrlpipe(ar_usb->udev, 0),
907 				 req,
908 				 USB_DIR_IN | USB_TYPE_VENDOR |
909 				 USB_RECIP_DEVICE, value, index, buf,
910 				 size, 2 * HZ);
911 
912 	if (ret < 0) {
913 		ath6kl_warn("Failed to read usb control message: %d\n", ret);
914 		kfree(buf);
915 		return ret;
916 	}
917 
918 	memcpy((u8 *) data, buf, size);
919 
920 	kfree(buf);
921 
922 	return 0;
923 }
924 
ath6kl_usb_ctrl_msg_exchange(struct ath6kl_usb * ar_usb,u8 req_val,u8 * req_buf,u32 req_len,u8 resp_val,u8 * resp_buf,u32 * resp_len)925 static int ath6kl_usb_ctrl_msg_exchange(struct ath6kl_usb *ar_usb,
926 				     u8 req_val, u8 *req_buf, u32 req_len,
927 				     u8 resp_val, u8 *resp_buf, u32 *resp_len)
928 {
929 	int ret;
930 
931 	/* send command */
932 	ret = ath6kl_usb_submit_ctrl_out(ar_usb, req_val, 0, 0,
933 					 req_buf, req_len);
934 
935 	if (ret != 0)
936 		return ret;
937 
938 	if (resp_buf == NULL) {
939 		/* no expected response */
940 		return ret;
941 	}
942 
943 	/* get response */
944 	ret = ath6kl_usb_submit_ctrl_in(ar_usb, resp_val, 0, 0,
945 					resp_buf, *resp_len);
946 
947 	return ret;
948 }
949 
ath6kl_usb_diag_read32(struct ath6kl * ar,u32 address,u32 * data)950 static int ath6kl_usb_diag_read32(struct ath6kl *ar, u32 address, u32 *data)
951 {
952 	struct ath6kl_usb *ar_usb = ar->hif_priv;
953 	struct ath6kl_usb_ctrl_diag_resp_read *resp;
954 	struct ath6kl_usb_ctrl_diag_cmd_read *cmd;
955 	u32 resp_len;
956 	int ret;
957 
958 	cmd = (struct ath6kl_usb_ctrl_diag_cmd_read *) ar_usb->diag_cmd_buffer;
959 
960 	memset(cmd, 0, sizeof(*cmd));
961 	cmd->cmd = ATH6KL_USB_CTRL_DIAG_CC_READ;
962 	cmd->address = cpu_to_le32(address);
963 	resp_len = sizeof(*resp);
964 
965 	ret = ath6kl_usb_ctrl_msg_exchange(ar_usb,
966 				ATH6KL_USB_CONTROL_REQ_DIAG_CMD,
967 				(u8 *) cmd,
968 				sizeof(struct ath6kl_usb_ctrl_diag_cmd_write),
969 				ATH6KL_USB_CONTROL_REQ_DIAG_RESP,
970 				ar_usb->diag_resp_buffer, &resp_len);
971 
972 	if (ret) {
973 		ath6kl_warn("diag read32 failed: %d\n", ret);
974 		return ret;
975 	}
976 
977 	resp = (struct ath6kl_usb_ctrl_diag_resp_read *)
978 		ar_usb->diag_resp_buffer;
979 
980 	*data = le32_to_cpu(resp->value);
981 
982 	return ret;
983 }
984 
ath6kl_usb_diag_write32(struct ath6kl * ar,u32 address,__le32 data)985 static int ath6kl_usb_diag_write32(struct ath6kl *ar, u32 address, __le32 data)
986 {
987 	struct ath6kl_usb *ar_usb = ar->hif_priv;
988 	struct ath6kl_usb_ctrl_diag_cmd_write *cmd;
989 	int ret;
990 
991 	cmd = (struct ath6kl_usb_ctrl_diag_cmd_write *) ar_usb->diag_cmd_buffer;
992 
993 	memset(cmd, 0, sizeof(struct ath6kl_usb_ctrl_diag_cmd_write));
994 	cmd->cmd = cpu_to_le32(ATH6KL_USB_CTRL_DIAG_CC_WRITE);
995 	cmd->address = cpu_to_le32(address);
996 	cmd->value = data;
997 
998 	ret = ath6kl_usb_ctrl_msg_exchange(ar_usb,
999 					   ATH6KL_USB_CONTROL_REQ_DIAG_CMD,
1000 					   (u8 *) cmd,
1001 					   sizeof(*cmd),
1002 					   0, NULL, NULL);
1003 	if (ret) {
1004 		ath6kl_warn("diag_write32 failed: %d\n", ret);
1005 		return ret;
1006 	}
1007 
1008 	return 0;
1009 }
1010 
ath6kl_usb_bmi_read(struct ath6kl * ar,u8 * buf,u32 len)1011 static int ath6kl_usb_bmi_read(struct ath6kl *ar, u8 *buf, u32 len)
1012 {
1013 	struct ath6kl_usb *ar_usb = ar->hif_priv;
1014 	int ret;
1015 
1016 	/* get response */
1017 	ret = ath6kl_usb_submit_ctrl_in(ar_usb,
1018 					ATH6KL_USB_CONTROL_REQ_RECV_BMI_RESP,
1019 					0, 0, buf, len);
1020 	if (ret) {
1021 		ath6kl_err("Unable to read the bmi data from the device: %d\n",
1022 			   ret);
1023 		return ret;
1024 	}
1025 
1026 	return 0;
1027 }
1028 
ath6kl_usb_bmi_write(struct ath6kl * ar,u8 * buf,u32 len)1029 static int ath6kl_usb_bmi_write(struct ath6kl *ar, u8 *buf, u32 len)
1030 {
1031 	struct ath6kl_usb *ar_usb = ar->hif_priv;
1032 	int ret;
1033 
1034 	/* send command */
1035 	ret = ath6kl_usb_submit_ctrl_out(ar_usb,
1036 					 ATH6KL_USB_CONTROL_REQ_SEND_BMI_CMD,
1037 					 0, 0, buf, len);
1038 	if (ret) {
1039 		ath6kl_err("unable to send the bmi data to the device: %d\n",
1040 			   ret);
1041 		return ret;
1042 	}
1043 
1044 	return 0;
1045 }
1046 
ath6kl_usb_power_on(struct ath6kl * ar)1047 static int ath6kl_usb_power_on(struct ath6kl *ar)
1048 {
1049 	hif_start(ar);
1050 	return 0;
1051 }
1052 
ath6kl_usb_power_off(struct ath6kl * ar)1053 static int ath6kl_usb_power_off(struct ath6kl *ar)
1054 {
1055 	hif_detach_htc(ar);
1056 	return 0;
1057 }
1058 
ath6kl_usb_stop(struct ath6kl * ar)1059 static void ath6kl_usb_stop(struct ath6kl *ar)
1060 {
1061 	hif_stop(ar);
1062 }
1063 
ath6kl_usb_cleanup_scatter(struct ath6kl * ar)1064 static void ath6kl_usb_cleanup_scatter(struct ath6kl *ar)
1065 {
1066 	/*
1067 	 * USB doesn't support it. Just return.
1068 	 */
1069 	return;
1070 }
1071 
ath6kl_usb_suspend(struct ath6kl * ar,struct cfg80211_wowlan * wow)1072 static int ath6kl_usb_suspend(struct ath6kl *ar, struct cfg80211_wowlan *wow)
1073 {
1074 	/*
1075 	 * cfg80211 suspend/WOW currently not supported for USB.
1076 	 */
1077 	return 0;
1078 }
1079 
ath6kl_usb_resume(struct ath6kl * ar)1080 static int ath6kl_usb_resume(struct ath6kl *ar)
1081 {
1082 	/*
1083 	 * cfg80211 resume currently not supported for USB.
1084 	 */
1085 	return 0;
1086 }
1087 
1088 static const struct ath6kl_hif_ops ath6kl_usb_ops = {
1089 	.diag_read32 = ath6kl_usb_diag_read32,
1090 	.diag_write32 = ath6kl_usb_diag_write32,
1091 	.bmi_read = ath6kl_usb_bmi_read,
1092 	.bmi_write = ath6kl_usb_bmi_write,
1093 	.power_on = ath6kl_usb_power_on,
1094 	.power_off = ath6kl_usb_power_off,
1095 	.stop = ath6kl_usb_stop,
1096 	.pipe_send = ath6kl_usb_send,
1097 	.pipe_get_default = ath6kl_usb_get_default_pipe,
1098 	.pipe_map_service = ath6kl_usb_map_service_pipe,
1099 	.pipe_get_free_queue_number = ath6kl_usb_get_free_queue_number,
1100 	.cleanup_scatter = ath6kl_usb_cleanup_scatter,
1101 	.suspend = ath6kl_usb_suspend,
1102 	.resume = ath6kl_usb_resume,
1103 };
1104 
1105 /* ath6kl usb driver registered functions */
ath6kl_usb_probe(struct usb_interface * interface,const struct usb_device_id * id)1106 static int ath6kl_usb_probe(struct usb_interface *interface,
1107 			    const struct usb_device_id *id)
1108 {
1109 	struct usb_device *dev = interface_to_usbdev(interface);
1110 	struct ath6kl *ar;
1111 	struct ath6kl_usb *ar_usb = NULL;
1112 	int vendor_id, product_id;
1113 	int ret = 0;
1114 
1115 	usb_get_dev(dev);
1116 
1117 	vendor_id = le16_to_cpu(dev->descriptor.idVendor);
1118 	product_id = le16_to_cpu(dev->descriptor.idProduct);
1119 
1120 	ath6kl_dbg(ATH6KL_DBG_USB, "vendor_id = %04x\n", vendor_id);
1121 	ath6kl_dbg(ATH6KL_DBG_USB, "product_id = %04x\n", product_id);
1122 
1123 	if (interface->cur_altsetting)
1124 		ath6kl_dbg(ATH6KL_DBG_USB, "USB Interface %d\n",
1125 			   interface->cur_altsetting->desc.bInterfaceNumber);
1126 
1127 
1128 	if (dev->speed == USB_SPEED_HIGH)
1129 		ath6kl_dbg(ATH6KL_DBG_USB, "USB 2.0 Host\n");
1130 	else
1131 		ath6kl_dbg(ATH6KL_DBG_USB, "USB 1.1 Host\n");
1132 
1133 	ar_usb = ath6kl_usb_create(interface);
1134 
1135 	if (ar_usb == NULL) {
1136 		ret = -ENOMEM;
1137 		goto err_usb_put;
1138 	}
1139 
1140 	ar = ath6kl_core_create(&ar_usb->udev->dev);
1141 	if (ar == NULL) {
1142 		ath6kl_err("Failed to alloc ath6kl core\n");
1143 		ret = -ENOMEM;
1144 		goto err_usb_destroy;
1145 	}
1146 
1147 	ar->hif_priv = ar_usb;
1148 	ar->hif_type = ATH6KL_HIF_TYPE_USB;
1149 	ar->hif_ops = &ath6kl_usb_ops;
1150 	ar->mbox_info.block_size = 16;
1151 	ar->bmi.max_data_size = 252;
1152 
1153 	ar_usb->ar = ar;
1154 
1155 	ret = ath6kl_core_init(ar, ATH6KL_HTC_TYPE_PIPE);
1156 	if (ret) {
1157 		ath6kl_err("Failed to init ath6kl core: %d\n", ret);
1158 		goto err_core_free;
1159 	}
1160 
1161 	return ret;
1162 
1163 err_core_free:
1164 	ath6kl_core_destroy(ar);
1165 err_usb_destroy:
1166 	ath6kl_usb_destroy(ar_usb);
1167 err_usb_put:
1168 	usb_put_dev(dev);
1169 
1170 	return ret;
1171 }
1172 
ath6kl_usb_remove(struct usb_interface * interface)1173 static void ath6kl_usb_remove(struct usb_interface *interface)
1174 {
1175 	usb_put_dev(interface_to_usbdev(interface));
1176 	ath6kl_usb_device_detached(interface);
1177 }
1178 
1179 #ifdef CONFIG_PM
1180 
ath6kl_usb_pm_suspend(struct usb_interface * interface,pm_message_t message)1181 static int ath6kl_usb_pm_suspend(struct usb_interface *interface,
1182 			      pm_message_t message)
1183 {
1184 	struct ath6kl_usb *device;
1185 	device = usb_get_intfdata(interface);
1186 
1187 	ath6kl_usb_flush_all(device);
1188 	return 0;
1189 }
1190 
ath6kl_usb_pm_resume(struct usb_interface * interface)1191 static int ath6kl_usb_pm_resume(struct usb_interface *interface)
1192 {
1193 	struct ath6kl_usb *device;
1194 	device = usb_get_intfdata(interface);
1195 
1196 	ath6kl_usb_post_recv_transfers(&device->pipes[ATH6KL_USB_PIPE_RX_DATA],
1197 				       ATH6KL_USB_RX_BUFFER_SIZE);
1198 	ath6kl_usb_post_recv_transfers(&device->pipes[ATH6KL_USB_PIPE_RX_DATA2],
1199 				       ATH6KL_USB_RX_BUFFER_SIZE);
1200 
1201 	return 0;
1202 }
1203 
1204 #else
1205 
1206 #define ath6kl_usb_pm_suspend NULL
1207 #define ath6kl_usb_pm_resume NULL
1208 
1209 #endif
1210 
1211 /* table of devices that work with this driver */
1212 static const struct usb_device_id ath6kl_usb_ids[] = {
1213 	{USB_DEVICE(0x0cf3, 0x9375)},
1214 	{USB_DEVICE(0x0cf3, 0x9374)},
1215 	{ /* Terminating entry */ },
1216 };
1217 
1218 MODULE_DEVICE_TABLE(usb, ath6kl_usb_ids);
1219 
1220 static struct usb_driver ath6kl_usb_driver = {
1221 	.name = "ath6kl_usb",
1222 	.probe = ath6kl_usb_probe,
1223 	.suspend = ath6kl_usb_pm_suspend,
1224 	.resume = ath6kl_usb_pm_resume,
1225 	.disconnect = ath6kl_usb_remove,
1226 	.id_table = ath6kl_usb_ids,
1227 	.supports_autosuspend = true,
1228 	.disable_hub_initiated_lpm = 1,
1229 };
1230 
1231 module_usb_driver(ath6kl_usb_driver);
1232 
1233 MODULE_AUTHOR("Atheros Communications, Inc.");
1234 MODULE_DESCRIPTION("Driver support for Atheros AR600x USB devices");
1235 MODULE_LICENSE("Dual BSD/GPL");
1236 MODULE_FIRMWARE(AR6004_HW_1_0_FIRMWARE_FILE);
1237 MODULE_FIRMWARE(AR6004_HW_1_0_BOARD_DATA_FILE);
1238 MODULE_FIRMWARE(AR6004_HW_1_0_DEFAULT_BOARD_DATA_FILE);
1239 MODULE_FIRMWARE(AR6004_HW_1_1_FIRMWARE_FILE);
1240 MODULE_FIRMWARE(AR6004_HW_1_1_BOARD_DATA_FILE);
1241 MODULE_FIRMWARE(AR6004_HW_1_1_DEFAULT_BOARD_DATA_FILE);
1242 MODULE_FIRMWARE(AR6004_HW_1_2_FIRMWARE_FILE);
1243 MODULE_FIRMWARE(AR6004_HW_1_2_BOARD_DATA_FILE);
1244 MODULE_FIRMWARE(AR6004_HW_1_2_DEFAULT_BOARD_DATA_FILE);
1245 MODULE_FIRMWARE(AR6004_HW_1_3_FW_DIR "/" AR6004_HW_1_3_FIRMWARE_FILE);
1246 MODULE_FIRMWARE(AR6004_HW_1_3_BOARD_DATA_FILE);
1247 MODULE_FIRMWARE(AR6004_HW_1_3_DEFAULT_BOARD_DATA_FILE);
1248