rtl8712: intf_priv: Replace semaphore lock with completion
[linux-2.6-microblaze.git] / drivers / staging / rtl8712 / usb_ops_linux.c
1 /******************************************************************************
2  * usb_ops_linux.c
3  *
4  * Copyright(c) 2007 - 2010 Realtek Corporation. All rights reserved.
5  * Linux device driver for RTL8192SU
6  *
7  * This program is free software; you can redistribute it and/or modify it
8  * under the terms of version 2 of the GNU General Public License as
9  * published by the Free Software Foundation.
10  *
11  * This program is distributed in the hope that it will be useful, but WITHOUT
12  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
14  * more details.
15  *
16  * You should have received a copy of the GNU General Public License along with
17  * this program; if not, write to the Free Software Foundation, Inc.,
18  * 51 Franklin Street, Fifth Floor, Boston, MA 02110, USA
19  *
20  * Modifications for inclusion into the Linux staging tree are
21  * Copyright(c) 2010 Larry Finger. All rights reserved.
22  *
23  * Contact information:
24  * WLAN FAE <wlanfae@realtek.com>
25  * Larry Finger <Larry.Finger@lwfinger.net>
26  *
27  ******************************************************************************/
28
29 #define _HCI_OPS_OS_C_
30
31 #include <linux/usb.h>
32
33 #include "osdep_service.h"
34 #include "drv_types.h"
35 #include "osdep_intf.h"
36 #include "usb_ops.h"
37
38 #define RTL871X_VENQT_READ      0xc0
39 #define RTL871X_VENQT_WRITE     0x40
40
41 struct zero_bulkout_context {
42         void *pbuf;
43         void *purb;
44         void *pirp;
45         void *padapter;
46 };
47
48 uint r8712_usb_init_intf_priv(struct intf_priv *pintfpriv)
49 {
50         pintfpriv->piorw_urb = usb_alloc_urb(0, GFP_ATOMIC);
51         if (!pintfpriv->piorw_urb)
52                 return _FAIL;
53         init_completion(&pintfpriv->io_retevt_comp);
54         return _SUCCESS;
55 }
56
57 void r8712_usb_unload_intf_priv(struct intf_priv *pintfpriv)
58 {
59         if (pintfpriv->piorw_urb) {
60                 usb_kill_urb(pintfpriv->piorw_urb);
61                 usb_free_urb(pintfpriv->piorw_urb);
62         }
63 }
64
65 static unsigned int ffaddr2pipehdl(struct dvobj_priv *pdvobj, u32 addr)
66 {
67         unsigned int pipe = 0;
68         struct usb_device *pusbd = pdvobj->pusbdev;
69
70         if (pdvobj->nr_endpoint == 11) {
71                 switch (addr) {
72                 case RTL8712_DMA_BKQ:
73                         pipe = usb_sndbulkpipe(pusbd, 0x07);
74                         break;
75                 case RTL8712_DMA_BEQ:
76                         pipe = usb_sndbulkpipe(pusbd, 0x06);
77                         break;
78                 case RTL8712_DMA_VIQ:
79                         pipe = usb_sndbulkpipe(pusbd, 0x05);
80                         break;
81                 case RTL8712_DMA_VOQ:
82                         pipe = usb_sndbulkpipe(pusbd, 0x04);
83                         break;
84                 case RTL8712_DMA_BCNQ:
85                         pipe = usb_sndbulkpipe(pusbd, 0x0a);
86                         break;
87                 case RTL8712_DMA_BMCQ:  /* HI Queue */
88                         pipe = usb_sndbulkpipe(pusbd, 0x0b);
89                         break;
90                 case RTL8712_DMA_MGTQ:
91                         pipe = usb_sndbulkpipe(pusbd, 0x0c);
92                         break;
93                 case RTL8712_DMA_RX0FF:
94                         pipe = usb_rcvbulkpipe(pusbd, 0x03); /* in */
95                         break;
96                 case RTL8712_DMA_C2HCMD:
97                         pipe = usb_rcvbulkpipe(pusbd, 0x09); /* in */
98                         break;
99                 case RTL8712_DMA_H2CCMD:
100                         pipe = usb_sndbulkpipe(pusbd, 0x0d);
101                         break;
102                 }
103         } else if (pdvobj->nr_endpoint == 6) {
104                 switch (addr) {
105                 case RTL8712_DMA_BKQ:
106                         pipe = usb_sndbulkpipe(pusbd, 0x07);
107                         break;
108                 case RTL8712_DMA_BEQ:
109                         pipe = usb_sndbulkpipe(pusbd, 0x06);
110                         break;
111                 case RTL8712_DMA_VIQ:
112                         pipe = usb_sndbulkpipe(pusbd, 0x05);
113                         break;
114                 case RTL8712_DMA_VOQ:
115                         pipe = usb_sndbulkpipe(pusbd, 0x04);
116                         break;
117                 case RTL8712_DMA_RX0FF:
118                 case RTL8712_DMA_C2HCMD:
119                         pipe = usb_rcvbulkpipe(pusbd, 0x03); /* in */
120                         break;
121                 case RTL8712_DMA_H2CCMD:
122                 case RTL8712_DMA_BCNQ:
123                 case RTL8712_DMA_BMCQ:
124                 case RTL8712_DMA_MGTQ:
125                         pipe = usb_sndbulkpipe(pusbd, 0x0d);
126                         break;
127                 }
128         } else if (pdvobj->nr_endpoint == 4) {
129                 switch (addr) {
130                 case RTL8712_DMA_BEQ:
131                         pipe = usb_sndbulkpipe(pusbd, 0x06);
132                         break;
133                 case RTL8712_DMA_VOQ:
134                         pipe = usb_sndbulkpipe(pusbd, 0x04);
135                         break;
136                 case RTL8712_DMA_RX0FF:
137                 case RTL8712_DMA_C2HCMD:
138                         pipe = usb_rcvbulkpipe(pusbd, 0x03); /* in */
139                         break;
140                 case RTL8712_DMA_H2CCMD:
141                 case RTL8712_DMA_BCNQ:
142                 case RTL8712_DMA_BMCQ:
143                 case RTL8712_DMA_MGTQ:
144                         pipe = usb_sndbulkpipe(pusbd, 0x0d);
145                         break;
146                 }
147         } else {
148            pipe = 0;
149         }
150         return pipe;
151 }
152
153 static void usb_write_mem_complete(struct urb *purb)
154 {
155         struct io_queue *pio_q = (struct io_queue *)purb->context;
156         struct intf_hdl *pintf = &(pio_q->intf);
157         struct intf_priv *pintfpriv = pintf->pintfpriv;
158         struct _adapter *padapter = (struct _adapter *)pintf->adapter;
159
160         if (purb->status != 0) {
161                 if (purb->status == (-ESHUTDOWN))
162                         padapter->bDriverStopped = true;
163                 else
164                         padapter->bSurpriseRemoved = true;
165         }
166         complete(&pintfpriv->io_retevt_comp);
167 }
168
169 void r8712_usb_write_mem(struct intf_hdl *pintfhdl, u32 addr, u32 cnt, u8 *wmem)
170 {
171         unsigned int pipe;
172         struct _adapter *padapter = (struct _adapter *)pintfhdl->adapter;
173         struct intf_priv *pintfpriv = pintfhdl->pintfpriv;
174         struct io_queue *pio_queue = padapter->pio_queue;
175         struct dvobj_priv *pdvobj = (struct dvobj_priv *)pintfpriv->intf_dev;
176         struct usb_device *pusbd = pdvobj->pusbdev;
177         struct urb *piorw_urb = pintfpriv->piorw_urb;
178
179         if ((padapter->bDriverStopped) || (padapter->bSurpriseRemoved) ||
180             (padapter->pwrctrlpriv.pnp_bstop_trx))
181                 return;
182         /* translate DMA FIFO addr to pipehandle */
183         pipe = ffaddr2pipehdl(pdvobj, addr);
184         if (pipe == 0)
185                 return;
186         usb_fill_bulk_urb(piorw_urb, pusbd, pipe,
187                           wmem, cnt, usb_write_mem_complete,
188                           pio_queue);
189         usb_submit_urb(piorw_urb, GFP_ATOMIC);
190         wait_for_completion_interruptible(&pintfpriv->io_retevt_comp);
191 }
192
193 static void r8712_usb_read_port_complete(struct urb *purb)
194 {
195         uint isevt, *pbuf;
196         struct recv_buf *precvbuf = (struct recv_buf *)purb->context;
197         struct _adapter *padapter = (struct _adapter *)precvbuf->adapter;
198         struct recv_priv *precvpriv = &padapter->recvpriv;
199
200         if (padapter->bSurpriseRemoved || padapter->bDriverStopped)
201                 return;
202         if (purb->status == 0) { /* SUCCESS */
203                 if ((purb->actual_length > (MAX_RECVBUF_SZ)) ||
204                     (purb->actual_length < RXDESC_SIZE)) {
205                         precvbuf->reuse = true;
206                         r8712_read_port(padapter, precvpriv->ff_hwaddr, 0,
207                                   (unsigned char *)precvbuf);
208                 } else {
209                         precvbuf->transfer_len = purb->actual_length;
210                         pbuf = (uint *)precvbuf->pbuf;
211                         isevt = le32_to_cpu(*(pbuf + 1)) & 0x1ff;
212                         if ((isevt & 0x1ff) == 0x1ff) {
213                                 r8712_rxcmd_event_hdl(padapter, pbuf);
214                                 precvbuf->reuse = true;
215                                 r8712_read_port(padapter, precvpriv->ff_hwaddr,
216                                                 0, (unsigned char *)precvbuf);
217                         } else {
218                                 _pkt *pskb = precvbuf->pskb;
219
220                                 skb_put(pskb, purb->actual_length);
221                                 skb_queue_tail(&precvpriv->rx_skb_queue, pskb);
222                                 tasklet_hi_schedule(&precvpriv->recv_tasklet);
223                                 precvbuf->pskb = NULL;
224                                 precvbuf->reuse = false;
225                                 r8712_read_port(padapter, precvpriv->ff_hwaddr,
226                                                 0, (unsigned char *)precvbuf);
227                         }
228                 }
229         } else {
230                 switch (purb->status) {
231                 case -EINVAL:
232                 case -EPIPE:
233                 case -ENODEV:
234                 case -ESHUTDOWN:
235                         padapter->bDriverStopped = true;
236                         break;
237                 case -ENOENT:
238                         if (!padapter->bSuspended) {
239                                 padapter->bDriverStopped = true;
240                                 break;
241                         }
242                         /* Fall through. */
243                 case -EPROTO:
244                         precvbuf->reuse = true;
245                         r8712_read_port(padapter, precvpriv->ff_hwaddr, 0,
246                                   (unsigned char *)precvbuf);
247                         break;
248                 case -EINPROGRESS:
249                         netdev_err(padapter->pnetdev, "ERROR: URB IS IN PROGRESS!\n");
250                         break;
251                 default:
252                         break;
253                 }
254         }
255 }
256
257 u32 r8712_usb_read_port(struct intf_hdl *pintfhdl, u32 addr, u32 cnt, u8 *rmem)
258 {
259         unsigned int pipe;
260         int err;
261         u32 tmpaddr = 0;
262         int alignment = 0;
263         u32 ret = _SUCCESS;
264         struct urb *purb = NULL;
265         struct recv_buf *precvbuf = (struct recv_buf *)rmem;
266         struct intf_priv *pintfpriv = pintfhdl->pintfpriv;
267         struct dvobj_priv *pdvobj = (struct dvobj_priv *)pintfpriv->intf_dev;
268         struct _adapter *adapter = pdvobj->padapter;
269         struct recv_priv *precvpriv = &adapter->recvpriv;
270         struct usb_device *pusbd = pdvobj->pusbdev;
271
272         if (adapter->bDriverStopped || adapter->bSurpriseRemoved ||
273             adapter->pwrctrlpriv.pnp_bstop_trx)
274                 return _FAIL;
275         if (precvbuf->reuse || !precvbuf->pskb) {
276                 precvbuf->pskb = skb_dequeue(&precvpriv->free_recv_skb_queue);
277                 if (precvbuf->pskb != NULL)
278                         precvbuf->reuse = true;
279         }
280         if (precvbuf != NULL) {
281                 r8712_init_recvbuf(adapter, precvbuf);
282                 /* re-assign for linux based on skb */
283                 if (!precvbuf->reuse || !precvbuf->pskb) {
284                         precvbuf->pskb = netdev_alloc_skb(adapter->pnetdev,
285                                          MAX_RECVBUF_SZ + RECVBUFF_ALIGN_SZ);
286                         if (!precvbuf->pskb)
287                                 return _FAIL;
288                         tmpaddr = (addr_t)precvbuf->pskb->data;
289                         alignment = tmpaddr & (RECVBUFF_ALIGN_SZ - 1);
290                         skb_reserve(precvbuf->pskb,
291                                     (RECVBUFF_ALIGN_SZ - alignment));
292                         precvbuf->phead = precvbuf->pskb->head;
293                         precvbuf->pdata = precvbuf->pskb->data;
294                         precvbuf->ptail = skb_tail_pointer(precvbuf->pskb);
295                         precvbuf->pend = skb_end_pointer(precvbuf->pskb);
296                         precvbuf->pbuf = precvbuf->pskb->data;
297                 } else { /* reuse skb */
298                         precvbuf->phead = precvbuf->pskb->head;
299                         precvbuf->pdata = precvbuf->pskb->data;
300                         precvbuf->ptail = skb_tail_pointer(precvbuf->pskb);
301                         precvbuf->pend = skb_end_pointer(precvbuf->pskb);
302                         precvbuf->pbuf = precvbuf->pskb->data;
303                         precvbuf->reuse = false;
304                 }
305                 purb = precvbuf->purb;
306                 /* translate DMA FIFO addr to pipehandle */
307                 pipe = ffaddr2pipehdl(pdvobj, addr);
308                 usb_fill_bulk_urb(purb, pusbd, pipe,
309                                   precvbuf->pbuf, MAX_RECVBUF_SZ,
310                                   r8712_usb_read_port_complete,
311                                   precvbuf);
312                 err = usb_submit_urb(purb, GFP_ATOMIC);
313                 if ((err) && (err != (-EPERM)))
314                         ret = _FAIL;
315         } else {
316                 ret = _FAIL;
317         }
318         return ret;
319 }
320
321 void r8712_usb_read_port_cancel(struct _adapter *padapter)
322 {
323         int i;
324         struct recv_buf *precvbuf;
325
326         precvbuf = (struct recv_buf *)padapter->recvpriv.precv_buf;
327         for (i = 0; i < NR_RECVBUFF; i++) {
328                 if (precvbuf->purb)
329                         usb_kill_urb(precvbuf->purb);
330                 precvbuf++;
331         }
332 }
333
334 void r8712_xmit_bh(void *priv)
335 {
336         int ret = false;
337         struct _adapter *padapter = priv;
338         struct xmit_priv *pxmitpriv = &padapter->xmitpriv;
339
340         if (padapter->bDriverStopped ||
341             padapter->bSurpriseRemoved) {
342                 netdev_err(padapter->pnetdev, "xmit_bh => bDriverStopped or bSurpriseRemoved\n");
343                 return;
344         }
345         ret = r8712_xmitframe_complete(padapter, pxmitpriv, NULL);
346         if (!ret)
347                 return;
348         tasklet_hi_schedule(&pxmitpriv->xmit_tasklet);
349 }
350
351 static void usb_write_port_complete(struct urb *purb)
352 {
353         int i;
354         struct xmit_frame *pxmitframe = (struct xmit_frame *)purb->context;
355         struct xmit_buf *pxmitbuf = pxmitframe->pxmitbuf;
356         struct _adapter *padapter = pxmitframe->padapter;
357         struct xmit_priv *pxmitpriv = &padapter->xmitpriv;
358         struct pkt_attrib *pattrib = &pxmitframe->attrib;
359
360         switch (pattrib->priority) {
361         case 1:
362         case 2:
363                 pxmitpriv->bkq_cnt--;
364                 break;
365         case 4:
366         case 5:
367                 pxmitpriv->viq_cnt--;
368                 break;
369         case 6:
370         case 7:
371                 pxmitpriv->voq_cnt--;
372                 break;
373         case 0:
374         case 3:
375         default:
376                 pxmitpriv->beq_cnt--;
377                 break;
378         }
379         pxmitpriv->txirp_cnt--;
380         for (i = 0; i < 8; i++) {
381                 if (purb == pxmitframe->pxmit_urb[i]) {
382                         pxmitframe->bpending[i] = false;
383                         break;
384                 }
385         }
386         if (padapter->bSurpriseRemoved)
387                 return;
388         switch (purb->status) {
389         case 0:
390                 break;
391         default:
392                 netdev_warn(padapter->pnetdev,
393                                 "r8712u: pipe error: (%d)\n", purb->status);
394                 break;
395         }
396         /* not to consider tx fragment */
397         r8712_free_xmitframe_ex(pxmitpriv, pxmitframe);
398         r8712_free_xmitbuf(pxmitpriv, pxmitbuf);
399         tasklet_hi_schedule(&pxmitpriv->xmit_tasklet);
400 }
401
402 u32 r8712_usb_write_port(struct intf_hdl *pintfhdl, u32 addr, u32 cnt, u8 *wmem)
403 {
404         unsigned long irqL;
405         int i, status;
406         unsigned int pipe;
407         u32 ret, bwritezero;
408         struct urb *purb = NULL;
409         struct _adapter *padapter = (struct _adapter *)pintfhdl->adapter;
410         struct dvobj_priv *pdvobj = &padapter->dvobjpriv;
411         struct xmit_priv *pxmitpriv = &padapter->xmitpriv;
412         struct xmit_frame *pxmitframe = (struct xmit_frame *)wmem;
413         struct usb_device *pusbd = pdvobj->pusbdev;
414         struct pkt_attrib *pattrib = &pxmitframe->attrib;
415
416         if ((padapter->bDriverStopped) || (padapter->bSurpriseRemoved) ||
417             (padapter->pwrctrlpriv.pnp_bstop_trx))
418                 return _FAIL;
419         for (i = 0; i < 8; i++) {
420                 if (!pxmitframe->bpending[i]) {
421                         spin_lock_irqsave(&pxmitpriv->lock, irqL);
422                         pxmitpriv->txirp_cnt++;
423                         pxmitframe->bpending[i]  = true;
424                         switch (pattrib->priority) {
425                         case 1:
426                         case 2:
427                                 pxmitpriv->bkq_cnt++;
428                                 break;
429                         case 4:
430                         case 5:
431                                 pxmitpriv->viq_cnt++;
432                                 break;
433                         case 6:
434                         case 7:
435                                 pxmitpriv->voq_cnt++;
436                                 break;
437                         case 0:
438                         case 3:
439                         default:
440                                 pxmitpriv->beq_cnt++;
441                                 break;
442                         }
443                         spin_unlock_irqrestore(&pxmitpriv->lock, irqL);
444                         pxmitframe->sz[i] = (u16)cnt;
445                         purb = pxmitframe->pxmit_urb[i];
446                         break;
447                 }
448         }
449         bwritezero = false;
450         if (pdvobj->ishighspeed) {
451                 if (cnt > 0 && cnt % 512 == 0)
452                         bwritezero = true;
453         } else {
454                 if (cnt > 0 && cnt % 64 == 0)
455                         bwritezero = true;
456         }
457         /* translate DMA FIFO addr to pipehandle */
458         pipe = ffaddr2pipehdl(pdvobj, addr);
459         if (pxmitpriv->free_xmitbuf_cnt % NR_XMITBUFF == 0)
460                 purb->transfer_flags  &=  (~URB_NO_INTERRUPT);
461         else
462                 purb->transfer_flags  |=  URB_NO_INTERRUPT;
463         if (bwritezero)
464                 cnt += 8;
465         usb_fill_bulk_urb(purb, pusbd, pipe,
466                           pxmitframe->mem_addr,
467                           cnt, usb_write_port_complete,
468                           pxmitframe); /* context is xmit_frame */
469         status = usb_submit_urb(purb, GFP_ATOMIC);
470         if (!status)
471                 ret = _SUCCESS;
472         else
473                 ret = _FAIL;
474         return ret;
475 }
476
477 void r8712_usb_write_port_cancel(struct _adapter *padapter)
478 {
479         int i, j;
480         struct xmit_buf *pxmitbuf = (struct xmit_buf *)
481                                      padapter->xmitpriv.pxmitbuf;
482
483         for (i = 0; i < NR_XMITBUFF; i++) {
484                 for (j = 0; j < 8; j++) {
485                         if (pxmitbuf->pxmit_urb[j])
486                                 usb_kill_urb(pxmitbuf->pxmit_urb[j]);
487                 }
488                 pxmitbuf++;
489         }
490 }
491
492 int r8712_usbctrl_vendorreq(struct intf_priv *pintfpriv, u8 request, u16 value,
493                       u16 index, void *pdata, u16 len, u8 requesttype)
494 {
495         unsigned int pipe;
496         int status;
497         u8 reqtype;
498         struct dvobj_priv *pdvobjpriv = (struct dvobj_priv *)
499                                          pintfpriv->intf_dev;
500         struct usb_device *udev = pdvobjpriv->pusbdev;
501         /* For mstar platform, mstar suggests the address for USB IO
502          * should be 16 bytes alignment. Trying to fix it here.
503          */
504         u8 *palloc_buf, *pIo_buf;
505
506         palloc_buf = kmalloc((u32)len + 16, GFP_ATOMIC);
507         if (!palloc_buf)
508                 return -ENOMEM;
509         pIo_buf = palloc_buf + 16 - ((addr_t)(palloc_buf) & 0x0f);
510         if (requesttype == 0x01) {
511                 pipe = usb_rcvctrlpipe(udev, 0); /* read_in */
512                 reqtype =  RTL871X_VENQT_READ;
513         } else {
514                 pipe = usb_sndctrlpipe(udev, 0); /* write_out */
515                 reqtype =  RTL871X_VENQT_WRITE;
516                 memcpy(pIo_buf, pdata, len);
517         }
518         status = usb_control_msg(udev, pipe, request, reqtype, value, index,
519                                  pIo_buf, len, HZ / 2);
520         if (status > 0) {  /* Success this control transfer. */
521                 if (requesttype == 0x01) {
522                         /* For Control read transfer, we have to copy the read
523                          * data from pIo_buf to pdata.
524                          */
525                         memcpy(pdata, pIo_buf,  status);
526                 }
527         }
528         kfree(palloc_buf);
529         return status;
530 }