| @@ -50,15 +50,15 @@ | ||
| 50 | 50 | } | 
| 51 | 51 | $pid = getmypid(); | 
| 52 | 52 |          switch (true) { | 
| 53 | - case $this->ownerPid === $pid: | |
| 54 | - $role = 'owner'; | |
| 55 | - break; | |
| 56 | - case $this->masterPid === $pid: | |
| 57 | - $role = 'master'; | |
| 58 | - break; | |
| 59 | - default: | |
| 60 | - $role = 'worker'; | |
| 61 | - break; | |
| 53 | + case $this->ownerPid === $pid: | |
| 54 | + $role = 'owner'; | |
| 55 | + break; | |
| 56 | + case $this->masterPid === $pid: | |
| 57 | + $role = 'master'; | |
| 58 | + break; | |
| 59 | + default: | |
| 60 | + $role = 'worker'; | |
| 61 | + break; | |
| 62 | 62 | } | 
| 63 | 63 | fputs( | 
| 64 | 64 | $this->destination, | 
| @@ -126,7 +126,7 @@ discard block | ||
| 126 | 126 | * @param mixed $args | 
| 127 | 127 | * @param string $tag | 
| 128 | 128 | * @param \Ackintosh\Snidel\Token $token | 
| 129 | - * @return void | |
| 129 | + * @return null|integer | |
| 130 | 130 | * @throws \RuntimeException | 
| 131 | 131 | */ | 
| 132 | 132 | private function forkChild(Token $token, $callable, $args = array(), $tag = null) | 
| @@ -313,6 +313,7 @@ discard block | ||
| 313 | 313 | * fork the first processing of the map container | 
| 314 | 314 | * | 
| 315 | 315 | * @param \Ackintosh\Snidel\MapContainer | 
| 316 | + * @param Token $token | |
| 316 | 317 | * @return void | 
| 317 | 318 | * @throws \RuntimeException | 
| 318 | 319 | */ | 
| @@ -19,7 +19,6 @@ discard block | ||
| 19 | 19 | /** | 
| 20 | 20 | * @param callable $callable | 
| 21 | 21 | * @param array $args | 
| 22 | - * @param string $string | |
| 23 | 22 | */ | 
| 24 | 23 | public function __construct($callable, $args, $tag) | 
| 25 | 24 |      { | 
| @@ -45,7 +44,7 @@ discard block | ||
| 45 | 44 | } | 
| 46 | 45 | |
| 47 | 46 | /** | 
| 48 | - * @return string|null | |
| 47 | + * @return string | |
| 49 | 48 | */ | 
| 50 | 49 | public function getTag() | 
| 51 | 50 |      { | 
| @@ -53,7 +52,7 @@ discard block | ||
| 53 | 52 | } | 
| 54 | 53 | |
| 55 | 54 | /** | 
| 56 | - * @return Ackintosh\Snidel\Result\Result | |
| 55 | + * @return Result | |
| 57 | 56 | */ | 
| 58 | 57 | public function execute() | 
| 59 | 58 |      { | 
| @@ -54,6 +54,7 @@ discard block | ||
| 54 | 54 | |
| 55 | 55 | /** | 
| 56 | 56 | * @param int $ownerPid | 
| 57 | + * @param \Ackintosh\Snidel\Log $log | |
| 57 | 58 | */ | 
| 58 | 59 | public function __construct($ownerPid, $log, $concurrency = 5) | 
| 59 | 60 |      { | 
| @@ -69,6 +70,7 @@ discard block | ||
| 69 | 70 | |
| 70 | 71 | /** | 
| 71 | 72 | * @param \Ackintosh\Snidel\Task | 
| 73 | + * @param \Ackintosh\Snidel\Task\Task $task | |
| 72 | 74 | * @return void | 
| 73 | 75 | * @throws \RuntimeException | 
| 74 | 76 | */ | 
| @@ -304,7 +306,7 @@ discard block | ||
| 304 | 306 | } | 
| 305 | 307 | |
| 306 | 308 | /** | 
| 307 | - * @return array | |
| 309 | + * @return integer[] | |
| 308 | 310 | */ | 
| 309 | 311 | public function getChildPids() | 
| 310 | 312 |      { | 
| @@ -315,13 +317,16 @@ discard block | ||
| 315 | 317 | * return fork | 
| 316 | 318 | * | 
| 317 | 319 | * @param int $pid | 
| 318 | - * @return \Ackintosh\Snidel\Fork\Fork | |
| 320 | + * @return Result | |
| 319 | 321 | */ | 
| 320 | 322 | public function get($pid) | 
| 321 | 323 |      { | 
| 322 | 324 | return $this->results[$pid]; | 
| 323 | 325 | } | 
| 324 | 326 | |
| 327 | + /** | |
| 328 | + * @param string $tag | |
| 329 | + */ | |
| 325 | 330 | public function getCollection($tag = null) | 
| 326 | 331 |      { | 
| 327 | 332 |          if ($tag === null) { | 
| @@ -364,7 +369,7 @@ discard block | ||
| 364 | 369 | } | 
| 365 | 370 | |
| 366 | 371 | /** | 
| 367 | - * @return \Ackintosh\Sniden\Error | |
| 372 | + * @return Error | |
| 368 | 373 | */ | 
| 369 | 374 | public function getError() | 
| 370 | 375 |      { |