]> git.ipfire.org Git - thirdparty/kernel/linux.git/commitdiff
thunderbolt: Remove XDomain from the bus without holding tb->lock
authorMika Westerberg <mika.westerberg@linux.intel.com>
Thu, 6 Nov 2025 15:59:52 +0000 (17:59 +0200)
committerMika Westerberg <mika.westerberg@linux.intel.com>
Tue, 5 May 2026 11:53:46 +0000 (13:53 +0200)
Currently we call device_unregister() for services and the XDomain
itself with tb->lock held. This prevents the service drivers from
calling any functions that may take it. For this reason separate
removing the XDomain from the topology data structures (where we need
the lock) from unregistering the device from the bus (where remove
callbacks of the drivers are being called).

Signed-off-by: Mika Westerberg <mika.westerberg@linux.intel.com>
drivers/thunderbolt/debugfs.c
drivers/thunderbolt/domain.c
drivers/thunderbolt/icm.c
drivers/thunderbolt/switch.c
drivers/thunderbolt/tb.c
drivers/thunderbolt/tb.h
drivers/thunderbolt/xdomain.c

index d089d2deceddbfffe3418de4f56b23a6cd11a533..569163a26afa2acc1ada344c215abd160cf26d39 100644 (file)
@@ -1780,6 +1780,8 @@ static void margining_port_remove(struct tb_port *port)
 
        if (!port->usb4)
                return;
+       if (!port->usb4->margining)
+               return;
 
        snprintf(dir_name, sizeof(dir_name), "port%d", port->port);
        parent = debugfs_lookup(dir_name, port->sw->debugfs_dir);
index df4d7dd45adf322d9b13c7b26ea6fcd00ba18ae6..d83719a37b4c1f53308f8b6df9ac86d9a3fcdde2 100644 (file)
@@ -853,6 +853,36 @@ int tb_domain_disconnect_all_paths(struct tb *tb)
        return bus_for_each_dev(&tb_bus_type, NULL, tb, disconnect_xdomain);
 }
 
+struct unregister_context {
+       const struct tb *tb;
+       int n;
+};
+
+static int unregister_unplugged_xdomain(struct device *dev, void *data)
+{
+       struct unregister_context *ctx = data;
+       struct tb_xdomain *xd;
+
+       xd = tb_to_xdomain(dev);
+       if (xd && xd->tb == ctx->tb && xd->is_unplugged) {
+               tb_xdomain_unregister(xd);
+               ctx->n++;
+       }
+       return 0;
+}
+
+int tb_domain_unregister_unplugged_xdomains(struct tb *tb)
+{
+       struct unregister_context ctx;
+
+       ctx.tb = tb_domain_get(tb);
+       ctx.n = 0;
+       bus_for_each_dev(&tb_bus_type, NULL, &ctx, unregister_unplugged_xdomain);
+       tb_domain_put(tb);
+
+       return ctx.n;
+}
+
 int tb_domain_init(void)
 {
        int ret;
index 9d95bf3ab44c103828dc8871115bcd2304df92ea..2f93a7bccad55d71cd632377423608c01279e91c 100644 (file)
@@ -738,6 +738,7 @@ static void remove_xdomain(struct tb_xdomain *xd)
 
        sw = tb_to_switch(xd->dev.parent);
        tb_port_at(xd->route, sw)->xdomain = NULL;
+       xd->is_unplugged = true;
        tb_xdomain_remove(xd);
 }
 
@@ -1762,6 +1763,8 @@ static void icm_handle_notification(struct work_struct *work)
 
        kfree(n->pkg);
        kfree(n);
+
+       tb_domain_unregister_unplugged_xdomains(tb);
 }
 
 static void icm_handle_event(struct tb *tb, enum tb_cfg_pkg_type type,
@@ -2112,6 +2115,8 @@ static void icm_rescan_work(struct work_struct *work)
        if (tb->root_switch)
                icm_free_unplugged_children(tb->root_switch);
        mutex_unlock(&tb->lock);
+
+       tb_domain_unregister_unplugged_xdomains(tb);
 }
 
 static void icm_complete(struct tb *tb)
index c2ad58b19e7b1ae93101d5e09b634f220ba6ebf7..bfcab98faf4b23ff90dc347fd7c0fa8b313196fe 100644 (file)
@@ -3625,6 +3625,20 @@ int tb_switch_resume(struct tb_switch *sw, bool runtime)
                                tb_port_warn(port,
                                             "lost during suspend, disconnecting\n");
                                tb_sw_set_unplugged(port->remote->sw);
+                       } else if (port->xdomain) {
+                               /*
+                                * If the user replaced the XDomain with
+                                * another router, this will succeed in
+                                * which case we must remove the XDomain
+                                * before adding the new router.
+                                */
+                               err = tb_cfg_get_upstream_port(sw->tb->ctl,
+                                                              port->xdomain->route);
+                               if (err > 0) {
+                                       tb_port_warn(port,
+                                                    "XDomain was disconnected\n");
+                                       port->xdomain->is_unplugged = true;
+                               }
                        }
                }
        }
index 677877baae6386b8213c0148d7f6e516b55ff8ee..a9d26a2ec259bd46ed3fc00f07280556b47446fe 100644 (file)
@@ -2524,6 +2524,8 @@ put_sw:
 out:
        mutex_unlock(&tb->lock);
 
+       tb_domain_unregister_unplugged_xdomains(tb);
+
        pm_runtime_mark_last_busy(&tb->dev);
        pm_runtime_put_autosuspend(&tb->dev);
 
@@ -3114,6 +3116,24 @@ static void tb_restore_children(struct tb_switch *sw)
        }
 }
 
+static void tb_free_unplugged_xdomains(struct tb_switch *sw)
+{
+       struct tb_port *port;
+
+       tb_switch_for_each_port(sw, port) {
+               if (tb_is_upstream_port(port))
+                       continue;
+               if (port->xdomain && port->xdomain->is_unplugged) {
+                       tb_retimer_remove_all(port);
+                       tb_xdomain_remove(port->xdomain);
+                       tb_port_unconfigure_xdomain(port);
+                       port->xdomain = NULL;
+               } else if (port->remote) {
+                       tb_free_unplugged_xdomains(port->remote->sw);
+               }
+       }
+}
+
 static int tb_resume_noirq(struct tb *tb)
 {
        struct tb_cm *tcm = tb_priv(tb);
@@ -3133,6 +3153,7 @@ static int tb_resume_noirq(struct tb *tb)
        tb_switch_resume(tb->root_switch, false);
        tb_free_invalid_tunnels(tb);
        tb_free_unplugged_children(tb->root_switch);
+       tb_free_unplugged_xdomains(tb->root_switch);
        tb_restore_children(tb->root_switch);
 
        /*
@@ -3175,28 +3196,6 @@ static int tb_resume_noirq(struct tb *tb)
        return 0;
 }
 
-static int tb_free_unplugged_xdomains(struct tb_switch *sw)
-{
-       struct tb_port *port;
-       int ret = 0;
-
-       tb_switch_for_each_port(sw, port) {
-               if (tb_is_upstream_port(port))
-                       continue;
-               if (port->xdomain && port->xdomain->is_unplugged) {
-                       tb_retimer_remove_all(port);
-                       tb_xdomain_remove(port->xdomain);
-                       tb_port_unconfigure_xdomain(port);
-                       port->xdomain = NULL;
-                       ret++;
-               } else if (port->remote) {
-                       ret += tb_free_unplugged_xdomains(port->remote->sw);
-               }
-       }
-
-       return ret;
-}
-
 static int tb_freeze_noirq(struct tb *tb)
 {
        struct tb_cm *tcm = tb_priv(tb);
@@ -3216,14 +3215,14 @@ static int tb_thaw_noirq(struct tb *tb)
 static void tb_complete(struct tb *tb)
 {
        /*
-        * Release any unplugged XDomains and if there is a case where
+        * Unregister unplugged XDomains and if there is a case where
         * another domain is swapped in place of unplugged XDomain we
         * need to run another rescan.
         */
-       mutex_lock(&tb->lock);
-       if (tb_free_unplugged_xdomains(tb->root_switch))
-               tb_scan_switch(tb->root_switch);
-       mutex_unlock(&tb->lock);
+       if (tb_domain_unregister_unplugged_xdomains(tb)) {
+               scoped_guard(mutex, &tb->lock)
+                       tb_scan_switch(tb->root_switch);
+       }
 }
 
 static int tb_runtime_suspend(struct tb *tb)
@@ -3250,11 +3249,11 @@ static void tb_remove_work(struct work_struct *work)
        struct tb *tb = tcm_to_tb(tcm);
 
        mutex_lock(&tb->lock);
-       if (tb->root_switch) {
+       if (tb->root_switch)
                tb_free_unplugged_children(tb->root_switch);
-               tb_free_unplugged_xdomains(tb->root_switch);
-       }
        mutex_unlock(&tb->lock);
+
+       tb_free_unplugged_xdomains(tb->root_switch);
 }
 
 static int tb_runtime_resume(struct tb *tb)
index 217c3114bec8ba96eaf2348de55f3ede70b6f24c..229b9e7961fba8613168e3db5fb685f4779cfb0f 100644 (file)
@@ -793,6 +793,7 @@ int tb_domain_disconnect_xdomain_paths(struct tb *tb, struct tb_xdomain *xd,
                                       int transmit_path, int transmit_ring,
                                       int receive_path, int receive_ring);
 int tb_domain_disconnect_all_paths(struct tb *tb);
+int tb_domain_unregister_unplugged_xdomains(struct tb *tb);
 
 static inline struct tb *tb_domain_get(struct tb *tb)
 {
@@ -1263,6 +1264,7 @@ struct tb_xdomain *tb_xdomain_alloc(struct tb *tb, struct device *parent,
                                    const uuid_t *remote_uuid);
 void tb_xdomain_add(struct tb_xdomain *xd);
 void tb_xdomain_remove(struct tb_xdomain *xd);
+void tb_xdomain_unregister(struct tb_xdomain *xd);
 struct tb_xdomain *tb_xdomain_find_by_link_depth(struct tb *tb, u8 link,
                                                 u8 depth);
 
index 76e1902d18f39d620acf2671ceb9912b49f89d9d..9a30fe36c4be419198baa38146d5ad046cffd4bf 100644 (file)
@@ -2105,40 +2105,53 @@ static int unregister_service(struct device *dev, void *data)
 }
 
 /**
- * tb_xdomain_remove() - Remove XDomain from the bus
+ * tb_xdomain_remove() - Remove XDomain
  * @xd: XDomain to remove
  *
- * This will stop all ongoing configuration work and remove the XDomain
- * along with any services from the bus. When the last reference to @xd
- * is released the object will be released as well.
+ * This will stop all ongoing configuration work. XDomain is not removed
+ * from the bus if it was added. That needs to be done separately by
+ * calling tb_xdomain_unregister().
+ *
+ * Called with @tb->lock held.
  */
 void tb_xdomain_remove(struct tb_xdomain *xd)
 {
        tb_xdomain_debugfs_remove(xd);
-
        stop_handshake(xd);
-
-       device_for_each_child_reverse(&xd->dev, xd, unregister_service);
-
        tb_xdomain_link_exit(xd);
 
-       /*
-        * Undo runtime PM here explicitly because it is possible that
-        * the XDomain was never added to the bus and thus device_del()
-        * is not called for it (device_del() would handle this otherwise).
-        */
-       pm_runtime_disable(&xd->dev);
-       pm_runtime_put_noidle(&xd->dev);
-       pm_runtime_set_suspended(&xd->dev);
-
        if (!device_is_registered(&xd->dev)) {
+               /*
+                * Undo runtime PM here explicitly because it is
+                * possible that the XDomain was never added to the bus
+                * and thus device_del() is not called for it
+                * (device_del() would handle this otherwise).
+                */
+               pm_runtime_disable(&xd->dev);
+               pm_runtime_put_noidle(&xd->dev);
+               pm_runtime_set_suspended(&xd->dev);
                put_device(&xd->dev);
-       } else {
-               dev_info(&xd->dev, "host disconnected\n");
-               device_unregister(&xd->dev);
        }
 }
 
+/**
+ * tb_xdomain_unregister() - Unregister XDomain
+ * @xd: XDomain to unregister
+ *
+ * This will unregister the XDomain along with any services from the
+ * bus. When the last reference to @xd is released the object will be
+ * released as well.
+ */
+void tb_xdomain_unregister(struct tb_xdomain *xd)
+{
+       lockdep_assert_not_held(&xd->tb->lock);
+
+       device_for_each_child_reverse(&xd->dev, xd, unregister_service);
+
+       dev_info(&xd->dev, "host disconnected\n");
+       device_unregister(&xd->dev);
+}
+
 /**
  * tb_xdomain_lane_bonding_enable() - Enable lane bonding on XDomain
  * @xd: XDomain connection