add tests for fiber cancellation scenarios and coroutine behavior

Author: EdmondDantes

tests/fiber/023-fiber_cancel_via_coroutine.phpt

@@ -0,0 +1,45 @@
+--TEST--
+Cancel fiber's coroutine via getCoroutine()->cancel()
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\await;
+use Async\CancellationError;
+
+$c = spawn(function() {
+    $fiber = new Fiber(function() {
+        echo "Fiber started\n";
+        Fiber::suspend("suspended");
+        echo "Fiber resumed\n";
+        return "done";
+    });
+
+    $fiber->start();
+    echo "Fiber suspended\n";
+
+    // Get fiber's coroutine and cancel it
+    $coro = $fiber->getCoroutine();
+    $coro->cancel(new CancellationError("cancelled"));
+    echo "Coroutine cancelled\n";
+
+    // Try to resume fiber
+    try {
+        $fiber->resume();
+        echo "Fiber completed\n";
+    } catch (CancellationError $e) {
+        echo "CancellationError: " . $e->getMessage() . "\n";
+    } catch (FiberError $e) {
+        echo "FiberError: " . $e->getMessage() . "\n";
+    }
+});
+
+await($c);
+echo "OK\n";
+?>
+--EXPECTF--
+Fiber started
+Fiber suspended
+Coroutine cancelled
+%a
+OK

tests/fiber/024-fiber_cancel_during_suspend.phpt

@@ -0,0 +1,44 @@
+--TEST--
+Cancel fiber's coroutine while fiber is suspended
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\suspend;
+use function Async\await;
+use Async\CancellationError;
+
+$c = spawn(function() {
+    $fiber = new Fiber(function() {
+        echo "Fiber: before suspend\n";
+        Fiber::suspend();
+        echo "Fiber: after suspend\n";
+        return "result";
+    });
+
+    $fiber->start();
+
+    // Fiber is suspended, cancel its coroutine
+    $coro = $fiber->getCoroutine();
+    echo "Cancelling coroutine\n";
+    $coro->cancel(new CancellationError("test"));
+
+    // Give scheduler a chance
+    suspend();
+
+    // Try resume
+    try {
+        $fiber->resume();
+    } catch (Throwable $e) {
+        echo "Caught: " . $e->getMessage() . "\n";
+    }
+});
+
+await($c);
+echo "OK\n";
+?>
+--EXPECTF--
+Fiber: before suspend
+Cancelling coroutine
+Caught: Cannot resume a fiber that is not suspended
+OK

tests/fiber/025-fiber_double_cancel.phpt

@@ -0,0 +1,47 @@
+--TEST--
+Double cancel - parent coroutine and fiber's coroutine
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\await;
+use Async\CancellationError;
+
+$parent = spawn(function() {
+    $fiber = new Fiber(function() {
+        Fiber::suspend();
+        return "done";
+    });
+
+    $fiber->start();
+
+    // Cancel fiber's coroutine
+    $fiberCoro = $fiber->getCoroutine();
+    $fiberCoro->cancel(new CancellationError("fiber cancel"));
+    echo "Fiber coroutine cancelled\n";
+
+    // Try resume
+    try {
+        $fiber->resume();
+    } catch (Throwable $e) {
+        echo "Fiber caught: " . $e->getMessage() . "\n";
+    }
+
+    return "parent done";
+});
+
+// Also cancel parent
+$parent->cancel(new CancellationError("parent cancel"));
+echo "Parent cancelled\n";
+
+try {
+    await($parent);
+} catch (CancellationError $e) {
+    echo "Parent caught: " . $e->getMessage() . "\n";
+}
+
+echo "OK\n";
+?>
+--EXPECTF--
+%a
+OK

tests/fiber/026-fiber_getCoroutine_after_termination.phpt

@@ -0,0 +1,37 @@
+--TEST--
+Get fiber's coroutine after fiber termination
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\await;
+
+$c = spawn(function() {
+    $fiber = new Fiber(function() {
+        return "done";
+    });
+
+    $result = $fiber->start();
+    echo "Fiber completed: {$result}\n";
+
+    // Get coroutine after fiber is terminated
+    $coro = $fiber->getCoroutine();
+
+    if ($coro !== null) {
+        echo "Has coroutine: yes\n";
+        echo "Is finished: " . ($coro->isFinished() ? "yes" : "no") . "\n";
+    } else {
+        echo "Has coroutine: no\n";
+    }
+
+    return "ok";
+});
+
+await($c);
+echo "OK\n";
+?>
+--EXPECTF--
+Fiber completed: done
+Has coroutine: yes
+Is finished: yes
+OK

tests/fiber/027-fiber_cancel_in_nested_spawn.phpt

@@ -0,0 +1,49 @@
+--TEST--
+Cancel fiber's coroutine from nested spawn
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\suspend;
+use function Async\await;
+use Async\CancellationError;
+
+$outer = spawn(function() {
+    $fiber = new Fiber(function() {
+        echo "Fiber running\n";
+        Fiber::suspend();
+        echo "This should not print\n";
+        return "done";
+    });
+
+    $fiber->start();
+    $fiberCoro = $fiber->getCoroutine();
+
+    // Nested coroutine cancels fiber's coroutine
+    $inner = spawn(function() use ($fiberCoro) {
+        echo "Inner: cancelling fiber coroutine\n";
+        $fiberCoro->cancel(new CancellationError("nested cancel"));
+    });
+
+    await($inner);
+    suspend();
+
+    // Try to use fiber
+    try {
+        $fiber->resume();
+    } catch (Throwable $e) {
+        echo "Caught: " . $e->getMessage() . "\n";
+    }
+
+    return "outer done";
+});
+
+$result = await($outer);
+echo "Result: {$result}\n";
+echo "OK\n";
+?>
+--EXPECTF--
+Fiber running
+Inner: cancelling fiber coroutine
+%a
+OK

tests/fiber/028-fiber_exception_vs_cancel.phpt

@@ -0,0 +1,38 @@
+--TEST--
+Fiber throws exception while coroutine is being cancelled
+--FILE--
+<?php
+
+use function Async\spawn;
+use function Async\await;
+use Async\CancellationError;
+
+$c = spawn(function() {
+    $fiber = new Fiber(function() {
+        Fiber::suspend();
+        throw new Exception("fiber exception");
+    });
+
+    $fiber->start();
+    $coro = $fiber->getCoroutine();
+
+    // Cancel coroutine
+    $coro->cancel(new CancellationError("cancel"));
+
+    // Resume - what happens? Exception or CancellationError?
+    try {
+        $fiber->resume();
+        echo "No exception\n";
+    } catch (CancellationError $e) {
+        echo "CancellationError: " . $e->getMessage() . "\n";
+    } catch (Exception $e) {
+        echo "Exception: " . $e->getMessage() . "\n";
+    }
+});
+
+await($c);
+echo "OK\n";
+?>
+--EXPECTF--
+%a
+OK