ftp://ftp.kernel.org/pub/linux/kernel/v2.6/linux-2.6.6.tar.bz2
[linux-2.6.git] / drivers / isdn / hisax / st5481_usb.c
1 /*
2  * Driver for ST5481 USB ISDN modem
3  *
4  * Author       Frode Isaksen
5  * Copyright    2001 by Frode Isaksen      <fisaksen@bewan.com>
6  *              2001 by Kai Germaschewski  <kai.germaschewski@gmx.de>
7  * 
8  * This software may be used and distributed according to the terms
9  * of the GNU General Public License, incorporated herein by reference.
10  *
11  */
12
13 #include <linux/init.h>
14 #include <linux/usb.h>
15 #include <linux/slab.h>
16 #include "st5481.h"
17
18 /* ======================================================================
19  * control pipe
20  */
21
22 /*
23  * Send the next endpoint 0 request stored in the FIFO.
24  * Called either by the completion or by usb_ctrl_msg.
25  */
26 static void usb_next_ctrl_msg(struct urb *urb,
27                               struct st5481_adapter *adapter)
28 {
29         struct st5481_ctrl *ctrl = &adapter->ctrl;
30         int r_index;
31
32         if (test_and_set_bit(0, &ctrl->busy)) {
33                 return;
34         }
35
36         if ((r_index = fifo_remove(&ctrl->msg_fifo.f)) < 0) {
37                 test_and_clear_bit(0,&ctrl->busy);
38                 return;
39         } 
40         urb->setup_packet = 
41                 (unsigned char *)&ctrl->msg_fifo.data[r_index];
42         
43         DBG(1,"request=0x%02x,value=0x%04x,index=%x",
44             ((struct ctrl_msg *)urb->setup_packet)->dr.bRequest,
45             ((struct ctrl_msg *)urb->setup_packet)->dr.wValue,
46             ((struct ctrl_msg *)urb->setup_packet)->dr.wIndex);
47
48         // Prepare the URB
49         urb->dev = adapter->usb_dev;
50
51         SUBMIT_URB(urb, GFP_ATOMIC);
52 }
53
54 /*
55  * Asynchronous endpoint 0 request (async version of usb_control_msg).
56  * The request will be queued up in a FIFO if the endpoint is busy.
57  */
58 void usb_ctrl_msg(struct st5481_adapter *adapter,
59                   u8 request, u8 requesttype, u16 value, u16 index,
60                   ctrl_complete_t complete, void *context)
61 {
62         struct st5481_ctrl *ctrl = &adapter->ctrl;
63         int w_index;
64         struct ctrl_msg *ctrl_msg;
65         
66         if ((w_index = fifo_add(&ctrl->msg_fifo.f)) < 0) {
67                 WARN("control msg FIFO full");
68                 return;
69         }
70         ctrl_msg = &ctrl->msg_fifo.data[w_index]; 
71    
72         ctrl_msg->dr.bRequestType = requesttype;
73         ctrl_msg->dr.bRequest = request;
74         ctrl_msg->dr.wValue = cpu_to_le16p(&value);
75         ctrl_msg->dr.wIndex = cpu_to_le16p(&index);
76         ctrl_msg->dr.wLength = 0;
77         ctrl_msg->complete = complete;
78         ctrl_msg->context = context;
79
80         usb_next_ctrl_msg(ctrl->urb, adapter);
81 }
82
83 /*
84  * Asynchronous endpoint 0 device request.
85  */
86 void st5481_usb_device_ctrl_msg(struct st5481_adapter *adapter,
87                          u8 request, u16 value,
88                          ctrl_complete_t complete, void *context)
89 {
90         usb_ctrl_msg(adapter, request, 
91                      USB_DIR_OUT | USB_TYPE_VENDOR | USB_RECIP_DEVICE, 
92                      value, 0, complete, context);
93 }
94
95 /*
96  * Asynchronous pipe reset (async version of usb_clear_halt).
97  */
98 void st5481_usb_pipe_reset(struct st5481_adapter *adapter,
99                     u_char pipe,
100                     ctrl_complete_t complete, void *context)
101 {
102         DBG(1,"pipe=%02x",pipe);
103
104         usb_ctrl_msg(adapter,
105                      USB_REQ_CLEAR_FEATURE, USB_DIR_OUT | USB_RECIP_ENDPOINT,
106                      0, pipe, complete, context);
107 }
108
109
110 /*
111   Physical level functions
112 */
113
114 void st5481_ph_command(struct st5481_adapter *adapter, unsigned int command)
115 {
116         DBG(8,"command=%s", ST5481_CMD_string(command));
117
118         st5481_usb_device_ctrl_msg(adapter, TXCI, command, NULL, NULL);
119 }
120
121 /*
122  * The request on endpoint 0 has completed.
123  * Call the user provided completion routine and try
124  * to send the next request.
125  */
126 static void usb_ctrl_complete(struct urb *urb, struct pt_regs *regs)
127 {
128         struct st5481_adapter *adapter = urb->context;
129         struct st5481_ctrl *ctrl = &adapter->ctrl;
130         struct ctrl_msg *ctrl_msg;
131         
132         if (unlikely(urb->status < 0)) {
133                 if (urb->status != -ENOENT && urb->status != -ESHUTDOWN) {
134                         WARN("urb status %d",urb->status);
135                 } else {
136                         DBG(1,"urb killed");
137                         return; // Give up
138                 }
139         }
140
141         ctrl_msg = (struct ctrl_msg *)urb->setup_packet;
142         
143         if (ctrl_msg->dr.bRequest == USB_REQ_CLEAR_FEATURE) {
144                 /* Special case handling for pipe reset */
145                 le16_to_cpus(&ctrl_msg->dr.wIndex);
146                 usb_endpoint_running(adapter->usb_dev,
147                                      ctrl_msg->dr.wIndex & ~USB_DIR_IN, 
148                                      (ctrl_msg->dr.wIndex & USB_DIR_IN) == 0);
149
150                 /* toggle is reset on clear */
151                 usb_settoggle(adapter->usb_dev, 
152                               ctrl_msg->dr.wIndex & ~USB_DIR_IN, 
153                               (ctrl_msg->dr.wIndex & USB_DIR_IN) == 0,
154                               0);
155
156
157         }
158         
159         if (ctrl_msg->complete)
160                 ctrl_msg->complete(ctrl_msg->context);
161
162         clear_bit(0, &ctrl->busy);
163         
164         // Try to send next control message
165         usb_next_ctrl_msg(urb, adapter);
166         return;
167 }
168
169 /* ======================================================================
170  * interrupt pipe
171  */
172
173 /*
174  * The interrupt endpoint will be called when any
175  * of the 6 registers changes state (depending on masks).
176  * Decode the register values and schedule a private event.
177  * Called at interrupt.
178  */
179 static void usb_int_complete(struct urb *urb, struct pt_regs *regs)
180 {
181         u8 *data = urb->transfer_buffer;
182         u8 irqbyte;
183         struct st5481_adapter *adapter = urb->context;
184         int j;
185         int status;
186
187         switch (urb->status) {
188         case 0:
189                 /* success */
190                 break;
191         case -ECONNRESET:
192         case -ENOENT:
193         case -ESHUTDOWN:
194                 /* this urb is terminated, clean up */
195                 DBG(1, "urb shutting down with status: %d", urb->status);
196                 return;
197         default:
198                 WARN("nonzero urb status received: %d", urb->status);
199                 goto exit;
200         }
201
202         
203         DBG_PACKET(1, data, INT_PKT_SIZE);
204                 
205         if (urb->actual_length == 0) {
206                 goto exit;
207         }
208
209         irqbyte = data[MPINT];
210         if (irqbyte & DEN_INT)
211                 FsmEvent(&adapter->d_out.fsm, EV_DOUT_DEN, NULL);
212
213         if (irqbyte & DCOLL_INT)
214                 FsmEvent(&adapter->d_out.fsm, EV_DOUT_COLL, NULL);
215
216         irqbyte = data[FFINT_D];
217         if (irqbyte & OUT_UNDERRUN)
218                 FsmEvent(&adapter->d_out.fsm, EV_DOUT_UNDERRUN, NULL);
219
220         if (irqbyte & OUT_DOWN)
221 ;//             printk("OUT_DOWN\n");
222
223         irqbyte = data[MPINT];
224         if (irqbyte & RXCI_INT)
225                 FsmEvent(&adapter->l1m, data[CCIST] & 0x0f, NULL);
226
227         for (j = 0; j < 2; j++)
228                 adapter->bcs[j].b_out.flow_event |= data[FFINT_B1 + j];
229
230         urb->actual_length = 0;
231
232 exit:
233         status = usb_submit_urb (urb, GFP_ATOMIC);
234         if (status)
235                 WARN("usb_submit_urb failed with result %d", status);
236 }
237
238 /* ======================================================================
239  * initialization
240  */
241
242 int st5481_setup_usb(struct st5481_adapter *adapter)
243 {
244         struct usb_device *dev = adapter->usb_dev;
245         struct st5481_ctrl *ctrl = &adapter->ctrl;
246         struct st5481_intr *intr = &adapter->intr;
247         struct usb_host_interface *altsetting;
248         struct usb_host_endpoint *endpoint;
249         int status;
250         struct urb *urb;
251         u8 *buf;
252         
253         DBG(1,"");
254         
255         if ((status = usb_reset_configuration (dev)) < 0) {
256                 WARN("reset_configuration failed,status=%d",status);
257                 return status;
258         }
259
260         
261         altsetting = &(dev->config->interface[0]->altsetting[3]);       
262
263         // Check if the config is sane
264         if ( altsetting->desc.bNumEndpoints != 7 ) {
265                 WARN("expecting 7 got %d endpoints!", altsetting->desc.bNumEndpoints);
266                 return -EINVAL;
267         }
268
269         // The descriptor is wrong for some early samples of the ST5481 chip
270         altsetting->endpoint[3].desc.wMaxPacketSize = 32;
271         altsetting->endpoint[4].desc.wMaxPacketSize = 32;
272
273         // Use alternative setting 3 on interface 0 to have 2B+D
274         if ((status = usb_set_interface (dev, 0, 3)) < 0) {
275                 WARN("usb_set_interface failed,status=%d",status);
276                 return status;
277         }
278
279         // Allocate URB for control endpoint
280         urb = usb_alloc_urb(0, GFP_KERNEL);
281         if (!urb) {
282                 return -ENOMEM;
283         }
284         ctrl->urb = urb;
285         
286         // Fill the control URB
287         usb_fill_control_urb (urb, dev, 
288                           usb_sndctrlpipe(dev, 0),
289                           NULL, NULL, 0, usb_ctrl_complete, adapter);
290
291                 
292         fifo_init(&ctrl->msg_fifo.f, ARRAY_SIZE(ctrl->msg_fifo.data));
293
294         // Allocate URBs and buffers for interrupt endpoint
295         urb = usb_alloc_urb(0, GFP_KERNEL);
296         if (!urb) { 
297                 return -ENOMEM;
298         }
299         intr->urb = urb;
300         
301         buf = kmalloc(INT_PKT_SIZE, GFP_KERNEL);
302         if (!buf) {
303                 return -ENOMEM;
304         }
305
306         endpoint = &altsetting->endpoint[EP_INT-1];
307                                 
308         // Fill the interrupt URB
309         usb_fill_int_urb(urb, dev,
310                      usb_rcvintpipe(dev, endpoint->desc.bEndpointAddress),
311                      buf, INT_PKT_SIZE,
312                      usb_int_complete, adapter,
313                      endpoint->desc.bInterval);
314                 
315         return 0;
316 }
317
318 /*
319  * Release buffers and URBs for the interrupt and control
320  * endpoint.
321  */
322 void st5481_release_usb(struct st5481_adapter *adapter)
323 {
324         struct st5481_intr *intr = &adapter->intr;
325         struct st5481_ctrl *ctrl = &adapter->ctrl;
326
327         DBG(1,"");
328
329         // Stop and free Control and Interrupt URBs
330         usb_unlink_urb(ctrl->urb);
331         if (ctrl->urb->transfer_buffer)
332                 kfree(ctrl->urb->transfer_buffer);
333         usb_free_urb(ctrl->urb);
334
335         usb_unlink_urb(intr->urb);
336         if (intr->urb->transfer_buffer)
337                 kfree(intr->urb->transfer_buffer);
338         usb_free_urb(intr->urb);
339 }
340
341 /*
342  *  Initialize the adapter.
343  */
344 void st5481_start(struct st5481_adapter *adapter)
345 {
346         static const u8 init_cmd_table[]={
347                 SET_DEFAULT,0,
348                 STT,0,
349                 SDA_MIN,0x0d,
350                 SDA_MAX,0x29,
351                 SDELAY_VALUE,0x14,
352                 GPIO_DIR,0x01,          
353                 GPIO_OUT,RED_LED,
354 //              FFCTRL_OUT_D,4,
355 //              FFCTRH_OUT_D,12,
356                 FFCTRL_OUT_B1,6,
357                 FFCTRH_OUT_B1,20,
358                 FFCTRL_OUT_B2,6,
359                 FFCTRH_OUT_B2,20,
360                 MPMSK,RXCI_INT+DEN_INT+DCOLL_INT,
361                 0
362         };      
363         struct st5481_intr *intr = &adapter->intr;
364         int i = 0;
365         u8 request,value;
366
367         DBG(8,"");
368
369         adapter->leds = RED_LED; 
370
371         // Start receiving on the interrupt endpoint
372         SUBMIT_URB(intr->urb, GFP_KERNEL); 
373
374         while ((request = init_cmd_table[i++])) {
375                 value = init_cmd_table[i++];
376                 st5481_usb_device_ctrl_msg(adapter, request, value, NULL, NULL);
377         }
378         st5481_ph_command(adapter, ST5481_CMD_PUP);
379 }
380
381 /*
382  * Reset the adapter to default values.
383  */
384 void st5481_stop(struct st5481_adapter *adapter)
385 {
386         DBG(8,"");
387
388         st5481_usb_device_ctrl_msg(adapter, SET_DEFAULT, 0, NULL, NULL);
389 }
390
391 /* ======================================================================
392  * isochronous USB  helpers
393  */
394
395 static void
396 fill_isoc_urb(struct urb *urb, struct usb_device *dev,
397               unsigned int pipe, void *buf, int num_packets, 
398               int packet_size, usb_complete_t complete,
399               void *context) 
400 {
401         int k;
402
403         spin_lock_init(&urb->lock);
404         urb->dev=dev;
405         urb->pipe=pipe;
406         urb->transfer_buffer=buf;
407         urb->number_of_packets = num_packets;
408         urb->transfer_buffer_length=num_packets*packet_size;
409         urb->actual_length = 0;
410         urb->complete=complete;
411         urb->context=context;
412         urb->transfer_flags=URB_ISO_ASAP;
413         for (k = 0; k < num_packets; k++) {
414                 urb->iso_frame_desc[k].offset = packet_size * k;
415                 urb->iso_frame_desc[k].length = packet_size;
416                 urb->iso_frame_desc[k].actual_length = 0;
417         }
418 }
419
420 int
421 st5481_setup_isocpipes(struct urb* urb[2], struct usb_device *dev, 
422                            unsigned int pipe, int num_packets,
423                            int packet_size, int buf_size,
424                            usb_complete_t complete, void *context)
425 {
426         int j, retval;
427         unsigned char *buf;
428
429         for (j = 0; j < 2; j++) {
430                 retval = -ENOMEM;
431                 urb[j] = usb_alloc_urb(num_packets, GFP_KERNEL);
432                 if (!urb[j])
433                         goto err;
434
435                 // Allocate memory for 2000bytes/sec (16Kb/s)
436                 buf = kmalloc(buf_size, GFP_KERNEL);
437                 if (!buf)
438                         goto err;
439                         
440                 // Fill the isochronous URB
441                 fill_isoc_urb(urb[j], dev, pipe, buf, 
442                               num_packets, packet_size, complete,
443                               context);
444         }
445         return 0;
446
447  err:
448         for (j = 0; j < 2; j++) {
449                 if (urb[j]) {
450                         if (urb[j]->transfer_buffer)
451                                 kfree(urb[j]->transfer_buffer);
452                         usb_free_urb(urb[j]);
453                 }
454         }
455         return retval;
456 }
457
458 void st5481_release_isocpipes(struct urb* urb[2])
459 {
460         int j;
461
462         for (j = 0; j < 2; j++) {
463                 usb_unlink_urb(urb[j]);
464                 if (urb[j]->transfer_buffer)
465                         kfree(urb[j]->transfer_buffer);                 
466                 usb_free_urb(urb[j]);
467         }
468 }
469
470 /*
471  * Decode frames received on the B/D channel.
472  * Note that this function will be called continously
473  * with 64Kbit/s / 16Kbit/s of data and hence it will be 
474  * called 50 times per second with 20 ISOC descriptors. 
475  * Called at interrupt.
476  */
477 static void usb_in_complete(struct urb *urb, struct pt_regs *regs)
478 {
479         struct st5481_in *in = urb->context;
480         unsigned char *ptr;
481         struct sk_buff *skb;
482         int len, count, status;
483
484         if (unlikely(urb->status < 0)) {
485                 if (urb->status != -ENOENT && urb->status != -ESHUTDOWN) {
486                         WARN("urb status %d",urb->status);
487                 } else {
488                         DBG(1,"urb killed");
489                         return; // Give up
490                 }
491         }
492
493         DBG_ISO_PACKET(0x80,urb);
494
495         len = st5481_isoc_flatten(urb);
496         ptr = urb->transfer_buffer;
497         while (len > 0) {
498                 if (in->mode == L1_MODE_TRANS) {
499                         memcpy(in->rcvbuf, ptr, len);
500                         status = len;
501                         len = 0;
502                 } else {
503                         status = isdnhdlc_decode(&in->hdlc_state, ptr, len, &count,
504                                 in->rcvbuf, in->bufsize);
505                         ptr += count;
506                         len -= count;
507                 }
508                 
509                 if (status > 0) {
510                         // Good frame received
511                         DBG(4,"count=%d",status);
512                         DBG_PACKET(0x400, in->rcvbuf, status);
513                         if (!(skb = dev_alloc_skb(status))) {
514                                 WARN("receive out of memory\n");
515                                 break;
516                         }
517                         memcpy(skb_put(skb, status), in->rcvbuf, status);
518                         in->hisax_if->l1l2(in->hisax_if, PH_DATA | INDICATION, skb);
519                 } else if (status == -HDLC_CRC_ERROR) {
520                         INFO("CRC error");
521                 } else if (status == -HDLC_FRAMING_ERROR) {
522                         INFO("framing error");
523                 } else if (status == -HDLC_LENGTH_ERROR) {
524                         INFO("length error");
525                 }
526         }
527
528         // Prepare URB for next transfer
529         urb->dev = in->adapter->usb_dev;
530         urb->actual_length = 0;
531
532         SUBMIT_URB(urb, GFP_ATOMIC);
533 }
534
535 int st5481_setup_in(struct st5481_in *in)
536 {
537         struct usb_device *dev = in->adapter->usb_dev;
538         int retval;
539
540         DBG(4,"");
541
542         in->rcvbuf = kmalloc(in->bufsize, GFP_KERNEL);
543         retval = -ENOMEM;
544         if (!in->rcvbuf)
545                 goto err;
546
547         retval = st5481_setup_isocpipes(in->urb, dev, 
548                                         usb_rcvisocpipe(dev, in->ep),
549                                         in->num_packets,  in->packet_size,
550                                         in->num_packets * in->packet_size,
551                                         usb_in_complete, in);
552         if (retval)
553                 goto err_free;
554         return 0;
555
556  err_free:
557         kfree(in->rcvbuf);
558  err:
559         return retval;
560 }
561
562 void st5481_release_in(struct st5481_in *in)
563 {
564         DBG(2,"");
565
566         st5481_release_isocpipes(in->urb);
567 }
568
569 /*
570  * Make the transfer_buffer contiguous by
571  * copying from the iso descriptors if necessary. 
572  */
573 int st5481_isoc_flatten(struct urb *urb)
574 {
575         struct usb_iso_packet_descriptor *pipd,*pend;
576         unsigned char *src,*dst;
577         unsigned int len;
578         
579         if (urb->status < 0) {
580                 return urb->status;
581         }
582         for (pipd = &urb->iso_frame_desc[0],
583                      pend = &urb->iso_frame_desc[urb->number_of_packets],
584                      dst = urb->transfer_buffer; 
585              pipd < pend; 
586              pipd++) {
587                 
588                 if (pipd->status < 0) {
589                         return (pipd->status);
590                 }
591         
592                 len = pipd->actual_length;
593                 pipd->actual_length = 0;
594                 src = urb->transfer_buffer+pipd->offset;
595
596                 if (src != dst) {
597                         // Need to copy since isoc buffers not full
598                         while (len--) {
599                                 *dst++ = *src++;
600                         }                       
601                 } else {
602                         // No need to copy, just update destination buffer
603                         dst += len;
604                 }
605         }
606         // Return size of flattened buffer
607         return (dst - (unsigned char *)urb->transfer_buffer);
608 }
609
610 static void st5481_start_rcv(void *context)
611 {
612         struct st5481_in *in = context;
613         struct st5481_adapter *adapter = in->adapter;
614
615         DBG(4,"");
616
617         in->urb[0]->dev = adapter->usb_dev;
618         SUBMIT_URB(in->urb[0], GFP_KERNEL);
619
620         in->urb[1]->dev = adapter->usb_dev;
621         SUBMIT_URB(in->urb[1], GFP_KERNEL);
622 }
623
624 void st5481_in_mode(struct st5481_in *in, int mode)
625 {
626         if (in->mode == mode)
627                 return;
628
629         in->mode = mode;
630
631         usb_unlink_urb(in->urb[0]);
632         usb_unlink_urb(in->urb[1]);
633
634         if (in->mode != L1_MODE_NULL) {
635                 if (in->mode != L1_MODE_TRANS)
636                         isdnhdlc_rcv_init(&in->hdlc_state,
637                                 in->mode == L1_MODE_HDLC_56K);
638                 
639                 st5481_usb_pipe_reset(in->adapter, in->ep, NULL, NULL);
640                 st5481_usb_device_ctrl_msg(in->adapter, in->counter,
641                                            in->packet_size,
642                                            NULL, NULL);
643                 st5481_start_rcv(in);
644         } else {
645                 st5481_usb_device_ctrl_msg(in->adapter, in->counter,
646                                            0, NULL, NULL);
647         }
648 }
649