Skip to content
Snippets Groups Projects
Commit a3d468db authored by Mateusz Charytoniuk's avatar Mateusz Charytoniuk
Browse files

chore: try finding which test causes segfault in github actions

parent 0d351250
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
src/ObservableTaskTableSlotStatusUpdateIteratorTest.php
+ 37
− 37
View file @ a3d468db
......@@ -36,41 +36,41 @@ final class ObservableTaskTableSlotStatusUpdateIteratorTest extends TestCase
Event::wait();
}
public function test_channel_is_observed(): void
{
SwooleCoroutineHelper::mustRun(function () {
$observableTask = new ObservableTask(static function () {
yield new ObservableTaskStatusUpdate(
ObservableTaskStatus::Running,
'test1',
);
yield new ObservableTaskStatusUpdate(
ObservableTaskStatus::Finished,
'test2',
);
});
SwooleCoroutineHelper::mustGo(function () {
self::assertNotNull($this->observableTaskTable);
$iterator = new ObservableTaskTableSlotStatusUpdateIterator($this->observableTaskTable);
foreach ($iterator as $statusUpdate) {
self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $statusUpdate);
self::assertEquals('0', $statusUpdate->slotId);
if (ObservableTaskStatus::Finished === $statusUpdate->observableTaskStatusUpdate->status) {
self::assertEquals('test2', $statusUpdate->observableTaskStatusUpdate->data);
break;
}
self::assertEquals('test1', $statusUpdate->observableTaskStatusUpdate->data);
}
});
$this->observableTaskTable?->observe($observableTask);
});
}
// public function test_channel_is_observed(): void
// {
// SwooleCoroutineHelper::mustRun(function () {
// $observableTask = new ObservableTask(static function () {
// yield new ObservableTaskStatusUpdate(
// ObservableTaskStatus::Running,
// 'test1',
// );
// yield new ObservableTaskStatusUpdate(
// ObservableTaskStatus::Finished,
// 'test2',
// );
// });
// SwooleCoroutineHelper::mustGo(function () {
// self::assertNotNull($this->observableTaskTable);
// $iterator = new ObservableTaskTableSlotStatusUpdateIterator($this->observableTaskTable);
// foreach ($iterator as $statusUpdate) {
// self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $statusUpdate);
// self::assertEquals('0', $statusUpdate->slotId);
// if (ObservableTaskStatus::Finished === $statusUpdate->observableTaskStatusUpdate->status) {
// self::assertEquals('test2', $statusUpdate->observableTaskStatusUpdate->data);
// break;
// }
// self::assertEquals('test1', $statusUpdate->observableTaskStatusUpdate->data);
// }
// });
// $this->observableTaskTable?->observe($observableTask);
// });
// }
}
src/ObservableTaskTableTest.php
+ 49
− 49
View file @ a3d468db
......@@ -39,71 +39,71 @@ final class ObservableTaskTableTest extends TestCase
Event::wait();
}
public function test_channel_is_observed(): void
{
SwooleCoroutineHelper::mustRun(function () {
$channel = new Channel();
$wg = new WaitGroup();
// public function test_channel_is_observed(): void
// {
// SwooleCoroutineHelper::mustRun(function () {
// $channel = new Channel();
// $wg = new WaitGroup();
$this->observableTaskTable?->observableChannels->add($channel);
// $this->observableTaskTable?->observableChannels->add($channel);
$observableTask = new ObservableTask(static function () {
yield new ObservableTaskStatusUpdate(
ObservableTaskStatus::Running,
'test1',
);
// $observableTask = new ObservableTask(static function () {
// yield new ObservableTaskStatusUpdate(
// ObservableTaskStatus::Running,
// 'test1',
// );
yield new ObservableTaskStatusUpdate(
ObservableTaskStatus::Finished,
'test2',
);
});
// yield new ObservableTaskStatusUpdate(
// ObservableTaskStatus::Finished,
// 'test2',
// );
// });
$wg->add();
// $wg->add();
SwooleCoroutineHelper::mustGo(static function () use ($channel, $wg) {
Coroutine::defer(static function () use ($wg) {
$wg->done();
});
// SwooleCoroutineHelper::mustGo(static function () use ($channel, $wg) {
// Coroutine::defer(static function () use ($wg) {
// $wg->done();
// });
$status1 = $channel->pop();
// $status1 = $channel->pop();
self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status1);
self::assertSame(ObservableTaskStatus::Running, $status1->observableTaskStatusUpdate->status);
// self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status1);
// self::assertSame(ObservableTaskStatus::Running, $status1->observableTaskStatusUpdate->status);
$status2 = $channel->pop();
// $status2 = $channel->pop();
self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status2);
self::assertSame(ObservableTaskStatus::Finished, $status2->observableTaskStatusUpdate->status);
});
// self::assertInstanceOf(ObservableTaskSlotStatusUpdate::class, $status2);
// self::assertSame(ObservableTaskStatus::Finished, $status2->observableTaskStatusUpdate->status);
// });
$this->observableTaskTable?->observe($observableTask);
// $this->observableTaskTable?->observe($observableTask);
$wg->wait();
// $wg->wait();
$this->observableTaskTable?->observableChannels->remove($channel);
});
}
// $this->observableTaskTable?->observableChannels->remove($channel);
// });
// }
public function test_task_is_observed(): void
{
$observableTask = new ObservableTask(static function () {
yield new ObservableTaskStatusUpdate(
ObservableTaskStatus::Running,
'test',
);
});
// public function test_task_is_observed(): void
// {
// $observableTask = new ObservableTask(static function () {
// yield new ObservableTaskStatusUpdate(
// ObservableTaskStatus::Running,
// 'test',
// );
// });
self::assertNull($this->observableTaskTable?->getStatus('0'));
// self::assertNull($this->observableTaskTable?->getStatus('0'));
$slotId = $this->observableTaskTable?->observe($observableTask);
// $slotId = $this->observableTaskTable?->observe($observableTask);
self::assertSame('0', $slotId);
// self::assertSame('0', $slotId);
$status = $this->observableTaskTable?->getStatus($slotId);
// $status = $this->observableTaskTable?->getStatus($slotId);
self::assertInstanceOf(ObservableTaskStatusUpdate::class, $status);
self::assertSame(ObservableTaskStatus::Running, $status->status);
self::assertSame('test', $status->data);
}
// self::assertInstanceOf(ObservableTaskStatusUpdate::class, $status);
// self::assertSame(ObservableTaskStatus::Running, $status->status);
// self::assertSame('test', $status->data);
// }
}
src/SwooleTimeoutTest.php
+ 24
− 24
View file @ a3d468db
......@@ -21,35 +21,35 @@ final class SwooleTimeoutTest extends TestCase
Event::wait();
}
public function test_code_executes_after_timeout(): void
{
SwooleCoroutineHelper::mustRun(static function () {
$before = microtime(true);
// public function test_code_executes_after_timeout(): void
// {
// SwooleCoroutineHelper::mustRun(static function () {
// $before = microtime(true);
$timeout = new SwooleTimeout(static function () use ($before) {
$after = microtime(true);
// $timeout = new SwooleTimeout(static function () use ($before) {
// $after = microtime(true);
self::assertGreaterThan(0.03, $after - $before);
self::assertLessThan(0.035, $after - $before);
});
// self::assertGreaterThan(0.03, $after - $before);
// self::assertLessThan(0.035, $after - $before);
// });
$timeout->setTimeout(0.03);
});
}
// $timeout->setTimeout(0.03);
// });
// }
public function test_task_is_rescheduled(): void
{
SwooleCoroutineHelper::mustRun(static function () {
$before = microtime(true);
// public function test_task_is_rescheduled(): void
// {
// SwooleCoroutineHelper::mustRun(static function () {
// $before = microtime(true);
$timeout = new SwooleTimeout(static function () use ($before) {
$after = microtime(true);
// $timeout = new SwooleTimeout(static function () use ($before) {
// $after = microtime(true);
self::assertGreaterThan(0.03, $after - $before);
self::assertLessThan(0.035, $after - $before);
});
// self::assertGreaterThan(0.03, $after - $before);
// self::assertLessThan(0.035, $after - $before);
// });
$timeout->setTimeout(0.02)->reschedule(0.03);
});
}
// $timeout->setTimeout(0.02)->reschedule(0.03);
// });
// }
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment

:feet::heart: Strive to be the person your dogs believe you are :heart::feet: