@@ -120,7 +120,7 @@ |
||
| 120 | 120 | * Routes incoming request to related application |
| 121 | 121 | * @param object $req Generic |
| 122 | 122 | * @param object $upstream AppInstance of Upstream |
| 123 | - * @param string $default App Default application name |
|
| 123 | + * @param string $defaultApp App Default application name |
|
| 124 | 124 | * @return object Request |
| 125 | 125 | */ |
| 126 | 126 | public function getRequest($req, $upstream, $defaultApp = null) { |
@@ -75,6 +75,9 @@ |
||
| 75 | 75 | } |
| 76 | 76 | } |
| 77 | 77 | |
| 78 | + /** |
|
| 79 | + * @param callable|null $cb |
|
| 80 | + */ |
|
| 78 | 81 | public static function addToArray(&$arr, $cb) { |
| 79 | 82 | if ($arr === null) { |
| 80 | 83 | $arr = []; |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | /** |
| 141 | 141 | * Sets a limit of simultaneously executing tasks |
| 142 | 142 | * @param integer $n Natural number or -1 (no limit) |
| 143 | - * @return this |
|
| 143 | + * @return ComplexJob |
|
| 144 | 144 | */ |
| 145 | 145 | public function maxConcurrency($n = -1) { |
| 146 | 146 | $this->maxConcurrency = $n; |
@@ -212,7 +212,7 @@ discard block |
||
| 212 | 212 | /** |
| 213 | 213 | * Sets a callback which is going to be fired always when we have a room for more jobs |
| 214 | 214 | * @param callable $cb Callback |
| 215 | - * @return this |
|
| 215 | + * @return ComplexJob|null |
|
| 216 | 216 | */ |
| 217 | 217 | public function more($cb = null) { |
| 218 | 218 | if ($cb !== null) { |
@@ -464,6 +464,7 @@ |
||
| 464 | 464 | /** |
| 465 | 465 | * Check file syntax via runkit_lint_file if supported or via php -l |
| 466 | 466 | * @param string File name |
| 467 | + * @param string $filename |
|
| 467 | 468 | * @return boolean |
| 468 | 469 | */ |
| 469 | 470 | public static function lintFile($filename) { |
@@ -58,7 +58,7 @@ |
||
| 58 | 58 | * Returns a proxy callback function with logging for debugging purposes |
| 59 | 59 | * @param callable $cb Callback |
| 60 | 60 | * @param mixed $name Data |
| 61 | - * @return callable |
|
| 61 | + * @return \Closure |
|
| 62 | 62 | */ |
| 63 | 63 | public static function proxy($cb, $name = null) { |
| 64 | 64 | static $i = 0; |
@@ -108,7 +108,7 @@ |
||
| 108 | 108 | |
| 109 | 109 | /** |
| 110 | 110 | * Reset |
| 111 | - * @return this |
|
| 111 | + * @return DeferredEvent |
|
| 112 | 112 | */ |
| 113 | 113 | public function reset() { |
| 114 | 114 | $this->state = self::STATE_WAITING; |
@@ -110,7 +110,7 @@ discard block |
||
| 110 | 110 | |
| 111 | 111 | /** |
| 112 | 112 | * Set group |
| 113 | - * @return this |
|
| 113 | + * @return ShellCommand |
|
| 114 | 114 | */ |
| 115 | 115 | public function setGroup($val) { |
| 116 | 116 | $this->setGroup = $val; |
@@ -120,7 +120,7 @@ discard block |
||
| 120 | 120 | /** |
| 121 | 121 | * Set cwd |
| 122 | 122 | * @param string $dir |
| 123 | - * @return this |
|
| 123 | + * @return ShellCommand |
|
| 124 | 124 | */ |
| 125 | 125 | public function setCwd($dir) { |
| 126 | 126 | $this->cwd = $dir; |
@@ -130,7 +130,7 @@ discard block |
||
| 130 | 130 | /** |
| 131 | 131 | * Set group |
| 132 | 132 | * @param string $val |
| 133 | - * @return this |
|
| 133 | + * @return ShellCommand |
|
| 134 | 134 | */ |
| 135 | 135 | public function setUser($val) { |
| 136 | 136 | $this->setUser = $val; |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | /** |
| 141 | 141 | * Set chroot |
| 142 | 142 | * @param string $dir |
| 143 | - * @return this |
|
| 143 | + * @return ShellCommand |
|
| 144 | 144 | */ |
| 145 | 145 | public function setChroot($dir) { |
| 146 | 146 | $this->chroot = $dir; |
@@ -215,7 +215,7 @@ discard block |
||
| 215 | 215 | /** |
| 216 | 216 | * Sets an array of arguments |
| 217 | 217 | * @param array Arguments |
| 218 | - * @return this |
|
| 218 | + * @return ShellCommand |
|
| 219 | 219 | */ |
| 220 | 220 | public function setArgs($args = NULL) { |
| 221 | 221 | $this->args = $args; |
@@ -226,7 +226,7 @@ discard block |
||
| 226 | 226 | /** |
| 227 | 227 | * Set a hash of environment's variables |
| 228 | 228 | * @param array Hash of environment's variables |
| 229 | - * @return this |
|
| 229 | + * @return ShellCommand |
|
| 230 | 230 | */ |
| 231 | 231 | public function setEnv($env = NULL) { |
| 232 | 232 | $this->env = $env; |
@@ -250,7 +250,7 @@ discard block |
||
| 250 | 250 | /** |
| 251 | 251 | * Set priority |
| 252 | 252 | * @param integer $nice Priority |
| 253 | - * @return this |
|
| 253 | + * @return ShellCommand |
|
| 254 | 254 | */ |
| 255 | 255 | public function nice($nice = NULL) { |
| 256 | 256 | $this->nice = $nice; |
@@ -260,7 +260,7 @@ discard block |
||
| 260 | 260 | |
| 261 | 261 | /** |
| 262 | 262 | * Called when new data received |
| 263 | - * @return this|null |
|
| 263 | + * @return ShellCommand|null |
|
| 264 | 264 | */ |
| 265 | 265 | protected function onRead() { |
| 266 | 266 | if (func_num_args() === 1) { |
@@ -302,7 +302,7 @@ discard block |
||
| 302 | 302 | * @param string $binPath Optional. Binpath |
| 303 | 303 | * @param array $args Optional. Arguments |
| 304 | 304 | * @param array $env Optional. Hash of environment's variables |
| 305 | - * @return this |
|
| 305 | + * @return ShellCommand |
|
| 306 | 306 | */ |
| 307 | 307 | public function execute($binPath = NULL, $args = NULL, $env = NULL) { |
| 308 | 308 | if ($binPath !== NULL) { |
@@ -397,7 +397,7 @@ discard block |
||
| 397 | 397 | |
| 398 | 398 | /** |
| 399 | 399 | * Close write stream |
| 400 | - * @return this |
|
| 400 | + * @return ShellCommand |
|
| 401 | 401 | */ |
| 402 | 402 | public function closeWrite() { |
| 403 | 403 | if ($this->bevWrite) { |
@@ -474,7 +474,7 @@ discard block |
||
| 474 | 474 | /** |
| 475 | 475 | * Sets callback which will be called once when got EOF |
| 476 | 476 | * @param callable $cb |
| 477 | - * @return this |
|
| 477 | + * @return ShellCommand |
|
| 478 | 478 | */ |
| 479 | 479 | public function onEOF($cb = NULL) { |
| 480 | 480 | $this->onEOF = CallbackWrapper::wrap($cb); |
@@ -100,7 +100,7 @@ |
||
| 100 | 100 | * @param integer $timeout Timeout |
| 101 | 101 | * @param integer|string $id Timer ID |
| 102 | 102 | * @param integer $priority Priority |
| 103 | - * @return integer|string Timer ID |
|
| 103 | + * @return integer|null Timer ID |
|
| 104 | 104 | */ |
| 105 | 105 | public static function add($cb, $timeout = null, $id = null, $priority = null) { |
| 106 | 106 | $obj = new self($cb, $timeout, $id, $priority); |
@@ -97,7 +97,7 @@ discard block |
||
| 97 | 97 | * Converts string of flags to integer or standard text representation |
| 98 | 98 | * @param string $mode Mode |
| 99 | 99 | * @param boolean $text Text? |
| 100 | - * @return mixed |
|
| 100 | + * @return string |
|
| 101 | 101 | */ |
| 102 | 102 | public static function convertFlags($mode, $text = false) { |
| 103 | 103 | $plus = strpos($mode, '+') !== false; |
@@ -540,7 +540,10 @@ discard block |
||
| 540 | 540 | * @param integer &$offset |
| 541 | 541 | * @param integer &$pri |
| 542 | 542 | * @param string &$buf |
| 543 | - * @return callable |
|
| 543 | + * @param integer $offset |
|
| 544 | + * @param integer $pri |
|
| 545 | + * @param string $buf |
|
| 546 | + * @return \Closure |
|
| 544 | 547 | */ |
| 545 | 548 | protected function readAllGenHandler($cb, $size, &$offset, &$pri, &$buf) { |
| 546 | 549 | return function ($file, $data) use ($cb, $size, &$offset, &$pri, &$buf) { |
@@ -593,7 +596,7 @@ discard block |
||
| 593 | 596 | * @param integer $size |
| 594 | 597 | * @param integer $offset |
| 595 | 598 | * @param integer $pri |
| 596 | - * @return callable |
|
| 599 | + * @return \Closure |
|
| 597 | 600 | */ |
| 598 | 601 | protected function readAllChunkedGenHandler($cb, $chunkcb, $size, &$offset, $pri) { |
| 599 | 602 | return function ($file, $data) use ($cb, $chunkcb, $size, &$offset, $pri) { |