@@ -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 | */ |
@@ -59,6 +59,7 @@ discard block |
||
| 59 | 59 | |
| 60 | 60 | /** |
| 61 | 61 | * @param int $ownerPid |
| 62 | + * @param \Ackintosh\Snidel\Log $log |
|
| 62 | 63 | */ |
| 63 | 64 | public function __construct($ownerPid, $log, $concurrency = 5) |
| 64 | 65 | { |
@@ -74,6 +75,7 @@ discard block |
||
| 74 | 75 | |
| 75 | 76 | /** |
| 76 | 77 | * @param \Ackintosh\Snidel\Task |
| 78 | + * @param \Ackintosh\Snidel\Task\Task $task |
|
| 77 | 79 | * @return void |
| 78 | 80 | * @throws \RuntimeException |
| 79 | 81 | */ |
@@ -95,7 +97,7 @@ discard block |
||
| 95 | 97 | } |
| 96 | 98 | |
| 97 | 99 | /** |
| 98 | - * @return \Ackintosh\Snidel\Fork\Fork |
|
| 100 | + * @return Result |
|
| 99 | 101 | */ |
| 100 | 102 | private function dequeue() |
| 101 | 103 | { |
@@ -345,7 +347,7 @@ discard block |
||
| 345 | 347 | } |
| 346 | 348 | |
| 347 | 349 | /** |
| 348 | - * @return array |
|
| 350 | + * @return Fork[] |
|
| 349 | 351 | */ |
| 350 | 352 | public function getChildren() |
| 351 | 353 | { |
@@ -356,13 +358,16 @@ discard block |
||
| 356 | 358 | * return fork |
| 357 | 359 | * |
| 358 | 360 | * @param int $pid |
| 359 | - * @return \Ackintosh\Snidel\Fork\Fork |
|
| 361 | + * @return Result |
|
| 360 | 362 | */ |
| 361 | 363 | public function get($pid) |
| 362 | 364 | { |
| 363 | 365 | return $this->results[$pid]; |
| 364 | 366 | } |
| 365 | 367 | |
| 368 | + /** |
|
| 369 | + * @param string $tag |
|
| 370 | + */ |
|
| 366 | 371 | public function getCollection($tag = null) |
| 367 | 372 | { |
| 368 | 373 | if ($tag === null) { |
@@ -405,7 +410,7 @@ discard block |
||
| 405 | 410 | } |
| 406 | 411 | |
| 407 | 412 | /** |
| 408 | - * @return \Ackintosh\Sniden\Error |
|
| 413 | + * @return Error |
|
| 409 | 414 | */ |
| 410 | 415 | public function getError() |
| 411 | 416 | { |