Merge branch 'for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/roland...
[linux-2.6] / drivers / usb / serial / pl2303.c
1 /*
2  * Prolific PL2303 USB to serial adaptor driver
3  *
4  * Copyright (C) 2001-2007 Greg Kroah-Hartman (greg@kroah.com)
5  * Copyright (C) 2003 IBM Corp.
6  *
7  * Original driver for 2.2.x by anonymous
8  *
9  *      This program is free software; you can redistribute it and/or
10  *      modify it under the terms of the GNU General Public License version
11  *      2 as published by the Free Software Foundation.
12  *
13  * See Documentation/usb/usb-serial.txt for more information on using this driver
14  *
15  */
16
17 #include <linux/kernel.h>
18 #include <linux/errno.h>
19 #include <linux/init.h>
20 #include <linux/slab.h>
21 #include <linux/tty.h>
22 #include <linux/tty_driver.h>
23 #include <linux/tty_flip.h>
24 #include <linux/serial.h>
25 #include <linux/module.h>
26 #include <linux/moduleparam.h>
27 #include <linux/spinlock.h>
28 #include <asm/uaccess.h>
29 #include <linux/usb.h>
30 #include <linux/usb/serial.h>
31 #include "pl2303.h"
32
33 /*
34  * Version Information
35  */
36 #define DRIVER_DESC "Prolific PL2303 USB to serial adaptor driver"
37
38 static int debug;
39
40 #define PL2303_CLOSING_WAIT     (30*HZ)
41
42 #define PL2303_BUF_SIZE         1024
43 #define PL2303_TMP_BUF_SIZE     1024
44
45 struct pl2303_buf {
46         unsigned int    buf_size;
47         char            *buf_buf;
48         char            *buf_get;
49         char            *buf_put;
50 };
51
52 static struct usb_device_id id_table [] = {
53         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID) },
54         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID_RSAQ2) },
55         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID_DCU11) },
56         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID_RSAQ3) },
57         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID_PHAROS) },
58         { USB_DEVICE(PL2303_VENDOR_ID, PL2303_PRODUCT_ID_ALDIGA) },
59         { USB_DEVICE(IODATA_VENDOR_ID, IODATA_PRODUCT_ID) },
60         { USB_DEVICE(IODATA_VENDOR_ID, IODATA_PRODUCT_ID_RSAQ5) },
61         { USB_DEVICE(ATEN_VENDOR_ID, ATEN_PRODUCT_ID) },
62         { USB_DEVICE(ATEN_VENDOR_ID2, ATEN_PRODUCT_ID) },
63         { USB_DEVICE(ELCOM_VENDOR_ID, ELCOM_PRODUCT_ID) },
64         { USB_DEVICE(ELCOM_VENDOR_ID, ELCOM_PRODUCT_ID_UCSGT) },
65         { USB_DEVICE(ITEGNO_VENDOR_ID, ITEGNO_PRODUCT_ID) },
66         { USB_DEVICE(ITEGNO_VENDOR_ID, ITEGNO_PRODUCT_ID_2080) },
67         { USB_DEVICE(MA620_VENDOR_ID, MA620_PRODUCT_ID) },
68         { USB_DEVICE(RATOC_VENDOR_ID, RATOC_PRODUCT_ID) },
69         { USB_DEVICE(RATOC_VENDOR_ID, RATOC_PRODUCT_ID_USB60F) },
70         { USB_DEVICE(TRIPP_VENDOR_ID, TRIPP_PRODUCT_ID) },
71         { USB_DEVICE(RADIOSHACK_VENDOR_ID, RADIOSHACK_PRODUCT_ID) },
72         { USB_DEVICE(DCU10_VENDOR_ID, DCU10_PRODUCT_ID) },
73         { USB_DEVICE(SITECOM_VENDOR_ID, SITECOM_PRODUCT_ID) },
74         { USB_DEVICE(ALCATEL_VENDOR_ID, ALCATEL_PRODUCT_ID) },
75         { USB_DEVICE(SAMSUNG_VENDOR_ID, SAMSUNG_PRODUCT_ID) },
76         { USB_DEVICE(SIEMENS_VENDOR_ID, SIEMENS_PRODUCT_ID_SX1) },
77         { USB_DEVICE(SIEMENS_VENDOR_ID, SIEMENS_PRODUCT_ID_X65) },
78         { USB_DEVICE(SIEMENS_VENDOR_ID, SIEMENS_PRODUCT_ID_X75) },
79         { USB_DEVICE(SIEMENS_VENDOR_ID, SIEMENS_PRODUCT_ID_EF81) },
80         { USB_DEVICE(SYNTECH_VENDOR_ID, SYNTECH_PRODUCT_ID) },
81         { USB_DEVICE(NOKIA_CA42_VENDOR_ID, NOKIA_CA42_PRODUCT_ID) },
82         { USB_DEVICE(CA_42_CA42_VENDOR_ID, CA_42_CA42_PRODUCT_ID) },
83         { USB_DEVICE(SAGEM_VENDOR_ID, SAGEM_PRODUCT_ID) },
84         { USB_DEVICE(LEADTEK_VENDOR_ID, LEADTEK_9531_PRODUCT_ID) },
85         { USB_DEVICE(SPEEDDRAGON_VENDOR_ID, SPEEDDRAGON_PRODUCT_ID) },
86         { USB_DEVICE(DATAPILOT_U2_VENDOR_ID, DATAPILOT_U2_PRODUCT_ID) },
87         { USB_DEVICE(BELKIN_VENDOR_ID, BELKIN_PRODUCT_ID) },
88         { USB_DEVICE(ALCOR_VENDOR_ID, ALCOR_PRODUCT_ID) },
89         { USB_DEVICE(WS002IN_VENDOR_ID, WS002IN_PRODUCT_ID) },
90         { USB_DEVICE(COREGA_VENDOR_ID, COREGA_PRODUCT_ID) },
91         { USB_DEVICE(HL340_VENDOR_ID, HL340_PRODUCT_ID) },
92         { USB_DEVICE(YCCABLE_VENDOR_ID, YCCABLE_PRODUCT_ID) },
93         { }                                     /* Terminating entry */
94 };
95
96 MODULE_DEVICE_TABLE(usb, id_table);
97
98 static struct usb_driver pl2303_driver = {
99         .name =         "pl2303",
100         .probe =        usb_serial_probe,
101         .disconnect =   usb_serial_disconnect,
102         .id_table =     id_table,
103         .suspend =      usb_serial_suspend,
104         .resume =       usb_serial_resume,
105         .no_dynamic_id =        1,
106         .supports_autosuspend = 1,
107 };
108
109 #define SET_LINE_REQUEST_TYPE           0x21
110 #define SET_LINE_REQUEST                0x20
111
112 #define SET_CONTROL_REQUEST_TYPE        0x21
113 #define SET_CONTROL_REQUEST             0x22
114 #define CONTROL_DTR                     0x01
115 #define CONTROL_RTS                     0x02
116
117 #define BREAK_REQUEST_TYPE              0x21
118 #define BREAK_REQUEST                   0x23    
119 #define BREAK_ON                        0xffff
120 #define BREAK_OFF                       0x0000
121
122 #define GET_LINE_REQUEST_TYPE           0xa1
123 #define GET_LINE_REQUEST                0x21
124
125 #define VENDOR_WRITE_REQUEST_TYPE       0x40
126 #define VENDOR_WRITE_REQUEST            0x01
127
128 #define VENDOR_READ_REQUEST_TYPE        0xc0
129 #define VENDOR_READ_REQUEST             0x01
130
131 #define UART_STATE                      0x08
132 #define UART_STATE_TRANSIENT_MASK       0x74
133 #define UART_DCD                        0x01
134 #define UART_DSR                        0x02
135 #define UART_BREAK_ERROR                0x04
136 #define UART_RING                       0x08
137 #define UART_FRAME_ERROR                0x10
138 #define UART_PARITY_ERROR               0x20
139 #define UART_OVERRUN_ERROR              0x40
140 #define UART_CTS                        0x80
141
142
143 enum pl2303_type {
144         type_0,         /* don't know the difference between type 0 and */
145         type_1,         /* type 1, until someone from prolific tells us... */
146         HX,             /* HX version of the pl2303 chip */
147 };
148
149 struct pl2303_private {
150         spinlock_t lock;
151         struct pl2303_buf *buf;
152         int write_urb_in_use;
153         wait_queue_head_t delta_msr_wait;
154         u8 line_control;
155         u8 line_status;
156         u8 termios_initialized;
157         enum pl2303_type type;
158 };
159
160 /*
161  * pl2303_buf_alloc
162  *
163  * Allocate a circular buffer and all associated memory.
164  */
165 static struct pl2303_buf *pl2303_buf_alloc(unsigned int size)
166 {
167         struct pl2303_buf *pb;
168
169         if (size == 0)
170                 return NULL;
171
172         pb = kmalloc(sizeof(struct pl2303_buf), GFP_KERNEL);
173         if (pb == NULL)
174                 return NULL;
175
176         pb->buf_buf = kmalloc(size, GFP_KERNEL);
177         if (pb->buf_buf == NULL) {
178                 kfree(pb);
179                 return NULL;
180         }
181
182         pb->buf_size = size;
183         pb->buf_get = pb->buf_put = pb->buf_buf;
184
185         return pb;
186 }
187
188 /*
189  * pl2303_buf_free
190  *
191  * Free the buffer and all associated memory.
192  */
193 static void pl2303_buf_free(struct pl2303_buf *pb)
194 {
195         if (pb) {
196                 kfree(pb->buf_buf);
197                 kfree(pb);
198         }
199 }
200
201 /*
202  * pl2303_buf_clear
203  *
204  * Clear out all data in the circular buffer.
205  */
206 static void pl2303_buf_clear(struct pl2303_buf *pb)
207 {
208         if (pb != NULL)
209                 pb->buf_get = pb->buf_put;
210                 /* equivalent to a get of all data available */
211 }
212
213 /*
214  * pl2303_buf_data_avail
215  *
216  * Return the number of bytes of data available in the circular
217  * buffer.
218  */
219 static unsigned int pl2303_buf_data_avail(struct pl2303_buf *pb)
220 {
221         if (pb == NULL)
222                 return 0;
223
224         return ((pb->buf_size + pb->buf_put - pb->buf_get) % pb->buf_size);
225 }
226
227 /*
228  * pl2303_buf_space_avail
229  *
230  * Return the number of bytes of space available in the circular
231  * buffer.
232  */
233 static unsigned int pl2303_buf_space_avail(struct pl2303_buf *pb)
234 {
235         if (pb == NULL)
236                 return 0;
237
238         return ((pb->buf_size + pb->buf_get - pb->buf_put - 1) % pb->buf_size);
239 }
240
241 /*
242  * pl2303_buf_put
243  *
244  * Copy data data from a user buffer and put it into the circular buffer.
245  * Restrict to the amount of space available.
246  *
247  * Return the number of bytes copied.
248  */
249 static unsigned int pl2303_buf_put(struct pl2303_buf *pb, const char *buf,
250                                    unsigned int count)
251 {
252         unsigned int len;
253
254         if (pb == NULL)
255                 return 0;
256
257         len  = pl2303_buf_space_avail(pb);
258         if (count > len)
259                 count = len;
260
261         if (count == 0)
262                 return 0;
263
264         len = pb->buf_buf + pb->buf_size - pb->buf_put;
265         if (count > len) {
266                 memcpy(pb->buf_put, buf, len);
267                 memcpy(pb->buf_buf, buf+len, count - len);
268                 pb->buf_put = pb->buf_buf + count - len;
269         } else {
270                 memcpy(pb->buf_put, buf, count);
271                 if (count < len)
272                         pb->buf_put += count;
273                 else /* count == len */
274                         pb->buf_put = pb->buf_buf;
275         }
276
277         return count;
278 }
279
280 /*
281  * pl2303_buf_get
282  *
283  * Get data from the circular buffer and copy to the given buffer.
284  * Restrict to the amount of data available.
285  *
286  * Return the number of bytes copied.
287  */
288 static unsigned int pl2303_buf_get(struct pl2303_buf *pb, char *buf,
289                                    unsigned int count)
290 {
291         unsigned int len;
292
293         if (pb == NULL)
294                 return 0;
295
296         len = pl2303_buf_data_avail(pb);
297         if (count > len)
298                 count = len;
299
300         if (count == 0)
301                 return 0;
302
303         len = pb->buf_buf + pb->buf_size - pb->buf_get;
304         if (count > len) {
305                 memcpy(buf, pb->buf_get, len);
306                 memcpy(buf+len, pb->buf_buf, count - len);
307                 pb->buf_get = pb->buf_buf + count - len;
308         } else {
309                 memcpy(buf, pb->buf_get, count);
310                 if (count < len)
311                         pb->buf_get += count;
312                 else /* count == len */
313                         pb->buf_get = pb->buf_buf;
314         }
315
316         return count;
317 }
318
319 static int pl2303_vendor_read(__u16 value, __u16 index,
320                 struct usb_serial *serial, unsigned char *buf)
321 {
322         int res = usb_control_msg(serial->dev, usb_rcvctrlpipe(serial->dev, 0),
323                         VENDOR_READ_REQUEST, VENDOR_READ_REQUEST_TYPE,
324                         value, index, buf, 1, 100);
325         dbg("0x%x:0x%x:0x%x:0x%x  %d - %x", VENDOR_READ_REQUEST_TYPE,
326                         VENDOR_READ_REQUEST, value, index, res, buf[0]);
327         return res;
328 }
329
330 static int pl2303_vendor_write(__u16 value, __u16 index,
331                 struct usb_serial *serial)
332 {
333         int res = usb_control_msg(serial->dev, usb_sndctrlpipe(serial->dev, 0),
334                         VENDOR_WRITE_REQUEST, VENDOR_WRITE_REQUEST_TYPE,
335                         value, index, NULL, 0, 100);
336         dbg("0x%x:0x%x:0x%x:0x%x  %d", VENDOR_WRITE_REQUEST_TYPE,
337                         VENDOR_WRITE_REQUEST, value, index, res);
338         return res;
339 }
340
341 static int pl2303_startup(struct usb_serial *serial)
342 {
343         struct pl2303_private *priv;
344         enum pl2303_type type = type_0;
345         unsigned char *buf;
346         int i;
347
348         buf = kmalloc(10, GFP_KERNEL);
349         if (buf == NULL)
350                 return -ENOMEM;
351
352         if (serial->dev->descriptor.bDeviceClass == 0x02)
353                 type = type_0;
354         else if (serial->dev->descriptor.bMaxPacketSize0 == 0x40)
355                 type = HX;
356         else if (serial->dev->descriptor.bDeviceClass == 0x00)
357                 type = type_1;
358         else if (serial->dev->descriptor.bDeviceClass == 0xFF)
359                 type = type_1;
360         dbg("device type: %d", type);
361
362         for (i = 0; i < serial->num_ports; ++i) {
363                 priv = kzalloc(sizeof(struct pl2303_private), GFP_KERNEL);
364                 if (!priv)
365                         goto cleanup;
366                 spin_lock_init(&priv->lock);
367                 priv->buf = pl2303_buf_alloc(PL2303_BUF_SIZE);
368                 if (priv->buf == NULL) {
369                         kfree(priv);
370                         goto cleanup;
371                 }
372                 init_waitqueue_head(&priv->delta_msr_wait);
373                 priv->type = type;
374                 usb_set_serial_port_data(serial->port[i], priv);
375         }
376
377         pl2303_vendor_read(0x8484, 0, serial, buf);
378         pl2303_vendor_write(0x0404, 0, serial);
379         pl2303_vendor_read(0x8484, 0, serial, buf);
380         pl2303_vendor_read(0x8383, 0, serial, buf);
381         pl2303_vendor_read(0x8484, 0, serial, buf);
382         pl2303_vendor_write(0x0404, 1, serial);
383         pl2303_vendor_read(0x8484, 0, serial, buf);
384         pl2303_vendor_read(0x8383, 0, serial, buf);
385         pl2303_vendor_write(0, 1, serial);
386         pl2303_vendor_write(1, 0, serial);
387         if (type == HX)
388                 pl2303_vendor_write(2, 0x44, serial);
389         else
390                 pl2303_vendor_write(2, 0x24, serial);
391
392         kfree(buf);
393         return 0;
394
395 cleanup:
396         kfree(buf);
397         for (--i; i>=0; --i) {
398                 priv = usb_get_serial_port_data(serial->port[i]);
399                 pl2303_buf_free(priv->buf);
400                 kfree(priv);
401                 usb_set_serial_port_data(serial->port[i], NULL);
402         }
403         return -ENOMEM;
404 }
405
406 static int set_control_lines(struct usb_device *dev, u8 value)
407 {
408         int retval;
409         
410         retval = usb_control_msg(dev, usb_sndctrlpipe(dev, 0),
411                                  SET_CONTROL_REQUEST, SET_CONTROL_REQUEST_TYPE,
412                                  value, 0, NULL, 0, 100);
413         dbg("%s - value = %d, retval = %d", __func__, value, retval);
414         return retval;
415 }
416
417 static void pl2303_send(struct usb_serial_port *port)
418 {
419         int count, result;
420         struct pl2303_private *priv = usb_get_serial_port_data(port);
421         unsigned long flags;
422
423         dbg("%s - port %d", __func__, port->number);
424
425         spin_lock_irqsave(&priv->lock, flags);
426
427         if (priv->write_urb_in_use) {
428                 spin_unlock_irqrestore(&priv->lock, flags);
429                 return;
430         }
431
432         count = pl2303_buf_get(priv->buf, port->write_urb->transfer_buffer,
433                                port->bulk_out_size);
434
435         if (count == 0) {
436                 spin_unlock_irqrestore(&priv->lock, flags);
437                 return;
438         }
439
440         priv->write_urb_in_use = 1;
441
442         spin_unlock_irqrestore(&priv->lock, flags);
443
444         usb_serial_debug_data(debug, &port->dev, __func__, count,
445                               port->write_urb->transfer_buffer);
446
447         port->write_urb->transfer_buffer_length = count;
448         port->write_urb->dev = port->serial->dev;
449         result = usb_submit_urb(port->write_urb, GFP_ATOMIC);
450         if (result) {
451                 dev_err(&port->dev, "%s - failed submitting write urb,"
452                         " error %d\n", __func__, result);
453                 priv->write_urb_in_use = 0;
454                 // TODO: reschedule pl2303_send
455         }
456
457         usb_serial_port_softint(port);
458 }
459
460 static int pl2303_write(struct usb_serial_port *port, const unsigned char *buf,
461                         int count)
462 {
463         struct pl2303_private *priv = usb_get_serial_port_data(port);
464         unsigned long flags;
465
466         dbg("%s - port %d, %d bytes", __func__, port->number, count);
467
468         if (!count)
469                 return count;
470
471         spin_lock_irqsave(&priv->lock, flags);
472         count = pl2303_buf_put(priv->buf, buf, count);
473         spin_unlock_irqrestore(&priv->lock, flags);
474
475         pl2303_send(port);
476
477         return count;
478 }
479
480 static int pl2303_write_room(struct usb_serial_port *port)
481 {
482         struct pl2303_private *priv = usb_get_serial_port_data(port);
483         int room = 0;
484         unsigned long flags;
485
486         dbg("%s - port %d", __func__, port->number);
487
488         spin_lock_irqsave(&priv->lock, flags);
489         room = pl2303_buf_space_avail(priv->buf);
490         spin_unlock_irqrestore(&priv->lock, flags);
491
492         dbg("%s - returns %d", __func__, room);
493         return room;
494 }
495
496 static int pl2303_chars_in_buffer(struct usb_serial_port *port)
497 {
498         struct pl2303_private *priv = usb_get_serial_port_data(port);
499         int chars = 0;
500         unsigned long flags;
501
502         dbg("%s - port %d", __func__, port->number);
503
504         spin_lock_irqsave(&priv->lock, flags);
505         chars = pl2303_buf_data_avail(priv->buf);
506         spin_unlock_irqrestore(&priv->lock, flags);
507
508         dbg("%s - returns %d", __func__, chars);
509         return chars;
510 }
511
512 static void pl2303_set_termios(struct usb_serial_port *port,
513                                struct ktermios *old_termios)
514 {
515         struct usb_serial *serial = port->serial;
516         struct pl2303_private *priv = usb_get_serial_port_data(port);
517         unsigned long flags;
518         unsigned int cflag;
519         unsigned char *buf;
520         int baud;
521         int i;
522         u8 control;
523
524         dbg("%s -  port %d", __func__, port->number);
525
526         spin_lock_irqsave(&priv->lock, flags);
527         if (!priv->termios_initialized) {
528                 *(port->tty->termios) = tty_std_termios;
529                 port->tty->termios->c_cflag = B9600 | CS8 | CREAD |
530                                               HUPCL | CLOCAL;
531                 port->tty->termios->c_ispeed = 9600;
532                 port->tty->termios->c_ospeed = 9600;
533                 priv->termios_initialized = 1;
534         }
535         spin_unlock_irqrestore(&priv->lock, flags);
536
537         /* The PL2303 is reported to lose bytes if you change
538            serial settings even to the same values as before. Thus
539            we actually need to filter in this specific case */
540
541         if (!tty_termios_hw_change(port->tty->termios, old_termios))
542                 return;
543
544         cflag = port->tty->termios->c_cflag;
545
546         buf = kzalloc(7, GFP_KERNEL);
547         if (!buf) {
548                 dev_err(&port->dev, "%s - out of memory.\n", __func__);
549                 /* Report back no change occurred */
550                 *port->tty->termios = *old_termios;
551                 return;
552         }
553
554         i = usb_control_msg(serial->dev, usb_rcvctrlpipe(serial->dev, 0),
555                             GET_LINE_REQUEST, GET_LINE_REQUEST_TYPE,
556                             0, 0, buf, 7, 100);
557         dbg("0xa1:0x21:0:0  %d - %x %x %x %x %x %x %x", i,
558             buf[0], buf[1], buf[2], buf[3], buf[4], buf[5], buf[6]);
559
560         if (cflag & CSIZE) {
561                 switch (cflag & CSIZE) {
562                         case CS5:       buf[6] = 5;     break;
563                         case CS6:       buf[6] = 6;     break;
564                         case CS7:       buf[6] = 7;     break;
565                         default:
566                         case CS8:       buf[6] = 8;     break;
567                 }
568                 dbg("%s - data bits = %d", __func__, buf[6]);
569         }
570
571         baud = tty_get_baud_rate(port->tty);;
572         dbg("%s - baud = %d", __func__, baud);
573         if (baud) {
574                 buf[0] = baud & 0xff;
575                 buf[1] = (baud >> 8) & 0xff;
576                 buf[2] = (baud >> 16) & 0xff;
577                 buf[3] = (baud >> 24) & 0xff;
578         }
579
580         /* For reference buf[4]=0 is 1 stop bits */
581         /* For reference buf[4]=1 is 1.5 stop bits */
582         /* For reference buf[4]=2 is 2 stop bits */
583         if (cflag & CSTOPB) {
584                 buf[4] = 2;
585                 dbg("%s - stop bits = 2", __func__);
586         } else {
587                 buf[4] = 0;
588                 dbg("%s - stop bits = 1", __func__);
589         }
590
591         if (cflag & PARENB) {
592                 /* For reference buf[5]=0 is none parity */
593                 /* For reference buf[5]=1 is odd parity */
594                 /* For reference buf[5]=2 is even parity */
595                 /* For reference buf[5]=3 is mark parity */
596                 /* For reference buf[5]=4 is space parity */
597                 if (cflag & PARODD) {
598                         buf[5] = 1;
599                         dbg("%s - parity = odd", __func__);
600                 } else {
601                         buf[5] = 2;
602                         dbg("%s - parity = even", __func__);
603                 }
604         } else {
605                 buf[5] = 0;
606                 dbg("%s - parity = none", __func__);
607         }
608
609         i = usb_control_msg(serial->dev, usb_sndctrlpipe(serial->dev, 0),
610                             SET_LINE_REQUEST, SET_LINE_REQUEST_TYPE,
611                             0, 0, buf, 7, 100);
612         dbg("0x21:0x20:0:0  %d", i);
613
614         /* change control lines if we are switching to or from B0 */
615         spin_lock_irqsave(&priv->lock, flags);
616         control = priv->line_control;
617         if ((cflag & CBAUD) == B0)
618                 priv->line_control &= ~(CONTROL_DTR | CONTROL_RTS);
619         else
620                 priv->line_control |= (CONTROL_DTR | CONTROL_RTS);
621         if (control != priv->line_control) {
622                 control = priv->line_control;
623                 spin_unlock_irqrestore(&priv->lock, flags);
624                 set_control_lines(serial->dev, control);
625         } else {
626                 spin_unlock_irqrestore(&priv->lock, flags);
627         }
628
629         buf[0] = buf[1] = buf[2] = buf[3] = buf[4] = buf[5] = buf[6] = 0;
630
631         i = usb_control_msg(serial->dev, usb_rcvctrlpipe(serial->dev, 0),
632                             GET_LINE_REQUEST, GET_LINE_REQUEST_TYPE,
633                             0, 0, buf, 7, 100);
634         dbg("0xa1:0x21:0:0  %d - %x %x %x %x %x %x %x", i,
635              buf[0], buf[1], buf[2], buf[3], buf[4], buf[5], buf[6]);
636
637         if (cflag & CRTSCTS) {
638                 if (priv->type == HX)
639                         pl2303_vendor_write(0x0, 0x61, serial);
640                 else
641                         pl2303_vendor_write(0x0, 0x41, serial);
642         } else {
643                 pl2303_vendor_write(0x0, 0x0, serial);
644         }
645
646         /* FIXME: Need to read back resulting baud rate */
647         if (baud)
648                 tty_encode_baud_rate(port->tty, baud, baud);
649
650         kfree(buf);
651 }
652
653 static void pl2303_close(struct usb_serial_port *port, struct file *filp)
654 {
655         struct pl2303_private *priv = usb_get_serial_port_data(port);
656         unsigned long flags;
657         unsigned int c_cflag;
658         int bps;
659         long timeout;
660         wait_queue_t wait;
661
662         dbg("%s - port %d", __func__, port->number);
663
664         /* wait for data to drain from the buffer */
665         spin_lock_irqsave(&priv->lock, flags);
666         timeout = PL2303_CLOSING_WAIT;
667         init_waitqueue_entry(&wait, current);
668         add_wait_queue(&port->tty->write_wait, &wait);
669         for (;;) {
670                 set_current_state(TASK_INTERRUPTIBLE);
671                 if (pl2303_buf_data_avail(priv->buf) == 0 ||
672                     timeout == 0 || signal_pending(current) ||
673                     port->serial->disconnected)
674                         break;
675                 spin_unlock_irqrestore(&priv->lock, flags);
676                 timeout = schedule_timeout(timeout);
677                 spin_lock_irqsave(&priv->lock, flags);
678         }
679         set_current_state(TASK_RUNNING);
680         remove_wait_queue(&port->tty->write_wait, &wait);
681         /* clear out any remaining data in the buffer */
682         pl2303_buf_clear(priv->buf);
683         spin_unlock_irqrestore(&priv->lock, flags);
684
685         /* wait for characters to drain from the device */
686         /* (this is long enough for the entire 256 byte */
687         /* pl2303 hardware buffer to drain with no flow */
688         /* control for data rates of 1200 bps or more, */
689         /* for lower rates we should really know how much */
690         /* data is in the buffer to compute a delay */
691         /* that is not unnecessarily long) */
692         bps = tty_get_baud_rate(port->tty);
693         if (bps > 1200)
694                 timeout = max((HZ*2560)/bps,HZ/10);
695         else
696                 timeout = 2*HZ;
697         schedule_timeout_interruptible(timeout);
698
699         /* shutdown our urbs */
700         dbg("%s - shutting down urbs", __func__);
701         usb_kill_urb(port->write_urb);
702         usb_kill_urb(port->read_urb);
703         usb_kill_urb(port->interrupt_in_urb);
704
705         if (port->tty) {
706                 c_cflag = port->tty->termios->c_cflag;
707                 if (c_cflag & HUPCL) {
708                         /* drop DTR and RTS */
709                         spin_lock_irqsave(&priv->lock, flags);
710                         priv->line_control = 0;
711                         spin_unlock_irqrestore(&priv->lock, flags);
712                         set_control_lines(port->serial->dev, 0);
713                 }
714         }
715 }
716
717 static int pl2303_open(struct usb_serial_port *port, struct file *filp)
718 {
719         struct ktermios tmp_termios;
720         struct usb_serial *serial = port->serial;
721         struct pl2303_private *priv = usb_get_serial_port_data(port);
722         int result;
723
724         dbg("%s -  port %d", __func__, port->number);
725
726         if (priv->type != HX) {
727                 usb_clear_halt(serial->dev, port->write_urb->pipe);
728                 usb_clear_halt(serial->dev, port->read_urb->pipe);
729         } else {
730                 /* reset upstream data pipes */
731                 pl2303_vendor_write(8, 0, serial);
732                 pl2303_vendor_write(9, 0, serial);
733         }
734
735         /* Setup termios */
736         if (port->tty) {
737                 pl2303_set_termios(port, &tmp_termios);
738         }
739
740         //FIXME: need to assert RTS and DTR if CRTSCTS off
741
742         dbg("%s - submitting read urb", __func__);
743         port->read_urb->dev = serial->dev;
744         result = usb_submit_urb(port->read_urb, GFP_KERNEL);
745         if (result) {
746                 dev_err(&port->dev, "%s - failed submitting read urb,"
747                         " error %d\n", __func__, result);
748                 pl2303_close(port, NULL);
749                 return -EPROTO;
750         }
751
752         dbg("%s - submitting interrupt urb", __func__);
753         port->interrupt_in_urb->dev = serial->dev;
754         result = usb_submit_urb(port->interrupt_in_urb, GFP_KERNEL);
755         if (result) {
756                 dev_err(&port->dev, "%s - failed submitting interrupt urb,"
757                         " error %d\n", __func__, result);
758                 pl2303_close(port, NULL);
759                 return -EPROTO;
760         }
761         return 0;
762 }
763
764 static int pl2303_tiocmset(struct usb_serial_port *port, struct file *file,
765                            unsigned int set, unsigned int clear)
766 {
767         struct pl2303_private *priv = usb_get_serial_port_data(port);
768         unsigned long flags;
769         u8 control;
770
771         if (!usb_get_intfdata(port->serial->interface))
772                 return -ENODEV;
773
774         spin_lock_irqsave(&priv->lock, flags);
775         if (set & TIOCM_RTS)
776                 priv->line_control |= CONTROL_RTS;
777         if (set & TIOCM_DTR)
778                 priv->line_control |= CONTROL_DTR;
779         if (clear & TIOCM_RTS)
780                 priv->line_control &= ~CONTROL_RTS;
781         if (clear & TIOCM_DTR)
782                 priv->line_control &= ~CONTROL_DTR;
783         control = priv->line_control;
784         spin_unlock_irqrestore(&priv->lock, flags);
785
786         return set_control_lines(port->serial->dev, control);
787 }
788
789 static int pl2303_tiocmget(struct usb_serial_port *port, struct file *file)
790 {
791         struct pl2303_private *priv = usb_get_serial_port_data(port);
792         unsigned long flags;
793         unsigned int mcr;
794         unsigned int status;
795         unsigned int result;
796
797         dbg("%s (%d)", __func__, port->number);
798
799         if (!usb_get_intfdata(port->serial->interface))
800                 return -ENODEV;
801
802         spin_lock_irqsave(&priv->lock, flags);
803         mcr = priv->line_control;
804         status = priv->line_status;
805         spin_unlock_irqrestore(&priv->lock, flags);
806
807         result = ((mcr & CONTROL_DTR)           ? TIOCM_DTR : 0)
808                   | ((mcr & CONTROL_RTS)        ? TIOCM_RTS : 0)
809                   | ((status & UART_CTS)        ? TIOCM_CTS : 0)
810                   | ((status & UART_DSR)        ? TIOCM_DSR : 0)
811                   | ((status & UART_RING)       ? TIOCM_RI  : 0)
812                   | ((status & UART_DCD)        ? TIOCM_CD  : 0);
813
814         dbg("%s - result = %x", __func__, result);
815
816         return result;
817 }
818
819 static int wait_modem_info(struct usb_serial_port *port, unsigned int arg)
820 {
821         struct pl2303_private *priv = usb_get_serial_port_data(port);
822         unsigned long flags;
823         unsigned int prevstatus;
824         unsigned int status;
825         unsigned int changed;
826
827         spin_lock_irqsave(&priv->lock, flags);
828         prevstatus = priv->line_status;
829         spin_unlock_irqrestore(&priv->lock, flags);
830
831         while (1) {
832                 interruptible_sleep_on(&priv->delta_msr_wait);
833                 /* see if a signal did it */
834                 if (signal_pending(current))
835                         return -ERESTARTSYS;
836
837                 spin_lock_irqsave(&priv->lock, flags);
838                 status = priv->line_status;
839                 spin_unlock_irqrestore(&priv->lock, flags);
840
841                 changed=prevstatus^status;
842
843                 if (((arg & TIOCM_RNG) && (changed & UART_RING)) ||
844                     ((arg & TIOCM_DSR) && (changed & UART_DSR)) ||
845                     ((arg & TIOCM_CD)  && (changed & UART_DCD)) ||
846                     ((arg & TIOCM_CTS) && (changed & UART_CTS)) ) {
847                         return 0;
848                 }
849                 prevstatus = status;
850         }
851         /* NOTREACHED */
852         return 0;
853 }
854
855 static int pl2303_ioctl(struct usb_serial_port *port, struct file *file,
856                         unsigned int cmd, unsigned long arg)
857 {
858         dbg("%s (%d) cmd = 0x%04x", __func__, port->number, cmd);
859
860         switch (cmd) {
861                 case TIOCMIWAIT:
862                         dbg("%s (%d) TIOCMIWAIT", __func__,  port->number);
863                         return wait_modem_info(port, arg);
864
865                 default:
866                         dbg("%s not supported = 0x%04x", __func__, cmd);
867                         break;
868         }
869
870         return -ENOIOCTLCMD;
871 }
872
873 static void pl2303_break_ctl(struct usb_serial_port *port, int break_state)
874 {
875         struct usb_serial *serial = port->serial;
876         u16 state;
877         int result;
878
879         dbg("%s - port %d", __func__, port->number);
880
881         if (break_state == 0)
882                 state = BREAK_OFF;
883         else
884                 state = BREAK_ON;
885         dbg("%s - turning break %s", __func__, state==BREAK_OFF ? "off" : "on");
886
887         result = usb_control_msg(serial->dev, usb_sndctrlpipe(serial->dev, 0),
888                                  BREAK_REQUEST, BREAK_REQUEST_TYPE, state,
889                                  0, NULL, 0, 100);
890         if (result)
891                 dbg("%s - error sending break = %d", __func__, result);
892 }
893
894 static void pl2303_shutdown(struct usb_serial *serial)
895 {
896         int i;
897         struct pl2303_private *priv;
898
899         dbg("%s", __func__);
900
901         for (i = 0; i < serial->num_ports; ++i) {
902                 priv = usb_get_serial_port_data(serial->port[i]);
903                 if (priv) {
904                         pl2303_buf_free(priv->buf);
905                         kfree(priv);
906                         usb_set_serial_port_data(serial->port[i], NULL);
907                 }
908         }
909 }
910
911 static void pl2303_update_line_status(struct usb_serial_port *port,
912                                       unsigned char *data,
913                                       unsigned int actual_length)
914 {
915
916         struct pl2303_private *priv = usb_get_serial_port_data(port);
917         unsigned long flags;
918         u8 status_idx = UART_STATE;
919         u8 length = UART_STATE + 1;
920         u16 idv, idp;
921
922         idv = le16_to_cpu(port->serial->dev->descriptor.idVendor);
923         idp = le16_to_cpu(port->serial->dev->descriptor.idProduct);
924
925
926         if (idv == SIEMENS_VENDOR_ID) {
927                 if (idp == SIEMENS_PRODUCT_ID_X65 ||
928                     idp == SIEMENS_PRODUCT_ID_SX1 ||
929                     idp == SIEMENS_PRODUCT_ID_X75) {
930
931                         length = 1;
932                         status_idx = 0;
933                 }
934         }
935
936         if (actual_length < length)
937                 return;
938
939         /* Save off the uart status for others to look at */
940         spin_lock_irqsave(&priv->lock, flags);
941         priv->line_status = data[status_idx];
942         spin_unlock_irqrestore(&priv->lock, flags);
943         wake_up_interruptible(&priv->delta_msr_wait);
944 }
945
946 static void pl2303_read_int_callback(struct urb *urb)
947 {
948         struct usb_serial_port *port =  urb->context;
949         unsigned char *data = urb->transfer_buffer;
950         unsigned int actual_length = urb->actual_length;
951         int status = urb->status;
952         int retval;
953
954         dbg("%s (%d)", __func__, port->number);
955
956         switch (status) {
957         case 0:
958                 /* success */
959                 break;
960         case -ECONNRESET:
961         case -ENOENT:
962         case -ESHUTDOWN:
963                 /* this urb is terminated, clean up */
964                 dbg("%s - urb shutting down with status: %d", __func__,
965                     status);
966                 return;
967         default:
968                 dbg("%s - nonzero urb status received: %d", __func__,
969                     status);
970                 goto exit;
971         }
972
973         usb_serial_debug_data(debug, &port->dev, __func__,
974                               urb->actual_length, urb->transfer_buffer);
975
976         pl2303_update_line_status(port, data, actual_length);
977
978 exit:
979         retval = usb_submit_urb(urb, GFP_ATOMIC);
980         if (retval)
981                 dev_err(&urb->dev->dev,
982                         "%s - usb_submit_urb failed with result %d\n",
983                         __func__, retval);
984 }
985
986 static void pl2303_read_bulk_callback(struct urb *urb)
987 {
988         struct usb_serial_port *port =  urb->context;
989         struct pl2303_private *priv = usb_get_serial_port_data(port);
990         struct tty_struct *tty;
991         unsigned char *data = urb->transfer_buffer;
992         unsigned long flags;
993         int i;
994         int result;
995         int status = urb->status;
996         u8 line_status;
997         char tty_flag;
998
999         dbg("%s - port %d", __func__, port->number);
1000
1001         if (status) {
1002                 dbg("%s - urb status = %d", __func__, status);
1003                 if (!port->open_count) {
1004                         dbg("%s - port is closed, exiting.", __func__);
1005                         return;
1006                 }
1007                 if (status == -EPROTO) {
1008                         /* PL2303 mysteriously fails with -EPROTO reschedule
1009                          * the read */
1010                         dbg("%s - caught -EPROTO, resubmitting the urb",
1011                             __func__);
1012                         urb->dev = port->serial->dev;
1013                         result = usb_submit_urb(urb, GFP_ATOMIC);
1014                         if (result)
1015                                 dev_err(&urb->dev->dev, "%s - failed"
1016                                         " resubmitting read urb, error %d\n",
1017                                         __func__, result);
1018                         return;
1019                 }
1020                 dbg("%s - unable to handle the error, exiting.", __func__);
1021                 return;
1022         }
1023
1024         usb_serial_debug_data(debug, &port->dev, __func__,
1025                               urb->actual_length, data);
1026
1027         /* get tty_flag from status */
1028         tty_flag = TTY_NORMAL;
1029
1030         spin_lock_irqsave(&priv->lock, flags);
1031         line_status = priv->line_status;
1032         priv->line_status &= ~UART_STATE_TRANSIENT_MASK;
1033         spin_unlock_irqrestore(&priv->lock, flags);
1034         wake_up_interruptible(&priv->delta_msr_wait);
1035
1036         /* break takes precedence over parity, */
1037         /* which takes precedence over framing errors */
1038         if (line_status & UART_BREAK_ERROR )
1039                 tty_flag = TTY_BREAK;
1040         else if (line_status & UART_PARITY_ERROR)
1041                 tty_flag = TTY_PARITY;
1042         else if (line_status & UART_FRAME_ERROR)
1043                 tty_flag = TTY_FRAME;
1044         dbg("%s - tty_flag = %d", __func__, tty_flag);
1045
1046         tty = port->tty;
1047         if (tty && urb->actual_length) {
1048                 tty_buffer_request_room(tty, urb->actual_length + 1);
1049                 /* overrun is special, not associated with a char */
1050                 if (line_status & UART_OVERRUN_ERROR)
1051                         tty_insert_flip_char(tty, 0, TTY_OVERRUN);
1052                 for (i = 0; i < urb->actual_length; ++i)
1053                         tty_insert_flip_char(tty, data[i], tty_flag);
1054                 tty_flip_buffer_push(tty);
1055         }
1056
1057         /* Schedule the next read _if_ we are still open */
1058         if (port->open_count) {
1059                 urb->dev = port->serial->dev;
1060                 result = usb_submit_urb(urb, GFP_ATOMIC);
1061                 if (result)
1062                         dev_err(&urb->dev->dev, "%s - failed resubmitting"
1063                                 " read urb, error %d\n", __func__, result);
1064         }
1065
1066         return;
1067 }
1068
1069 static void pl2303_write_bulk_callback(struct urb *urb)
1070 {
1071         struct usb_serial_port *port =  urb->context;
1072         struct pl2303_private *priv = usb_get_serial_port_data(port);
1073         int result;
1074         int status = urb->status;
1075
1076         dbg("%s - port %d", __func__, port->number);
1077
1078         switch (status) {
1079         case 0:
1080                 /* success */
1081                 break;
1082         case -ECONNRESET:
1083         case -ENOENT:
1084         case -ESHUTDOWN:
1085                 /* this urb is terminated, clean up */
1086                 dbg("%s - urb shutting down with status: %d", __func__,
1087                     status);
1088                 priv->write_urb_in_use = 0;
1089                 return;
1090         default:
1091                 /* error in the urb, so we have to resubmit it */
1092                 dbg("%s - Overflow in write", __func__);
1093                 dbg("%s - nonzero write bulk status received: %d", __func__,
1094                     status);
1095                 port->write_urb->transfer_buffer_length = 1;
1096                 port->write_urb->dev = port->serial->dev;
1097                 result = usb_submit_urb(port->write_urb, GFP_ATOMIC);
1098                 if (result)
1099                         dev_err(&urb->dev->dev, "%s - failed resubmitting write"
1100                                 " urb, error %d\n", __func__, result);
1101                 else
1102                         return;
1103         }
1104
1105         priv->write_urb_in_use = 0;
1106
1107         /* send any buffered data */
1108         pl2303_send(port);
1109 }
1110
1111 /* All of the device info needed for the PL2303 SIO serial converter */
1112 static struct usb_serial_driver pl2303_device = {
1113         .driver = {
1114                 .owner =        THIS_MODULE,
1115                 .name =         "pl2303",
1116         },
1117         .id_table =             id_table,
1118         .usb_driver =           &pl2303_driver,
1119         .num_ports =            1,
1120         .open =                 pl2303_open,
1121         .close =                pl2303_close,
1122         .write =                pl2303_write,
1123         .ioctl =                pl2303_ioctl,
1124         .break_ctl =            pl2303_break_ctl,
1125         .set_termios =          pl2303_set_termios,
1126         .tiocmget =             pl2303_tiocmget,
1127         .tiocmset =             pl2303_tiocmset,
1128         .read_bulk_callback =   pl2303_read_bulk_callback,
1129         .read_int_callback =    pl2303_read_int_callback,
1130         .write_bulk_callback =  pl2303_write_bulk_callback,
1131         .write_room =           pl2303_write_room,
1132         .chars_in_buffer =      pl2303_chars_in_buffer,
1133         .attach =               pl2303_startup,
1134         .shutdown =             pl2303_shutdown,
1135 };
1136
1137 static int __init pl2303_init(void)
1138 {
1139         int retval;
1140
1141         retval = usb_serial_register(&pl2303_device);
1142         if (retval)
1143                 goto failed_usb_serial_register;
1144         retval = usb_register(&pl2303_driver);
1145         if (retval)
1146                 goto failed_usb_register;
1147         info(DRIVER_DESC);
1148         return 0;
1149 failed_usb_register:
1150         usb_serial_deregister(&pl2303_device);
1151 failed_usb_serial_register:
1152         return retval;
1153 }
1154
1155 static void __exit pl2303_exit(void)
1156 {
1157         usb_deregister(&pl2303_driver);
1158         usb_serial_deregister(&pl2303_device);
1159 }
1160
1161 module_init(pl2303_init);
1162 module_exit(pl2303_exit);
1163
1164 MODULE_DESCRIPTION(DRIVER_DESC);
1165 MODULE_LICENSE("GPL");
1166
1167 module_param(debug, bool, S_IRUGO | S_IWUSR);
1168 MODULE_PARM_DESC(debug, "Debug enabled or not");
1169