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