Commit d0d4e1c0 authored by Jiri Slaby's avatar Jiri Slaby Committed by Linus Torvalds

Char: specialix, remove bottomhalves

- tqueue is used only for tty_wakeup, call it directly from the code
- tqueue_hangup for tty_hangup, it schedules its own work, use it directly
  too
Signed-off-by: default avatarJiri Slaby <jirislaby@gmail.com>
Acked-by: default avatarAlan Cox <alan@redhat.com>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent cfccaeea
...@@ -178,9 +178,6 @@ static int sx_poll = HZ; ...@@ -178,9 +178,6 @@ static int sx_poll = HZ;
ASYNC_SPD_HI | ASYNC_SPEED_VHI | ASYNC_SESSION_LOCKOUT | \ ASYNC_SPD_HI | ASYNC_SPEED_VHI | ASYNC_SESSION_LOCKOUT | \
ASYNC_PGRP_LOCKOUT | ASYNC_CALLOUT_NOHUP) ASYNC_PGRP_LOCKOUT | ASYNC_CALLOUT_NOHUP)
#undef RS_EVENT_WRITE_WAKEUP
#define RS_EVENT_WRITE_WAKEUP 0
static struct tty_driver *specialix_driver; static struct tty_driver *specialix_driver;
static struct specialix_board sx_board[SX_NBOARD] = { static struct specialix_board sx_board[SX_NBOARD] = {
...@@ -602,17 +599,6 @@ static int sx_probe(struct specialix_board *bp) ...@@ -602,17 +599,6 @@ static int sx_probe(struct specialix_board *bp)
* Interrupt processing routines. * Interrupt processing routines.
* */ * */
static inline void sx_mark_event(struct specialix_port * port, int event)
{
func_enter();
set_bit(event, &port->event);
schedule_work(&port->tqueue);
func_exit();
}
static inline struct specialix_port * sx_get_port(struct specialix_board * bp, static inline struct specialix_port * sx_get_port(struct specialix_board * bp,
unsigned char const * what) unsigned char const * what)
{ {
...@@ -809,7 +795,7 @@ static inline void sx_transmit(struct specialix_board * bp) ...@@ -809,7 +795,7 @@ static inline void sx_transmit(struct specialix_board * bp)
sx_out(bp, CD186x_IER, port->IER); sx_out(bp, CD186x_IER, port->IER);
} }
if (port->xmit_cnt <= port->wakeup_chars) if (port->xmit_cnt <= port->wakeup_chars)
sx_mark_event(port, RS_EVENT_WRITE_WAKEUP); tty_wakeup(tty);
func_exit(); func_exit();
} }
...@@ -839,7 +825,7 @@ static inline void sx_check_modem(struct specialix_board * bp) ...@@ -839,7 +825,7 @@ static inline void sx_check_modem(struct specialix_board * bp)
wake_up_interruptible(&port->open_wait); wake_up_interruptible(&port->open_wait);
} else { } else {
dprintk (SX_DEBUG_SIGNALS, "Sending HUP.\n"); dprintk (SX_DEBUG_SIGNALS, "Sending HUP.\n");
schedule_work(&port->tqueue_hangup); tty_hangup(tty);
} }
} }
...@@ -849,7 +835,7 @@ static inline void sx_check_modem(struct specialix_board * bp) ...@@ -849,7 +835,7 @@ static inline void sx_check_modem(struct specialix_board * bp)
tty->hw_stopped = 0; tty->hw_stopped = 0;
port->IER |= IER_TXRDY; port->IER |= IER_TXRDY;
if (port->xmit_cnt <= port->wakeup_chars) if (port->xmit_cnt <= port->wakeup_chars)
sx_mark_event(port, RS_EVENT_WRITE_WAKEUP); tty_wakeup(tty);
} else { } else {
tty->hw_stopped = 1; tty->hw_stopped = 1;
port->IER &= ~IER_TXRDY; port->IER &= ~IER_TXRDY;
...@@ -861,7 +847,7 @@ static inline void sx_check_modem(struct specialix_board * bp) ...@@ -861,7 +847,7 @@ static inline void sx_check_modem(struct specialix_board * bp)
tty->hw_stopped = 0; tty->hw_stopped = 0;
port->IER |= IER_TXRDY; port->IER |= IER_TXRDY;
if (port->xmit_cnt <= port->wakeup_chars) if (port->xmit_cnt <= port->wakeup_chars)
sx_mark_event(port, RS_EVENT_WRITE_WAKEUP); tty_wakeup(tty);
} else { } else {
tty->hw_stopped = 1; tty->hw_stopped = 1;
port->IER &= ~IER_TXRDY; port->IER &= ~IER_TXRDY;
...@@ -1618,7 +1604,6 @@ static void sx_close(struct tty_struct * tty, struct file * filp) ...@@ -1618,7 +1604,6 @@ static void sx_close(struct tty_struct * tty, struct file * filp)
tty_ldisc_flush(tty); tty_ldisc_flush(tty);
spin_lock_irqsave(&port->lock, flags); spin_lock_irqsave(&port->lock, flags);
tty->closing = 0; tty->closing = 0;
port->event = 0;
port->tty = NULL; port->tty = NULL;
spin_unlock_irqrestore(&port->lock, flags); spin_unlock_irqrestore(&port->lock, flags);
if (port->blocked_open) { if (port->blocked_open) {
...@@ -2235,32 +2220,6 @@ static void sx_start(struct tty_struct * tty) ...@@ -2235,32 +2220,6 @@ static void sx_start(struct tty_struct * tty)
func_exit(); func_exit();
} }
/*
* This routine is called from the work-queue when the interrupt
* routine has signalled that a hangup has occurred. The path of
* hangup processing is:
*
* serial interrupt routine -> (workqueue) ->
* do_sx_hangup() -> tty->hangup() -> sx_hangup()
*
*/
static void do_sx_hangup(struct work_struct *work)
{
struct specialix_port *port =
container_of(work, struct specialix_port, tqueue_hangup);
struct tty_struct *tty;
func_enter();
tty = port->tty;
if (tty)
tty_hangup(tty); /* FIXME: module removal race here */
func_exit();
}
static void sx_hangup(struct tty_struct * tty) static void sx_hangup(struct tty_struct * tty)
{ {
struct specialix_port *port = (struct specialix_port *)tty->driver_data; struct specialix_port *port = (struct specialix_port *)tty->driver_data;
...@@ -2278,7 +2237,6 @@ static void sx_hangup(struct tty_struct * tty) ...@@ -2278,7 +2237,6 @@ static void sx_hangup(struct tty_struct * tty)
sx_shutdown_port(bp, port); sx_shutdown_port(bp, port);
spin_lock_irqsave(&port->lock, flags); spin_lock_irqsave(&port->lock, flags);
port->event = 0;
bp->count -= port->count; bp->count -= port->count;
if (bp->count < 0) { if (bp->count < 0) {
printk(KERN_ERR "sx%d: sx_hangup: bad board count: %d port: %d\n", printk(KERN_ERR "sx%d: sx_hangup: bad board count: %d port: %d\n",
...@@ -2320,26 +2278,6 @@ static void sx_set_termios(struct tty_struct * tty, struct ktermios * old_termio ...@@ -2320,26 +2278,6 @@ static void sx_set_termios(struct tty_struct * tty, struct ktermios * old_termio
} }
} }
static void do_softint(struct work_struct *work)
{
struct specialix_port *port =
container_of(work, struct specialix_port, tqueue);
struct tty_struct *tty;
func_enter();
if(!(tty = port->tty)) {
func_exit();
return;
}
if (test_and_clear_bit(RS_EVENT_WRITE_WAKEUP, &port->event))
tty_wakeup(tty);
func_exit();
}
static const struct tty_operations sx_ops = { static const struct tty_operations sx_ops = {
.open = sx_open, .open = sx_open,
.close = sx_close, .close = sx_close,
...@@ -2397,8 +2335,6 @@ static int sx_init_drivers(void) ...@@ -2397,8 +2335,6 @@ static int sx_init_drivers(void)
memset(sx_port, 0, sizeof(sx_port)); memset(sx_port, 0, sizeof(sx_port));
for (i = 0; i < SX_NPORT * SX_NBOARD; i++) { for (i = 0; i < SX_NPORT * SX_NBOARD; i++) {
sx_port[i].magic = SPECIALIX_MAGIC; sx_port[i].magic = SPECIALIX_MAGIC;
INIT_WORK(&sx_port[i].tqueue, do_softint);
INIT_WORK(&sx_port[i].tqueue_hangup, do_sx_hangup);
sx_port[i].close_delay = 50 * HZ/100; sx_port[i].close_delay = 50 * HZ/100;
sx_port[i].closing_wait = 3000 * HZ/100; sx_port[i].closing_wait = 3000 * HZ/100;
init_waitqueue_head(&sx_port[i].open_wait); init_waitqueue_head(&sx_port[i].open_wait);
......
...@@ -112,7 +112,6 @@ struct specialix_port { ...@@ -112,7 +112,6 @@ struct specialix_port {
struct tty_struct * tty; struct tty_struct * tty;
int count; int count;
int blocked_open; int blocked_open;
ulong event;
int timeout; int timeout;
int close_delay; int close_delay;
unsigned char * xmit_buf; unsigned char * xmit_buf;
...@@ -122,8 +121,6 @@ struct specialix_port { ...@@ -122,8 +121,6 @@ struct specialix_port {
int xmit_cnt; int xmit_cnt;
wait_queue_head_t open_wait; wait_queue_head_t open_wait;
wait_queue_head_t close_wait; wait_queue_head_t close_wait;
struct work_struct tqueue;
struct work_struct tqueue_hangup;
short wakeup_chars; short wakeup_chars;
short break_length; short break_length;
unsigned short closing_wait; unsigned short closing_wait;
......
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