Hi Pauli, On Wed, Jun 28, 2023 at 9:24 AM Pauli Virtanen <pav@xxxxxx> wrote: > > Hi Luiz, > > ti, 2023-06-27 kello 16:05 -0700, Luiz Augusto von Dentz kirjoitti: > > Hi Pauli, > > > > On Fri, Jun 23, 2023 at 3:21 PM Pauli Virtanen <pav@xxxxxx> wrote: > > > > > > Hi Luiz, > > > > > > pe, 2023-06-23 kello 12:39 -0700, Luiz Augusto von Dentz kirjoitti: > > > > On Fri, Jun 23, 2023 at 10:37 AM Pauli Virtanen <pav@xxxxxx> wrote: > > > > > > > > > > A delayed operation such as hci_sync on a given hci_conn needs to take > > > > > hci_conn_get, so that the hci_conn doesn't get freed in the meantime. > > > > > This does not guarantee the conn is still alive in a valid state, as it > > > > > may be cleaned up in the meantime, so one needs to check if it is still > > > > > in conn_hash to know if it's still alive. > > > > > > > > > > Simplify this alive check, using HCI_CONN_DELETED flag. This is also > > > > > meaningful with RCU lock only, but with slightly different semantics. > > > > > > > > > > If hci_conn_is_alive(conn) returns true inside rcu_read_lock, conn was > > > > > in conn_hash from the point of view of the current task when the flag > > > > > was read. Then its deletion cannot complete before rcu_read_unlock. > > > > > > > > > > Signed-off-by: Pauli Virtanen <pav@xxxxxx> > > > > > --- > > > > > > > > > > Notes: > > > > > This probably can be done with RCU primitives setting list.prev, but > > > > > that's maybe more magical... > > > > > > > > > > include/net/bluetooth/hci_core.h | 18 ++++++++++++++++++ > > > > > net/bluetooth/hci_conn.c | 10 +--------- > > > > > 2 files changed, 19 insertions(+), 9 deletions(-) > > > > > > > > > > diff --git a/include/net/bluetooth/hci_core.h b/include/net/bluetooth/hci_core.h > > > > > index 05a9b3ab3f56..cab39bdd0592 100644 > > > > > --- a/include/net/bluetooth/hci_core.h > > > > > +++ b/include/net/bluetooth/hci_core.h > > > > > @@ -978,6 +978,7 @@ enum { > > > > > HCI_CONN_PER_ADV, > > > > > HCI_CONN_BIG_CREATED, > > > > > HCI_CONN_CREATE_CIS, > > > > > + HCI_CONN_DELETED, > > > > > }; > > > > > > > > > > static inline bool hci_conn_ssp_enabled(struct hci_conn *conn) > > > > > @@ -997,6 +998,7 @@ static inline bool hci_conn_sc_enabled(struct hci_conn *conn) > > > > > static inline void hci_conn_hash_add(struct hci_dev *hdev, struct hci_conn *c) > > > > > { > > > > > struct hci_conn_hash *h = &hdev->conn_hash; > > > > > + WARN_ON(test_bit(HCI_CONN_DELETED, &c->flags)); > > > > > list_add_tail_rcu(&c->list, &h->list); > > > > > switch (c->type) { > > > > > case ACL_LINK: > > > > > @@ -1023,6 +1025,10 @@ static inline void hci_conn_hash_add(struct hci_dev *hdev, struct hci_conn *c) > > > > > static inline void hci_conn_hash_del(struct hci_dev *hdev, struct hci_conn *c) > > > > > { > > > > > struct hci_conn_hash *h = &hdev->conn_hash; > > > > > + bool deleted; > > > > > + > > > > > + deleted = test_and_set_bit(HCI_CONN_DELETED, &c->flags); > > > > > + WARN_ON(deleted); > > > > > > > > > > list_del_rcu(&c->list); > > > > > synchronize_rcu(); > > > > > @@ -1049,6 +1055,18 @@ static inline void hci_conn_hash_del(struct hci_dev *hdev, struct hci_conn *c) > > > > > } > > > > > } > > > > > > > > > > +/* With hdev->lock: whether hci_conn is in conn_hash. > > > > > + * With RCU: if true, the hci_conn is valid conn_hash iteration cursor and > > > > > + * hci_conn_hash_del has not completed. (Note that if hci_conn was obtained in > > > > > + * this critical section it is always valid, but this may return false!) > > > > > + */ > > > > > +static inline bool hci_conn_is_alive(struct hci_dev *hdev, struct hci_conn *c) > > > > > +{ > > > > > + RCU_LOCKDEP_WARN(lockdep_is_held(&hdev->lock) || rcu_read_lock_held(), > > > > > + "suspicious locking"); > > > > > + return !test_bit(HCI_CONN_DELETED, &c->flags); > > > > > +} > > > > > > > > I think we are better off doing something like > > > > hci_conn_hold_unless_zero like we do in l2cap_chan_hold_unless_zero, > > > > that said we need to check if the hci_conn_drop can still set the ref > > > > below zero, anyway that is probably a bug in itself and we should > > > > probably WARN_ON if that happens. > > > > > > The problem here is that we'd like to have both > > > > > > (1) to have hci_conn_del/cleanup delete the item from conn_hash > > > immediately > > > > > > (2) be able to continue iteration from the conn we held, after > > > releasing and reacquiring RCU or hdev->lock > > > > > > If conn is removed from the list, conn->list.next won't be updated any > > > more, so it is not safe to access after we have left the critical > > > section. So it seems we'd need some marker on whether it is still in > > > the list. > > > > > > Maybe (1) could be given up instead, something like: hci_conn_cleanup > > > sets HCI_CONN_DELETED instead of deleting from the list if refcount is > > > positive, and lookup functions skip items with this flag. > > > > > > Something along these lines could work, need to think a bit. > > > > Ive end up reworking this logic to use something similar to what > > mgmt.c was doing: > > > > https://patchwork.kernel.org/project/bluetooth/patch/20230627225915.2674812-1-luiz.dentz@xxxxxxxxx/ > > > > That way we just cancel by handle and don't have to make reference > > left and right, we just lookup by handle if the connection is still > > there when the work is scheduled we abort otherwise we don't have to > > do anything. > > Does this still rely on the conn not being freed concurrently, maybe to > be totally sure holding rcu_read_lock/hdev->lock or having refcount > would be needed around the lookup and *conn access? > > Unless there is something else guaranteeing the call sites of > hci_conn_del cannot occur at the same time? > > IIUC, hci_conn_del is called also from several other places that may > run concurrently if you don't lock, eg. in hci_event.c (seems to run in > different workqueue than hci_sync), and I guess controller could > trigger eg. HCI_Disconnection_Complete spontaneously. > > I'm not sure if these can be serialized behind hci_sync, if a handle is > disconnected it probably needs to do some teardown immediately like > unregistering it from sysfs, so that the same handle value can be > reused. > > This is also problem for using conn->refcnt for keeping it alive: it > seems we want to do partial cleanup anyway even if someone is holding > the conn, so it would in the end to boil down to same as hci_conn_get. > (Having hci_conn_get keep items in list would simplify iteration, but > other parts seem to become more complex so what was in this RFC is > maybe simplest in that direction.) The idea here is that lookup by handle shall always be safe since if hci_conn_del has already been called the conn shall no longer be in the hash, now perhaps what you are afraid is that hci_conn_del is not safe to be called concurrently, which is probably correct, so perhaps we need a flag or something to check that HCI_CONN_DEL is in progress. > > > > > > > static inline unsigned int hci_conn_num(struct hci_dev *hdev, __u8 type) > > > > > { > > > > > struct hci_conn_hash *h = &hdev->conn_hash; > > > > > diff --git a/net/bluetooth/hci_conn.c b/net/bluetooth/hci_conn.c > > > > > index 62a7ccfdfe63..d489a4829be7 100644 > > > > > --- a/net/bluetooth/hci_conn.c > > > > > +++ b/net/bluetooth/hci_conn.c > > > > > @@ -183,21 +183,13 @@ static void le_scan_cleanup(struct work_struct *work) > > > > > struct hci_conn *conn = container_of(work, struct hci_conn, > > > > > le_scan_cleanup); > > > > > struct hci_dev *hdev = conn->hdev; > > > > > - struct hci_conn *c = NULL; > > > > > > > > > > BT_DBG("%s hcon %p", hdev->name, conn); > > > > > > > > > > hci_dev_lock(hdev); > > > > > > > > > > /* Check that the hci_conn is still around */ > > > > > - rcu_read_lock(); > > > > > - list_for_each_entry_rcu(c, &hdev->conn_hash.list, list) { > > > > > - if (c == conn) > > > > > - break; > > > > > - } > > > > > - rcu_read_unlock(); > > > > > - > > > > > - if (c == conn) { > > > > > + if (hci_conn_is_alive(hdev, conn)) { > > > > > > > > Hmm, I don't think this is safe, except if we are doing hci_conn_get > > > > we can't really access the conn pointer since it may be freed already, > > > > anyway this is sort of broken already given that we do access > > > > conn->hdev already. > > > > > > hci_conn_get is held here, there's a hci_conn_put at the end of this > > > function. > > > > > > > > > > > > hci_connect_le_scan_cleanup(conn, 0x00); > > > > > hci_conn_cleanup(conn); > > > > > } > > > > > -- > > > > > 2.41.0 > > > > > > > > > > > > > > > > > > > > > -- Luiz Augusto von Dentz