tty: introduce and use tty_port_tty_vhangup() helper

This code (tty_get -> vhangup -> tty_put) is repeated on few places.
Introduce a helper similar to tty_port_tty_hangup() (asynchronous) to
handle even vhangup (synchronous).

And use it on those places.

In fact, reuse the tty_port_tty_hangup()'s code and call tty_vhangup()
depending on a new bool parameter.

Signed-off-by: "Jiri Slaby (SUSE)" <jirislaby@kernel.org>
Cc: Karsten Keil <isdn@linux-pingi.de>
Cc: David Lin <dtwlin@gmail.com>
Cc: Johan Hovold <johan@kernel.org>
Cc: Alex Elder <elder@kernel.org>
Cc: Oliver Neukum <oneukum@suse.com>
Cc: Marcel Holtmann <marcel@holtmann.org>
Cc: Johan Hedberg <johan.hedberg@gmail.com>
Cc: Luiz Augusto von Dentz <luiz.dentz@gmail.com>
Reviewed-by: Ilpo Järvinen <ilpo.jarvinen@linux.intel.com>
Link: https://lore.kernel.org/r/20250611100319.186924-2-jirislaby@kernel.org
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
This commit is contained in:
Jiri Slaby (SUSE) 2025-06-11 12:02:47 +02:00 committed by Greg Kroah-Hartman
parent e04c78d86a
commit 2b5eac0f8c
8 changed files with 25 additions and 42 deletions

View file

@ -306,15 +306,9 @@ static void capincci_alloc_minor(struct capidev *cdev, struct capincci *np)
static void capincci_free_minor(struct capincci *np) static void capincci_free_minor(struct capincci *np)
{ {
struct capiminor *mp = np->minorp; struct capiminor *mp = np->minorp;
struct tty_struct *tty;
if (mp) { if (mp) {
tty = tty_port_tty_get(&mp->port); tty_port_tty_vhangup(&mp->port);
if (tty) {
tty_vhangup(tty);
tty_kref_put(tty);
}
capiminor_free(mp); capiminor_free(mp);
} }
} }

View file

@ -916,7 +916,6 @@ static void gb_uart_remove(struct gbphy_device *gbphy_dev)
{ {
struct gb_tty *gb_tty = gb_gbphy_get_data(gbphy_dev); struct gb_tty *gb_tty = gb_gbphy_get_data(gbphy_dev);
struct gb_connection *connection = gb_tty->connection; struct gb_connection *connection = gb_tty->connection;
struct tty_struct *tty;
int ret; int ret;
ret = gbphy_runtime_get_sync(gbphy_dev); ret = gbphy_runtime_get_sync(gbphy_dev);
@ -929,11 +928,7 @@ static void gb_uart_remove(struct gbphy_device *gbphy_dev)
wake_up_all(&gb_tty->wioctl); wake_up_all(&gb_tty->wioctl);
mutex_unlock(&gb_tty->mutex); mutex_unlock(&gb_tty->mutex);
tty = tty_port_tty_get(&gb_tty->port); tty_port_tty_vhangup(&gb_tty->port);
if (tty) {
tty_vhangup(tty);
tty_kref_put(tty);
}
gb_connection_disable_rx(connection); gb_connection_disable_rx(connection);
tty_unregister_device(gb_tty_driver, gb_tty->minor); tty_unregister_device(gb_tty_driver, gb_tty->minor);

View file

@ -3209,7 +3209,6 @@ static void serial_core_remove_one_port(struct uart_driver *drv,
struct uart_state *state = drv->state + uport->line; struct uart_state *state = drv->state + uport->line;
struct tty_port *port = &state->port; struct tty_port *port = &state->port;
struct uart_port *uart_port; struct uart_port *uart_port;
struct tty_struct *tty;
mutex_lock(&port->mutex); mutex_lock(&port->mutex);
uart_port = uart_port_check(state); uart_port = uart_port_check(state);
@ -3228,11 +3227,7 @@ static void serial_core_remove_one_port(struct uart_driver *drv,
*/ */
tty_port_unregister_device(port, drv->tty_driver, uport->line); tty_port_unregister_device(port, drv->tty_driver, uport->line);
tty = tty_port_tty_get(port); tty_port_tty_vhangup(port);
if (tty) {
tty_vhangup(port->tty);
tty_kref_put(tty);
}
/* /*
* If the port is used as a console, unregister it * If the port is used as a console, unregister it

View file

@ -396,15 +396,19 @@ EXPORT_SYMBOL(tty_port_hangup);
* @port: tty port * @port: tty port
* @check_clocal: hang only ttys with %CLOCAL unset? * @check_clocal: hang only ttys with %CLOCAL unset?
*/ */
void tty_port_tty_hangup(struct tty_port *port, bool check_clocal) void __tty_port_tty_hangup(struct tty_port *port, bool check_clocal, bool async)
{ {
struct tty_struct *tty = tty_port_tty_get(port); struct tty_struct *tty = tty_port_tty_get(port);
if (tty && (!check_clocal || !C_CLOCAL(tty))) if (tty && (!check_clocal || !C_CLOCAL(tty))) {
tty_hangup(tty); if (async)
tty_hangup(tty);
else
tty_vhangup(tty);
}
tty_kref_put(tty); tty_kref_put(tty);
} }
EXPORT_SYMBOL_GPL(tty_port_tty_hangup); EXPORT_SYMBOL_GPL(__tty_port_tty_hangup);
/** /**
* tty_port_tty_wakeup - helper to wake up a tty * tty_port_tty_wakeup - helper to wake up a tty

View file

@ -1571,7 +1571,6 @@ err_put_port:
static void acm_disconnect(struct usb_interface *intf) static void acm_disconnect(struct usb_interface *intf)
{ {
struct acm *acm = usb_get_intfdata(intf); struct acm *acm = usb_get_intfdata(intf);
struct tty_struct *tty;
int i; int i;
/* sibling interface is already cleaning up */ /* sibling interface is already cleaning up */
@ -1598,11 +1597,7 @@ static void acm_disconnect(struct usb_interface *intf)
usb_set_intfdata(acm->data, NULL); usb_set_intfdata(acm->data, NULL);
mutex_unlock(&acm->mutex); mutex_unlock(&acm->mutex);
tty = tty_port_tty_get(&acm->port); tty_port_tty_vhangup(&acm->port);
if (tty) {
tty_vhangup(tty);
tty_kref_put(tty);
}
cancel_delayed_work_sync(&acm->dwork); cancel_delayed_work_sync(&acm->dwork);

View file

@ -1176,7 +1176,6 @@ static void usb_serial_disconnect(struct usb_interface *interface)
struct usb_serial *serial = usb_get_intfdata(interface); struct usb_serial *serial = usb_get_intfdata(interface);
struct device *dev = &interface->dev; struct device *dev = &interface->dev;
struct usb_serial_port *port; struct usb_serial_port *port;
struct tty_struct *tty;
/* sibling interface is cleaning up */ /* sibling interface is cleaning up */
if (!serial) if (!serial)
@ -1191,11 +1190,7 @@ static void usb_serial_disconnect(struct usb_interface *interface)
for (i = 0; i < serial->num_ports; ++i) { for (i = 0; i < serial->num_ports; ++i) {
port = serial->port[i]; port = serial->port[i];
tty = tty_port_tty_get(&port->port); tty_port_tty_vhangup(&port->port);
if (tty) {
tty_vhangup(tty);
tty_kref_put(tty);
}
usb_serial_port_poison_urbs(port); usb_serial_port_poison_urbs(port);
wake_up_interruptible(&port->port.delta_msr_wait); wake_up_interruptible(&port->port.delta_msr_wait);
cancel_work_sync(&port->work); cancel_work_sync(&port->work);

View file

@ -232,7 +232,7 @@ bool tty_port_carrier_raised(struct tty_port *port);
void tty_port_raise_dtr_rts(struct tty_port *port); void tty_port_raise_dtr_rts(struct tty_port *port);
void tty_port_lower_dtr_rts(struct tty_port *port); void tty_port_lower_dtr_rts(struct tty_port *port);
void tty_port_hangup(struct tty_port *port); void tty_port_hangup(struct tty_port *port);
void tty_port_tty_hangup(struct tty_port *port, bool check_clocal); void __tty_port_tty_hangup(struct tty_port *port, bool check_clocal, bool async);
void tty_port_tty_wakeup(struct tty_port *port); void tty_port_tty_wakeup(struct tty_port *port);
int tty_port_block_til_ready(struct tty_port *port, struct tty_struct *tty, int tty_port_block_til_ready(struct tty_port *port, struct tty_struct *tty,
struct file *filp); struct file *filp);
@ -251,4 +251,14 @@ static inline int tty_port_users(struct tty_port *port)
return port->count + port->blocked_open; return port->count + port->blocked_open;
} }
static inline void tty_port_tty_hangup(struct tty_port *port, bool check_clocal)
{
__tty_port_tty_hangup(port, check_clocal, true);
}
static inline void tty_port_tty_vhangup(struct tty_port *port)
{
__tty_port_tty_hangup(port, false, false);
}
#endif #endif

View file

@ -438,7 +438,6 @@ static int __rfcomm_release_dev(void __user *arg)
{ {
struct rfcomm_dev_req req; struct rfcomm_dev_req req;
struct rfcomm_dev *dev; struct rfcomm_dev *dev;
struct tty_struct *tty;
if (copy_from_user(&req, arg, sizeof(req))) if (copy_from_user(&req, arg, sizeof(req)))
return -EFAULT; return -EFAULT;
@ -464,11 +463,7 @@ static int __rfcomm_release_dev(void __user *arg)
rfcomm_dlc_close(dev->dlc, 0); rfcomm_dlc_close(dev->dlc, 0);
/* Shut down TTY synchronously before freeing rfcomm_dev */ /* Shut down TTY synchronously before freeing rfcomm_dev */
tty = tty_port_tty_get(&dev->port); tty_port_tty_vhangup(&dev->port);
if (tty) {
tty_vhangup(tty);
tty_kref_put(tty);
}
if (!test_bit(RFCOMM_TTY_OWNED, &dev->status)) if (!test_bit(RFCOMM_TTY_OWNED, &dev->status))
tty_port_put(&dev->port); tty_port_put(&dev->port);