Have threads with no owned pool execute run_on_all calls themselves.

insertinterestingnamehere · insertinterestingnamehere · commit 0cb7b8a0944d · 2025-04-01T09:42:13.000-06:00
diff --git a/src/threadpool.c b/src/threadpool.c
@@ -416,7 +416,14 @@ pool_run_on_all(pool_header *pool, qt_threadpool_func_type func, void *arg) {
 }
 
 API_FUNC void run_on_current_pool(qt_threadpool_func_type func, void *arg) {
-  pool_run_on_all(owned_pool, func, arg);
+  if (owned_pool) {
+    pool_run_on_all(owned_pool, func, arg);
+  } else {
+    uint32_t outer_index = context_index;
+    context_index = 0;
+    func(arg);
+    context_index = outer_index;
+  }
 }
 
 API_FUNC void hw_pool_run_on_all(qt_threadpool_func_type func, void *arg) {

Original file line number	Diff line number	Diff line change
`@@ -416,7 +416,14 @@ pool_run_on_all(pool_header pool, qt_threadpool_func_type func, void arg) {`
`416`	`416`	`}`
`417`	`417`
`418`	`418`	`API_FUNC void run_on_current_pool(qt_threadpool_func_type func, void *arg) {`
`419`		`- pool_run_on_all(owned_pool, func, arg);`
	`419`	`+ if (owned_pool) {`
	`420`	`+ pool_run_on_all(owned_pool, func, arg);`
	`421`	`+ } else {`
	`422`	`+ uint32_t outer_index = context_index;`
	`423`	`+ context_index = 0;`
	`424`	`+ func(arg);`
	`425`	`+ context_index = outer_index;`
	`426`	`+ }`
`420`	`427`	`}`
`421`	`428`
`422`	`429`	`API_FUNC void hw_pool_run_on_all(qt_threadpool_func_type func, void *arg) {`