PoolMaxSimultaneousTest::testSingleMaxAdding2Processes()

Complexity

Conditions	1
Paths	1

Size

Total Lines	56
Code Lines	39

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    public function testSingleMaxAdding2Processes()
    {
        $pool = new PriorityPool();
        $this->assertSame($pool, $pool->setMaxSimultaneous(1));

        $this->assertEquals(1, $pool->getMaxSimultaneous());

        $process1 = Mockery::mock(Process::class);
        $process1->shouldReceive('stop');
        $process1->shouldReceive('isStarted')->andReturn(false, false, false, true); //add, add2, start, check
        $process1->shouldReceive('isRunning')->andReturn(false); //add, add2, check

        $pool->add($process1);

$process1 of type Mockery\MockInterface is incompatible with the type Graze\ParallelProcess\PoolInterface|Graze\ParallelProcess\RunInterface|Symfony\Component\Process\Process expected by parameter $item of Graze\ParallelProcess\PriorityPool::add().

        $process2 = Mockery::mock(Process::class);
        $process2->shouldReceive('stop');
        $process2->shouldReceive('isStarted')->andReturn(false, false, false, true); //add, add2, start, check
        $process2->shouldReceive('isRunning')->andReturn(false); //add, add2, check

        $pool->add($process2);

        $process1->shouldReceive('start')->once();
        $pool->start();

        $this->assertCount(1, $pool->getRunning());
        $this->assertCount(1, $pool->getWaiting());

        $running = $pool->getRunning();
        $run = reset($running);
        $this->assertInstanceOf(ProcessRun::class, $run);
        $this->assertSame($process1, $run->getProcess(), 'first process added should be run first');

        $waiting = $pool->getWaiting();
        $run = reset($waiting);
        $this->assertInstanceOf(ProcessRun::class, $run);
        $this->assertSame($process2, $run->getProcess(), 'second process added should be waiting');

        $process1->shouldReceive('isSuccessful')->andReturn(true);
        $process2->shouldReceive('start');

        $this->assertTrue($pool->poll()); // check running state

        $this->assertCount(1, $pool->getRunning());
        $this->assertCount(0, $pool->getWaiting());

        $running = $pool->getRunning();
        $run = reset($running);
        $this->assertInstanceOf(ProcessRun::class, $run);
        $this->assertSame($process2, $run->getProcess(), 'second process added should now be running');

        $process2->shouldReceive('isSuccessful')->andReturn(true);
        $process2->shouldReceive('isSuccessful')->andReturn(true);
        $this->assertFalse($pool->poll());

        $this->assertCount(0, $pool->getRunning());
        $this->assertCount(0, $pool->getWaiting());
    }