@@ -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 | { |