@@ -54,6 +54,7 @@ discard block |
||
54 | 54 | |
55 | 55 | /** |
56 | 56 | * @param int $ownerPid |
57 | + * @param 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 Task\Task $task |
|
72 | 74 | * @return void |
73 | 75 | * @throws \RuntimeException |
74 | 76 | */ |
@@ -303,7 +305,7 @@ discard block |
||
303 | 305 | } |
304 | 306 | |
305 | 307 | /** |
306 | - * @return array |
|
308 | + * @return integer[] |
|
307 | 309 | */ |
308 | 310 | public function getChildPids() |
309 | 311 | { |
@@ -314,13 +316,16 @@ discard block |
||
314 | 316 | * return fork |
315 | 317 | * |
316 | 318 | * @param int $pid |
317 | - * @return \Ackintosh\Snidel\Fork |
|
319 | + * @return Result |
|
318 | 320 | */ |
319 | 321 | public function get($pid) |
320 | 322 | { |
321 | 323 | return $this->results[$pid]; |
322 | 324 | } |
323 | 325 | |
326 | + /** |
|
327 | + * @param string $tag |
|
328 | + */ |
|
324 | 329 | public function getCollection($tag = null) |
325 | 330 | { |
326 | 331 | if ($tag === null) { |
@@ -363,7 +368,7 @@ discard block |
||
363 | 368 | } |
364 | 369 | |
365 | 370 | /** |
366 | - * @return \Ackintosh\Sniden\Error |
|
371 | + * @return Error |
|
367 | 372 | */ |
368 | 373 | public function getError() |
369 | 374 | { |
@@ -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 | { |