Skip to content

Commit

Permalink
USB: ti_usb_3410_5052: move write-fifo flushing to close
Browse files Browse the repository at this point in the history
Move write-fifo flushing from ti_drain to close where it belongs.

Signed-off-by: Johan Hovold <jhovold@gmail.com>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
  • Loading branch information
Johan Hovold authored and Greg Kroah-Hartman committed Apr 19, 2013
1 parent a8ec374 commit 113ec31
Showing 1 changed file with 8 additions and 9 deletions.
17 changes: 8 additions & 9 deletions drivers/usb/serial/ti_usb_3410_5052.c
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ static int ti_set_serial_info(struct tty_struct *tty, struct ti_port *tport,
struct serial_struct __user *new_arg);
static void ti_handle_new_msr(struct ti_port *tport, __u8 msr);

static void ti_drain(struct ti_port *tport, unsigned long timeout, int flush);
static void ti_drain(struct ti_port *tport, unsigned long timeout);

static void ti_stop_read(struct ti_port *tport, struct tty_struct *tty);
static int ti_restart_read(struct ti_port *tport, struct tty_struct *tty);
Expand Down Expand Up @@ -601,6 +601,7 @@ static void ti_close(struct usb_serial_port *port)
int port_number;
int status;
int do_unlock;
unsigned long flags;

tdev = usb_get_serial_data(port->serial);
tport = usb_get_serial_port_data(port);
Expand All @@ -609,11 +610,14 @@ static void ti_close(struct usb_serial_port *port)

tport->tp_is_open = 0;

ti_drain(tport, (tport->tp_closing_wait*HZ)/100, 1);
ti_drain(tport, (tport->tp_closing_wait*HZ)/100);

usb_kill_urb(port->read_urb);
usb_kill_urb(port->write_urb);
tport->tp_write_urb_in_use = 0;
spin_lock_irqsave(&tport->tp_lock, flags);
kfifo_reset_out(&tport->write_fifo);
spin_unlock_irqrestore(&tport->tp_lock, flags);

port_number = port->number - port->serial->minor;

Expand Down Expand Up @@ -965,7 +969,7 @@ static void ti_break(struct tty_struct *tty, int break_state)
if (tport == NULL)
return;

ti_drain(tport, (tport->tp_closing_wait*HZ)/100, 0);
ti_drain(tport, (tport->tp_closing_wait*HZ)/100);

status = ti_write_byte(port, tport->tp_tdev,
tport->tp_uart_base_addr + TI_UART_OFFSET_LCR,
Expand Down Expand Up @@ -1361,7 +1365,7 @@ static void ti_handle_new_msr(struct ti_port *tport, __u8 msr)
}


static void ti_drain(struct ti_port *tport, unsigned long timeout, int flush)
static void ti_drain(struct ti_port *tport, unsigned long timeout)
{
struct ti_device *tdev = tport->tp_tdev;
struct usb_serial_port *port = tport->tp_port;
Expand All @@ -1386,11 +1390,6 @@ static void ti_drain(struct ti_port *tport, unsigned long timeout, int flush)
}
set_current_state(TASK_RUNNING);
remove_wait_queue(&tport->tp_write_wait, &wait);

/* flush any remaining data in the buffer */
if (flush)
kfifo_reset_out(&tport->write_fifo);

spin_unlock_irq(&tport->tp_lock);

mutex_lock(&port->serial->disc_mutex);
Expand Down

0 comments on commit 113ec31

Please sign in to comment.