@@ -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 | */ |
@@ -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 | */ |
@@ -90,7 +92,7 @@ discard block |
||
90 | 92 | } |
91 | 93 | |
92 | 94 | /** |
93 | - * @return \Ackintosh\Snidel\Fork\Fork |
|
95 | + * @return Result |
|
94 | 96 | */ |
95 | 97 | private function dequeue() |
96 | 98 | { |
@@ -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 | { |