aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLoic Poulain <loic.poulain@linaro.org>2021-04-22 11:21:51 +0200
committerLoic Poulain <loic.poulain@linaro.org>2021-04-22 14:42:59 +0200
commitb485a8175e02fcccd3422bfe515ee74c2d95cbcc (patch)
tree9789d6161908a7cb7ecfc188ba630a6a58d6dc91
parent6f547a3470625250f0dd510e44093935eeeb1d48 (diff)
net: wwan: core: Return poll error in case of port removal
Ensure that the poll system call returns error flags when port is removed, allowing user side to properly fail, without trying read or write. Port removal leads to nullified port operations, add a is_port_connected() helper to safely check the status. Fixes: 9a44c1cc6388 ("net: Add a WWAN subsystem") Signed-off-by: Loic Poulain <loic.poulain@linaro.org>
-rw-r--r--drivers/net/wwan/wwan_core.c17
1 files changed, 15 insertions, 2 deletions
diff --git a/drivers/net/wwan/wwan_core.c b/drivers/net/wwan/wwan_core.c
index 5be5e1e3534c..c965b213b67f 100644
--- a/drivers/net/wwan/wwan_core.c
+++ b/drivers/net/wwan/wwan_core.c
@@ -369,14 +369,25 @@ out_unlock:
return ret;
}
+static bool is_port_connected(struct wwan_port *port)
+{
+ bool connected;
+
+ mutex_lock(&port->ops_lock);
+ connected = !!port->ops;
+ mutex_unlock(&port->ops_lock);
+
+ return connected;
+}
+
static bool is_read_blocked(struct wwan_port *port)
{
- return skb_queue_empty(&port->rxq) && port->ops;
+ return skb_queue_empty(&port->rxq) && is_port_connected(port);
}
static bool is_write_blocked(struct wwan_port *port)
{
- return test_bit(WWAN_PORT_TX_OFF, &port->flags) && port->ops;
+ return test_bit(WWAN_PORT_TX_OFF, &port->flags) && is_port_connected(port);
}
static int wwan_wait_rx(struct wwan_port *port, bool nonblock)
@@ -508,6 +519,8 @@ static __poll_t wwan_port_fops_poll(struct file *filp, poll_table *wait)
mask |= EPOLLOUT | EPOLLWRNORM;
if (!is_read_blocked(port))
mask |= EPOLLIN | EPOLLRDNORM;
+ if (!is_port_connected(port))
+ mask |= EPOLLHUP | EPOLLERR;
return mask;
}