Merge branch 'fixes' of git://git.kernel.org/pub/scm/linux/kernel/git/djbw/async_tx
[linux-2.6] / drivers / char / tty_port.c
1 /*
2  * Tty port functions
3  */
4
5 #include <linux/types.h>
6 #include <linux/errno.h>
7 #include <linux/tty.h>
8 #include <linux/tty_driver.h>
9 #include <linux/tty_flip.h>
10 #include <linux/serial.h>
11 #include <linux/timer.h>
12 #include <linux/string.h>
13 #include <linux/slab.h>
14 #include <linux/sched.h>
15 #include <linux/init.h>
16 #include <linux/wait.h>
17 #include <linux/bitops.h>
18 #include <linux/delay.h>
19 #include <linux/module.h>
20
21 void tty_port_init(struct tty_port *port)
22 {
23         memset(port, 0, sizeof(*port));
24         init_waitqueue_head(&port->open_wait);
25         init_waitqueue_head(&port->close_wait);
26         mutex_init(&port->mutex);
27         spin_lock_init(&port->lock);
28         port->close_delay = (50 * HZ) / 100;
29         port->closing_wait = (3000 * HZ) / 100;
30 }
31 EXPORT_SYMBOL(tty_port_init);
32
33 int tty_port_alloc_xmit_buf(struct tty_port *port)
34 {
35         /* We may sleep in get_zeroed_page() */
36         mutex_lock(&port->mutex);
37         if (port->xmit_buf == NULL)
38                 port->xmit_buf = (unsigned char *)get_zeroed_page(GFP_KERNEL);
39         mutex_unlock(&port->mutex);
40         if (port->xmit_buf == NULL)
41                 return -ENOMEM;
42         return 0;
43 }
44 EXPORT_SYMBOL(tty_port_alloc_xmit_buf);
45
46 void tty_port_free_xmit_buf(struct tty_port *port)
47 {
48         mutex_lock(&port->mutex);
49         if (port->xmit_buf != NULL) {
50                 free_page((unsigned long)port->xmit_buf);
51                 port->xmit_buf = NULL;
52         }
53         mutex_unlock(&port->mutex);
54 }
55 EXPORT_SYMBOL(tty_port_free_xmit_buf);
56
57
58 /**
59  *      tty_port_tty_get        -       get a tty reference
60  *      @port: tty port
61  *
62  *      Return a refcount protected tty instance or NULL if the port is not
63  *      associated with a tty (eg due to close or hangup)
64  */
65
66 struct tty_struct *tty_port_tty_get(struct tty_port *port)
67 {
68         unsigned long flags;
69         struct tty_struct *tty;
70
71         spin_lock_irqsave(&port->lock, flags);
72         tty = tty_kref_get(port->tty);
73         spin_unlock_irqrestore(&port->lock, flags);
74         return tty;
75 }
76 EXPORT_SYMBOL(tty_port_tty_get);
77
78 /**
79  *      tty_port_tty_set        -       set the tty of a port
80  *      @port: tty port
81  *      @tty: the tty
82  *
83  *      Associate the port and tty pair. Manages any internal refcounts.
84  *      Pass NULL to deassociate a port
85  */
86
87 void tty_port_tty_set(struct tty_port *port, struct tty_struct *tty)
88 {
89         unsigned long flags;
90
91         spin_lock_irqsave(&port->lock, flags);
92         if (port->tty)
93                 tty_kref_put(port->tty);
94         port->tty = tty_kref_get(tty);
95         spin_unlock_irqrestore(&port->lock, flags);
96 }
97 EXPORT_SYMBOL(tty_port_tty_set);
98
99 /**
100  *      tty_port_hangup         -       hangup helper
101  *      @port: tty port
102  *
103  *      Perform port level tty hangup flag and count changes. Drop the tty
104  *      reference.
105  */
106
107 void tty_port_hangup(struct tty_port *port)
108 {
109         unsigned long flags;
110
111         spin_lock_irqsave(&port->lock, flags);
112         port->count = 0;
113         port->flags &= ~ASYNC_NORMAL_ACTIVE;
114         if (port->tty)
115                 tty_kref_put(port->tty);
116         port->tty = NULL;
117         spin_unlock_irqrestore(&port->lock, flags);
118         wake_up_interruptible(&port->open_wait);
119 }
120 EXPORT_SYMBOL(tty_port_hangup);
121
122 /**
123  *      tty_port_carrier_raised -       carrier raised check
124  *      @port: tty port
125  *
126  *      Wrapper for the carrier detect logic. For the moment this is used
127  *      to hide some internal details. This will eventually become entirely
128  *      internal to the tty port.
129  */
130
131 int tty_port_carrier_raised(struct tty_port *port)
132 {
133         if (port->ops->carrier_raised == NULL)
134                 return 1;
135         return port->ops->carrier_raised(port);
136 }
137 EXPORT_SYMBOL(tty_port_carrier_raised);
138
139 /**
140  *      tty_port_raise_dtr_rts  -       Riase DTR/RTS
141  *      @port: tty port
142  *
143  *      Wrapper for the DTR/RTS raise logic. For the moment this is used
144  *      to hide some internal details. This will eventually become entirely
145  *      internal to the tty port.
146  */
147
148 void tty_port_raise_dtr_rts(struct tty_port *port)
149 {
150         if (port->ops->raise_dtr_rts)
151                 port->ops->raise_dtr_rts(port);
152 }
153 EXPORT_SYMBOL(tty_port_raise_dtr_rts);
154
155 /**
156  *      tty_port_block_til_ready        -       Waiting logic for tty open
157  *      @port: the tty port being opened
158  *      @tty: the tty device being bound
159  *      @filp: the file pointer of the opener
160  *
161  *      Implement the core POSIX/SuS tty behaviour when opening a tty device.
162  *      Handles:
163  *              - hangup (both before and during)
164  *              - non blocking open
165  *              - rts/dtr/dcd
166  *              - signals
167  *              - port flags and counts
168  *
169  *      The passed tty_port must implement the carrier_raised method if it can
170  *      do carrier detect and the raise_dtr_rts method if it supports software
171  *      management of these lines. Note that the dtr/rts raise is done each
172  *      iteration as a hangup may have previously dropped them while we wait.
173  */
174  
175 int tty_port_block_til_ready(struct tty_port *port,
176                                 struct tty_struct *tty, struct file *filp)
177 {
178         int do_clocal = 0, retval;
179         unsigned long flags;
180         DECLARE_WAITQUEUE(wait, current);
181         int cd;
182
183         /* block if port is in the process of being closed */
184         if (tty_hung_up_p(filp) || port->flags & ASYNC_CLOSING) {
185                 interruptible_sleep_on(&port->close_wait);
186                 if (port->flags & ASYNC_HUP_NOTIFY)
187                         return -EAGAIN;
188                 else
189                         return -ERESTARTSYS;
190         }
191
192         /* if non-blocking mode is set we can pass directly to open unless
193            the port has just hung up or is in another error state */
194         if ((filp->f_flags & O_NONBLOCK) ||
195                         (tty->flags & (1 << TTY_IO_ERROR))) {
196                 port->flags |= ASYNC_NORMAL_ACTIVE;
197                 return 0;
198         }
199
200         if (C_CLOCAL(tty))
201                 do_clocal = 1;
202
203         /* Block waiting until we can proceed. We may need to wait for the
204            carrier, but we must also wait for any close that is in progress
205            before the next open may complete */
206
207         retval = 0;
208         add_wait_queue(&port->open_wait, &wait);
209
210         /* The port lock protects the port counts */
211         spin_lock_irqsave(&port->lock, flags);
212         if (!tty_hung_up_p(filp))
213                 port->count--;
214         port->blocked_open++;
215         spin_unlock_irqrestore(&port->lock, flags);
216
217         while (1) {
218                 /* Indicate we are open */
219                 if (tty->termios->c_cflag & CBAUD)
220                         tty_port_raise_dtr_rts(port);
221
222                 set_current_state(TASK_INTERRUPTIBLE);
223                 /* Check for a hangup or uninitialised port. Return accordingly */
224                 if (tty_hung_up_p(filp) || !(port->flags & ASYNC_INITIALIZED)) {
225                         if (port->flags & ASYNC_HUP_NOTIFY)
226                                 retval = -EAGAIN;
227                         else
228                                 retval = -ERESTARTSYS;
229                         break;
230                 }
231                 /* Probe the carrier. For devices with no carrier detect this
232                    will always return true */
233                 cd = tty_port_carrier_raised(port);
234                 if (!(port->flags & ASYNC_CLOSING) &&
235                                 (do_clocal || cd))
236                         break;
237                 if (signal_pending(current)) {
238                         retval = -ERESTARTSYS;
239                         break;
240                 }
241                 schedule();
242         }
243         set_current_state(TASK_RUNNING);
244         remove_wait_queue(&port->open_wait, &wait);
245
246         /* Update counts. A parallel hangup will have set count to zero and
247            we must not mess that up further */
248         spin_lock_irqsave(&port->lock, flags);
249         if (!tty_hung_up_p(filp))
250                 port->count++;
251         port->blocked_open--;
252         if (retval == 0)
253                 port->flags |= ASYNC_NORMAL_ACTIVE;
254         spin_unlock_irqrestore(&port->lock, flags);
255         return 0;
256         
257 }
258 EXPORT_SYMBOL(tty_port_block_til_ready);
259
260 int tty_port_close_start(struct tty_port *port, struct tty_struct *tty, struct file *filp)
261 {
262         unsigned long flags;
263
264         spin_lock_irqsave(&port->lock, flags);
265         if (tty_hung_up_p(filp)) {
266                 spin_unlock_irqrestore(&port->lock, flags);
267                 return 0;
268         }
269
270         if( tty->count == 1 && port->count != 1) {
271                 printk(KERN_WARNING
272                     "tty_port_close_start: tty->count = 1 port count = %d.\n",
273                                                                 port->count);
274                 port->count = 1;
275         }
276         if (--port->count < 0) {
277                 printk(KERN_WARNING "tty_port_close_start: count = %d\n",
278                                                                 port->count);
279                 port->count = 0;
280         }
281
282         if (port->count) {
283                 spin_unlock_irqrestore(&port->lock, flags);
284                 return 0;
285         }
286         port->flags |= ASYNC_CLOSING;
287         tty->closing = 1;
288         spin_unlock_irqrestore(&port->lock, flags);
289         /* Don't block on a stalled port, just pull the chain */
290         if (tty->flow_stopped)
291                 tty_driver_flush_buffer(tty);
292         if (port->flags & ASYNC_INITIALIZED &&
293                         port->closing_wait != ASYNC_CLOSING_WAIT_NONE)
294                 tty_wait_until_sent(tty, port->closing_wait);
295         return 1;
296 }
297 EXPORT_SYMBOL(tty_port_close_start);
298
299 void tty_port_close_end(struct tty_port *port, struct tty_struct *tty)
300 {
301         unsigned long flags;
302
303         tty_ldisc_flush(tty);
304
305         spin_lock_irqsave(&port->lock, flags);
306         tty->closing = 0;
307
308         if (port->blocked_open) {
309                 spin_unlock_irqrestore(&port->lock, flags);
310                 if (port->close_delay) {
311                         msleep_interruptible(
312                                 jiffies_to_msecs(port->close_delay));
313                 }
314                 spin_lock_irqsave(&port->lock, flags);
315                 wake_up_interruptible(&port->open_wait);
316         }
317         port->flags &= ~(ASYNC_NORMAL_ACTIVE | ASYNC_CLOSING);
318         wake_up_interruptible(&port->close_wait);
319         spin_unlock_irqrestore(&port->lock, flags);
320 }
321 EXPORT_SYMBOL(tty_port_close_end);