Commit 86c80a8e authored by Peter Hurley's avatar Peter Hurley Committed by Greg Kroah-Hartman

tty: Flush ldisc buffer atomically with tty flip buffers

tty_ldisc_flush() first clears the line discipline input buffer,
then clears the tty flip buffers. However, this allows for existing
data in the tty flip buffers to be added after the ldisc input
buffer has been cleared, but before the flip buffers have been cleared.

Add an optional ldisc parameter to tty_buffer_flush() to allow
tty_ldisc_flush() to pass the ldisc to clear.

NB: Initially, the plan was to do this automatically in
tty_buffer_flush(). However, an audit of the behavior of existing
line disciplines showed that performing a ldisc buffer flush on
ioctl(TCFLSH) was not always the outcome. For example, some line
disciplines have flush_buffer() methods but not ioctl() methods,
so a ->flush_buffer() command would be unexpected.
Reviewed-by: default avatarAlan Cox <alan@linux.intel.com>
Signed-off-by: default avatarPeter Hurley <peter@hurleysoftware.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 276a661a
...@@ -202,14 +202,16 @@ static void tty_buffer_free(struct tty_port *port, struct tty_buffer *b) ...@@ -202,14 +202,16 @@ static void tty_buffer_free(struct tty_port *port, struct tty_buffer *b)
/** /**
* tty_buffer_flush - flush full tty buffers * tty_buffer_flush - flush full tty buffers
* @tty: tty to flush * @tty: tty to flush
* @ld: optional ldisc ptr (must be referenced)
* *
* flush all the buffers containing receive data. * flush all the buffers containing receive data. If ld != NULL,
* flush the ldisc input buffer.
* *
* Locking: takes buffer lock to ensure single-threaded flip buffer * Locking: takes buffer lock to ensure single-threaded flip buffer
* 'consumer' * 'consumer'
*/ */
void tty_buffer_flush(struct tty_struct *tty) void tty_buffer_flush(struct tty_struct *tty, struct tty_ldisc *ld)
{ {
struct tty_port *port = tty->port; struct tty_port *port = tty->port;
struct tty_bufhead *buf = &port->buf; struct tty_bufhead *buf = &port->buf;
...@@ -223,6 +225,10 @@ void tty_buffer_flush(struct tty_struct *tty) ...@@ -223,6 +225,10 @@ void tty_buffer_flush(struct tty_struct *tty)
buf->head = next; buf->head = next;
} }
buf->head->read = buf->head->commit; buf->head->read = buf->head->commit;
if (ld && ld->ops->flush_buffer)
ld->ops->flush_buffer(tty);
atomic_dec(&buf->priority); atomic_dec(&buf->priority);
mutex_unlock(&buf->lock); mutex_unlock(&buf->lock);
} }
......
...@@ -2890,7 +2890,7 @@ long tty_ioctl(struct file *file, unsigned int cmd, unsigned long arg) ...@@ -2890,7 +2890,7 @@ long tty_ioctl(struct file *file, unsigned int cmd, unsigned long arg)
case TCIFLUSH: case TCIFLUSH:
case TCIOFLUSH: case TCIOFLUSH:
/* flush tty buffer and allow ldisc to process ioctl */ /* flush tty buffer and allow ldisc to process ioctl */
tty_buffer_flush(tty); tty_buffer_flush(tty, NULL);
break; break;
} }
break; break;
......
...@@ -397,19 +397,17 @@ static void __lockfunc tty_ldisc_unlock_pair(struct tty_struct *tty, ...@@ -397,19 +397,17 @@ static void __lockfunc tty_ldisc_unlock_pair(struct tty_struct *tty,
* tty_ldisc_flush - flush line discipline queue * tty_ldisc_flush - flush line discipline queue
* @tty: tty * @tty: tty
* *
* Flush the line discipline queue (if any) for this tty. If there * Flush the line discipline queue (if any) and the tty flip buffers
* is no line discipline active this is a no-op. * for this tty.
*/ */
void tty_ldisc_flush(struct tty_struct *tty) void tty_ldisc_flush(struct tty_struct *tty)
{ {
struct tty_ldisc *ld = tty_ldisc_ref(tty); struct tty_ldisc *ld = tty_ldisc_ref(tty);
if (ld) {
if (ld->ops->flush_buffer) tty_buffer_flush(tty, ld);
ld->ops->flush_buffer(tty); if (ld)
tty_ldisc_deref(ld); tty_ldisc_deref(ld);
}
tty_buffer_flush(tty);
} }
EXPORT_SYMBOL_GPL(tty_ldisc_flush); EXPORT_SYMBOL_GPL(tty_ldisc_flush);
......
...@@ -441,7 +441,7 @@ extern void __do_SAK(struct tty_struct *tty); ...@@ -441,7 +441,7 @@ extern void __do_SAK(struct tty_struct *tty);
extern void no_tty(void); extern void no_tty(void);
extern void tty_flush_to_ldisc(struct tty_struct *tty); extern void tty_flush_to_ldisc(struct tty_struct *tty);
extern void tty_buffer_free_all(struct tty_port *port); extern void tty_buffer_free_all(struct tty_port *port);
extern void tty_buffer_flush(struct tty_struct *tty); extern void tty_buffer_flush(struct tty_struct *tty, struct tty_ldisc *ld);
extern void tty_buffer_init(struct tty_port *port); extern void tty_buffer_init(struct tty_port *port);
extern speed_t tty_termios_baud_rate(struct ktermios *termios); extern speed_t tty_termios_baud_rate(struct ktermios *termios);
extern speed_t tty_termios_input_baud_rate(struct ktermios *termios); extern speed_t tty_termios_input_baud_rate(struct ktermios *termios);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment