BaseParallelTestCase::addParallelProcess() - Code Metrics - Inspection of "fixup! EZP-30973: Made siteaccess aware repository..." - ezsystems/ezpublish-kernel - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — ezp_30973 ( feb262...9f83f6 )

unknown

created 2019-10-07 11:58 UTC

BaseParallelTestCase::addParallelProcess() A

↳ Parent: BaseParallelTestCase

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
nc	1
nop	2
dl	0
loc	12
rs	9.8666
c	0
b	0
f	0

<?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();
    }
}


1			<?php
2
3			/**
4			* @copyright Copyright (C) eZ Systems AS. All rights reserved.
5			* @license For full copyright and license information view LICENSE file distributed with this source code.
6			*/
7			declare(strict_types=1);
8
9			namespace eZ\Publish\API\Repository\Tests\Parallel;
10
11			use eZ\Publish\API\Repository\Tests\BaseTest;
12			use Jenner\SimpleFork\Process;
13
14			abstract class BaseParallelTestCase extends BaseTest
15			{
16			protected function setUp(): void
17			{
18			parent::setUp();
19
20			$connection = $this->getRawDatabaseConnection();
21			$dbms = $connection->getDatabasePlatform()->getName();
22
23			if ($dbms == 'sqlite') {
24			$this->markTestSkipped('Can not run parallel test on sqlite');
25			}
26			}
27
28			protected function addParallelProcess(ParallelProcessList $list, callable $callback): void
29			{
30			$connection = $this->getRawDatabaseConnection();
31
32			$process = new Process(function () use ($callback, $connection) {
33			$connection->connect();
34			$callback();
35			$connection->close();
36			});
37
38			$list->addProcess($process);
39			}
40
41			protected function runParallelProcesses(ParallelProcessList $list): void
42			{
43			$connection = $this->getRawDatabaseConnection();
44			// @see https://www.php.net/manual/en/function.pcntl-fork.php#70721
45			$connection->close();
46
47			foreach ($list as $process) {
48			$process->start();
49			}
50
51			foreach ($list as $process) {
52			$process->wait();
53			}
54
55			$connection->connect();
56			}
57			}
58

ezsystems / ezpublish-kernel

Push — ezp_30973 ( feb262...9f83f6 )

BaseParallelTestCase::addParallelProcess() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like