BaseParallelTestCase::addParallelProcess() - Code Metrics - Inspection of "xEZP-30469: Fixed publishing content in parallel" - ezsystems/ezpublish-kernel - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — parallel_test_fork ( b1fcc3...0461b5 )

unknown

created 2019-09-23 09:09 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 (!in_array($dbms, ['mysql', 'postgresql'])) {
            $this->markTestSkipped('Parallel test require mysql or postgresql db');
        }
    }

    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();
        $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 (!in_array($dbms, ['mysql', 'postgresql'])) {
24			$this->markTestSkipped('Parallel test require mysql or postgresql db');
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			$connection->close();
45
46			foreach ($list as $process) {
47			$process->start();
48			}
49
50			foreach ($list as $process) {
51			$process->wait();
52			}
53
54			$connection->connect();
55			}
56			}
57

ezsystems / ezpublish-kernel

Push — parallel_test_fork ( b1fcc3...0461b5 )

BaseParallelTestCase::addParallelProcess() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like