Notify scope on coroutine enqueue: add callback to handle new coroutine addition

EdmondDantes · EdmondDantes · commit eae4bab9af00 · 2025-12-07T18:09:10.000+02:00
diff --git a/scheduler.c b/scheduler.c
@@ -1032,6 +1032,14 @@ bool async_scheduler_coroutine_enqueue(zend_coroutine_t *coroutine)
 				}
 
 				ZEND_ASYNC_INCREASE_COROUTINE_COUNT;
+
+				// Notify scope that a new coroutine has been enqueued
+				zend_async_scope_t *scope = coroutine->scope;
+				scope->after_coroutine_enqueue(coroutine, scope);
+				if (UNEXPECTED(EG(exception))) {
+					coroutine->waker->status = ZEND_ASYNC_WAKER_IGNORED;
+					return false;
+				}
 			}
 
 			// Add to resumed_coroutines queue for event cleanup

Original file line number	Diff line number	Diff line change
`@@ -1032,6 +1032,14 @@ bool async_scheduler_coroutine_enqueue(zend_coroutine_t *coroutine)`
`1032`	`1032`	`}`
`1033`	`1033`
`1034`	`1034`	`ZEND_ASYNC_INCREASE_COROUTINE_COUNT;`
	`1035`	`+`
	`1036`	`+ // Notify scope that a new coroutine has been enqueued`
	`1037`	`+ zend_async_scope_t *scope = coroutine->scope;`
	`1038`	`+ scope->after_coroutine_enqueue(coroutine, scope);`
	`1039`	`+ if (UNEXPECTED(EG(exception))) {`
	`1040`	`+ coroutine->waker->status = ZEND_ASYNC_WAKER_IGNORED;`
	`1041`	`+ return false;`
	`1042`	`+ }`
`1035`	`1043`	`}`
`1036`	`1044`
`1037`	`1045`	`// Add to resumed_coroutines queue for event cleanup`