itertools\ForkingIterator

Complexity

Total Complexity

22

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	3
A	supportsFork()	0	4	1
A	isForkingEnabled()	0	4	2
A	fork()	0	12	3
A	wait()	0	6	1
B	rewind()	0	25	7
A	valid()	0	10	3
A	next()	0	7	2

<?php

namespace itertools;

use UnexpectedValueException;
use IteratorIterator;
use ArrayIterator;


class ForkingIterator extends IteratorIterator
{
	const IS_CHILD = 0;
	const ENABLED = true;
	const DISABLED = false;

	protected $isChild = false;
	protected $childCount = 0;
	protected $forkingEnabled;
	protected $maxChildren;

	public function __construct($innerIterator, $options = array())
	{
		parent::__construct(IterUtil::asTraversable($innerIterator));
		$this->forkingEnabled = array_key_exists('forkingEnabled', $options) ? $options['forkingEnabled'] : self::ENABLED;
		$this->maxChildren = array_key_exists('maxChildren', $options) ? $options['maxChildren'] : 8;
	}

	public static function supportsFork()
	{
		return function_exists('pcntl_fork');
	}

	public function isForkingEnabled()
	{
		return $this->forkingEnabled && self::supportsFork();
	}

	protected function fork()
	{
		$pid = pcntl_fork();
		if($pid == -1) {
			throw new UnexpectedValueException('Could not fork');
		}
		if($pid == self::IS_CHILD) {
			$this->isChild = true;
		}
		$this->childCount += 1;
		return $pid;
	}

	protected function wait()
	{
		pcntl_wait($status);

The variable $status does not exist. Did you forget to declare it?

		$this->childCount -= 1;
		return $status;
	}

	public function rewind()
	{
		if(!$this->isForkingEnabled()) {
			return parent::rewind();
		}

		parent::rewind();
		$status = 0;
		do {
			if($this->fork() == self::IS_CHILD) {
				return;
			}
			while($this->childCount >= $this->maxChildren) {
				$status |= $this->wait();
			}
			parent::next();

It seems like you call parent on a different method (next() instead of rewind()). Are you sure this is correct? If so, you might want to change this to $this->next().

		} while(parent::valid());

It seems like you call parent on a different method (valid() instead of rewind()). Are you sure this is correct? If so, you might want to change this to $this->valid().

		while($this->childCount > 0) {
			$status |= $this->wait();
		}
		if($status !== 0) {
			throw new UnexpectedValueException('Child exited with non zero status');
		}
	}

	public function valid()
	{
		if(!$this->isForkingEnabled()) {
			return parent::valid();
		}
		if(!$this->isChild) {
			return false;
		}
		return parent::valid();
	}

	public function next()
	{
		if(!$this->isForkingEnabled()) {
			return parent::next();
		}
		exit;
	}
}