eZ\Publish\API\Repository\Tests\Parallel\BaseParallelTestCase

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	11	2
A	addParallelProcess()	0	12	1
A	runParallelProcesses()	0	16	3

<?php

/**
 * @copyright Copyright (C) eZ Systems AS. All rights reserved.
 * @license For full copyright and license information view LICENSE file distributed with this source code.
 */
declare(strict_types=1);

namespace eZ\Publish\API\Repository\Tests\Parallel;

use eZ\Publish\API\Repository\Tests\BaseTest;
use Jenner\SimpleFork\Process;

abstract class BaseParallelTestCase extends BaseTest
{
    protected function setUp(): void
    {
        parent::setUp();

        $connection = $this->getRawDatabaseConnection();
        $dbms = $connection->getDatabasePlatform()->getName();

        if ($dbms == 'sqlite') {
            $this->markTestSkipped('Can not run parallel test on sqlite');
        }
    }

    protected function addParallelProcess(ParallelProcessList $list, callable $callback): void
    {
        $connection = $this->getRawDatabaseConnection();

        $process = new Process(function () use ($callback, $connection) {
            $connection->connect();
            $callback();
            $connection->close();
        });

        $list->addProcess($process);
    }

    protected function runParallelProcesses(ParallelProcessList $list): void
    {
        $connection = $this->getRawDatabaseConnection();
        // @see https://www.php.net/manual/en/function.pcntl-fork.php#70721
        $connection->close();

        foreach ($list as $process) {
            $process->start();
        }

        foreach ($list as $process) {
            $process->wait();
        }

        $connection->connect();
    }
}