Commit d8c215ad authored by Al Viro's avatar Al Viro Committed by Richard Weinberger

um: convert count_lock to mutex, fix a race in line_open()

If two processes are opening the same line, the second to get
into line_open() will decide that it doesn't need to do anything
(correctly) or wait for anything.  The latter, unfortunately,
is incorrect - the first opener might not be through yet.  We
need to have exclusion covering the entire line_init(), including
the blocking parts.  Moreover, the next patch will need to
widen the exclusion on mconsole side of things, also including
the blocking bits, so let's just convert that sucker to mutex...
Signed-off-by: default avatarAl Viro <viro@zeniv.linux.org.uk>
Signed-off-by: default avatarRichard Weinberger <richard@nod.at>
parent 43574c1a
...@@ -409,7 +409,7 @@ int line_open(struct line *lines, struct tty_struct *tty) ...@@ -409,7 +409,7 @@ int line_open(struct line *lines, struct tty_struct *tty)
struct line *line = &lines[tty->index]; struct line *line = &lines[tty->index];
int err = -ENODEV; int err = -ENODEV;
spin_lock(&line->count_lock); mutex_lock(&line->count_lock);
if (!line->valid) if (!line->valid)
goto out_unlock; goto out_unlock;
...@@ -421,10 +421,9 @@ int line_open(struct line *lines, struct tty_struct *tty) ...@@ -421,10 +421,9 @@ int line_open(struct line *lines, struct tty_struct *tty)
tty->driver_data = line; tty->driver_data = line;
line->tty = tty; line->tty = tty;
spin_unlock(&line->count_lock);
err = enable_chan(line); err = enable_chan(line);
if (err) /* line_close() will be called by our caller */ if (err) /* line_close() will be called by our caller */
return err; goto out_unlock;
INIT_DELAYED_WORK(&line->task, line_timer_cb); INIT_DELAYED_WORK(&line->task, line_timer_cb);
...@@ -435,11 +434,8 @@ int line_open(struct line *lines, struct tty_struct *tty) ...@@ -435,11 +434,8 @@ int line_open(struct line *lines, struct tty_struct *tty)
chan_window_size(&line->chan_list, &tty->winsize.ws_row, chan_window_size(&line->chan_list, &tty->winsize.ws_row,
&tty->winsize.ws_col); &tty->winsize.ws_col);
return 0;
out_unlock: out_unlock:
spin_unlock(&line->count_lock); mutex_unlock(&line->count_lock);
return err; return err;
} }
...@@ -459,7 +455,7 @@ void line_close(struct tty_struct *tty, struct file * filp) ...@@ -459,7 +455,7 @@ void line_close(struct tty_struct *tty, struct file * filp)
/* We ignore the error anyway! */ /* We ignore the error anyway! */
flush_buffer(line); flush_buffer(line);
spin_lock(&line->count_lock); mutex_lock(&line->count_lock);
BUG_ON(!line->valid); BUG_ON(!line->valid);
if (--line->count) if (--line->count)
...@@ -468,17 +464,13 @@ void line_close(struct tty_struct *tty, struct file * filp) ...@@ -468,17 +464,13 @@ void line_close(struct tty_struct *tty, struct file * filp)
line->tty = NULL; line->tty = NULL;
tty->driver_data = NULL; tty->driver_data = NULL;
spin_unlock(&line->count_lock);
if (line->sigio) { if (line->sigio) {
unregister_winch(tty); unregister_winch(tty);
line->sigio = 0; line->sigio = 0;
} }
return;
out_unlock: out_unlock:
spin_unlock(&line->count_lock); mutex_unlock(&line->count_lock);
} }
void close_lines(struct line *lines, int nlines) void close_lines(struct line *lines, int nlines)
...@@ -495,7 +487,7 @@ static int setup_one_line(struct line *lines, int n, char *init, ...@@ -495,7 +487,7 @@ static int setup_one_line(struct line *lines, int n, char *init,
struct line *line = &lines[n]; struct line *line = &lines[n];
int err = -EINVAL; int err = -EINVAL;
spin_lock(&line->count_lock); mutex_lock(&line->count_lock);
if (line->count) { if (line->count) {
*error_out = "Device is already open"; *error_out = "Device is already open";
...@@ -510,7 +502,7 @@ static int setup_one_line(struct line *lines, int n, char *init, ...@@ -510,7 +502,7 @@ static int setup_one_line(struct line *lines, int n, char *init,
} }
err = 0; err = 0;
out: out:
spin_unlock(&line->count_lock); mutex_unlock(&line->count_lock);
return err; return err;
} }
...@@ -609,13 +601,13 @@ int line_get_config(char *name, struct line *lines, unsigned int num, char *str, ...@@ -609,13 +601,13 @@ int line_get_config(char *name, struct line *lines, unsigned int num, char *str,
line = &lines[dev]; line = &lines[dev];
spin_lock(&line->count_lock); mutex_lock(&line->count_lock);
if (!line->valid) if (!line->valid)
CONFIG_CHUNK(str, size, n, "none", 1); CONFIG_CHUNK(str, size, n, "none", 1);
else if (line->tty == NULL) else if (line->tty == NULL)
CONFIG_CHUNK(str, size, n, line->init_str, 1); CONFIG_CHUNK(str, size, n, line->init_str, 1);
else n = chan_config_string(&line->chan_list, str, size, error_out); else n = chan_config_string(&line->chan_list, str, size, error_out);
spin_unlock(&line->count_lock); mutex_unlock(&line->count_lock);
return n; return n;
} }
......
...@@ -32,7 +32,7 @@ struct line_driver { ...@@ -32,7 +32,7 @@ struct line_driver {
struct line { struct line {
struct tty_struct *tty; struct tty_struct *tty;
spinlock_t count_lock; struct mutex count_lock;
unsigned long count; unsigned long count;
int valid; int valid;
......
...@@ -201,7 +201,7 @@ static int ssl_init(void) ...@@ -201,7 +201,7 @@ static int ssl_init(void)
serial_lines[i].valid = 1; serial_lines[i].valid = 1;
} }
spin_lock_init(&serial_lines[i].lock); spin_lock_init(&serial_lines[i].lock);
spin_lock_init(&serial_lines[i].count_lock); mutex_init(&serial_lines[i].count_lock);
serial_lines[i].driver = &driver; serial_lines[i].driver = &driver;
} }
ssl_driver = register_lines(&driver, &ssl_ops, serial_lines, ssl_driver = register_lines(&driver, &ssl_ops, serial_lines,
......
...@@ -173,7 +173,7 @@ static int stdio_init(void) ...@@ -173,7 +173,7 @@ static int stdio_init(void)
vts[i].valid = 1; vts[i].valid = 1;
} }
spin_lock_init(&vts[i].lock); spin_lock_init(&vts[i].lock);
spin_lock_init(&vts[i].count_lock); mutex_init(&vts[i].count_lock);
vts[i].driver = &driver; vts[i].driver = &driver;
} }
console_driver = register_lines(&driver, &console_ops, vts, console_driver = register_lines(&driver, &console_ops, vts,
......
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