@@ -69,7 +69,7 @@ |
||
69 | 69 | /** |
70 | 70 | * Let's check the password |
71 | 71 | * @param string Password |
72 | - * @return boolean |
|
72 | + * @return boolean|null |
|
73 | 73 | */ |
74 | 74 | private function checkPassword($pass = '') { |
75 | 75 | if ($pass != $this->pool->config->passphrase->value) { |
@@ -152,6 +152,11 @@ |
||
152 | 152 | } |
153 | 153 | }); |
154 | 154 | } |
155 | + |
|
156 | + /** |
|
157 | + * @param string $hostname |
|
158 | + * @param Closure $cb |
|
159 | + */ |
|
155 | 160 | public function get($hostname, $cb, $noncache = false) { |
156 | 161 | if (!$this->preloading->hasCompleted()) { |
157 | 162 | $pool = $this; |
@@ -114,6 +114,9 @@ |
||
114 | 114 | "\xc5\xb8" => "\x9f" |
115 | 115 | ); |
116 | 116 | |
117 | + /** |
|
118 | + * @param string $text |
|
119 | + */ |
|
117 | 120 | static function toUTF8($text){ |
118 | 121 | /** |
119 | 122 | * Function Encoding::toUTF8 |
@@ -253,7 +253,7 @@ discard block |
||
253 | 253 | * Handles the output from downstream requests. |
254 | 254 | * @param object Request. |
255 | 255 | * @param string The output. |
256 | - * @return void |
|
256 | + * @return boolean |
|
257 | 257 | */ |
258 | 258 | public function requestOut($req, $output) { |
259 | 259 | $outlen = strlen($output); |
@@ -331,6 +331,9 @@ discard block |
||
331 | 331 | } |
332 | 332 | /** |
333 | 333 | * Handles the output from downstream requests. |
334 | + * @param stdClass $req |
|
335 | + * @param integer $appStatus |
|
336 | + * @param integer $protoStatus |
|
334 | 337 | * @return void |
335 | 338 | */ |
336 | 339 | public function endRequest($req, $appStatus, $protoStatus) { |
@@ -15,6 +15,9 @@ discard block |
||
15 | 15 | public $append; |
16 | 16 | public $path; |
17 | 17 | |
18 | + /** |
|
19 | + * @return string |
|
20 | + */ |
|
18 | 21 | public static function convertFlags($mode, $text = false) { |
19 | 22 | $plus = strpos($mode, '+') !== false; |
20 | 23 | $sync = strpos($mode, 's') !== false; |
@@ -55,6 +58,9 @@ discard block |
||
55 | 58 | eio_ftruncate($this->fd, $offset, $pri, $cb, $this); |
56 | 59 | } |
57 | 60 | |
61 | + /** |
|
62 | + * @param Closure $cb |
|
63 | + */ |
|
58 | 64 | public function stat($cb, $pri = EIO_PRI_DEFAULT) { |
59 | 65 | if (!$this->fd || $this->fd === -1) { |
60 | 66 | if ($cb) { |
@@ -77,6 +83,9 @@ discard block |
||
77 | 83 | } |
78 | 84 | } |
79 | 85 | |
86 | + /** |
|
87 | + * @param Closure $cb |
|
88 | + */ |
|
80 | 89 | public function statRefresh($cb, $pri = EIO_PRI_DEFAULT) { |
81 | 90 | if (!$this->fd || $this->fd === -1) { |
82 | 91 | if ($cb) { |
@@ -86,6 +86,10 @@ discard block |
||
86 | 86 | return $stat; |
87 | 87 | |
88 | 88 | } |
89 | + |
|
90 | + /** |
|
91 | + * @param Closure $cb |
|
92 | + */ |
|
89 | 93 | public static function stat($path, $cb, $pri = EIO_PRI_DEFAULT) { |
90 | 94 | if (!self::$supported) { |
91 | 95 | call_user_func($cb, $path, FS::statPrepare(@stat($path))); |
@@ -182,6 +186,10 @@ discard block |
||
182 | 186 | return eio_mkdir($path, $mode, $pri, $cb, $path); |
183 | 187 | } |
184 | 188 | |
189 | + /** |
|
190 | + * @param string $path |
|
191 | + * @param Closure $cb |
|
192 | + */ |
|
185 | 193 | public static function readdir($path, $cb = null, $flags, $pri = EIO_PRI_DEFAULT) { |
186 | 194 | if (!FS::$supported) { |
187 | 195 | $r = glob($path); |
@@ -233,6 +241,9 @@ discard block |
||
233 | 241 | return eio_chown($path, $uid, $gid, $pri, $cb, $path); |
234 | 242 | } |
235 | 243 | |
244 | + /** |
|
245 | + * @param Closure $cb |
|
246 | + */ |
|
236 | 247 | public static function readfile($path, $cb, $pri = EIO_PRI_DEFAULT) { |
237 | 248 | if (!FS::$supported) { |
238 | 249 | call_user_func($cb, $path, file_get_contents($path)); |
@@ -247,6 +258,9 @@ discard block |
||
247 | 258 | }, null, $pri); |
248 | 259 | } |
249 | 260 | |
261 | + /** |
|
262 | + * @param Closure $chunkcb |
|
263 | + */ |
|
250 | 264 | public static function readfileChunked($path, $cb, $chunkcb, $pri = EIO_PRI_DEFAULT) { |
251 | 265 | if (!FS::$supported) { |
252 | 266 | call_user_func($chunkcb, $path, $r = readfile($path)); |
@@ -266,6 +280,10 @@ discard block |
||
266 | 280 | return tempnam($dir, $prefix); |
267 | 281 | } |
268 | 282 | |
283 | + /** |
|
284 | + * @param string $flags |
|
285 | + * @param Closure $cb |
|
286 | + */ |
|
269 | 287 | public static function open($path, $flags, $cb, $mode = null, $pri = EIO_PRI_DEFAULT) { |
270 | 288 | if (self::$supported) { |
271 | 289 | $fdCacheKey = $path . "\x00" . $flags; |
@@ -38,7 +38,7 @@ |
||
38 | 38 | * Creates Request. |
39 | 39 | * @param object Request. |
40 | 40 | * @param object Upstream application instance. |
41 | - * @return object Request. |
|
41 | + * @return GameMonitorHTTPRequest Request. |
|
42 | 42 | */ |
43 | 43 | public function beginRequest($req, $upstream) { |
44 | 44 | return new GameMonitorHTTPRequest($this, $upstream, $req); |
@@ -105,6 +105,9 @@ discard block |
||
105 | 105 | $this->parseParams(); |
106 | 106 | } |
107 | 107 | |
108 | + /** |
|
109 | + * @param Closure $cb |
|
110 | + */ |
|
108 | 111 | public function sendfile($path, $cb, $pri = EIO_PRI_DEFAULT) { |
109 | 112 | $req = $this; |
110 | 113 | if ($req->state === self::STATE_FINISHED) { |
@@ -122,6 +125,10 @@ discard block |
||
122 | 125 | } |
123 | 126 | $first = true; |
124 | 127 | FS::readfileChunked($path, $cb, |
128 | + |
|
129 | + /** |
|
130 | + * @param Closure $chunk |
|
131 | + */ |
|
125 | 132 | function($file, $chunk) use ($req, &$first) { // readed chunk |
126 | 133 | if ($first) { |
127 | 134 | try { |
@@ -137,7 +144,7 @@ discard block |
||
137 | 144 | /** |
138 | 145 | * Called by call() to check if ready |
139 | 146 | * @todo protected? |
140 | - * @return void |
|
147 | + * @return boolean |
|
141 | 148 | */ |
142 | 149 | public function checkIfReady() { |
143 | 150 | if ( |
@@ -484,7 +491,7 @@ discard block |
||
484 | 491 | * Send HTTP-status |
485 | 492 | * @throws RequestHeadersAlreadySent |
486 | 493 | * @param int Code |
487 | - * @return void |
|
494 | + * @return boolean |
|
488 | 495 | */ |
489 | 496 | public function status($code = 200) { |
490 | 497 | if (!isset(self::$codes[$code])) { |
@@ -522,6 +529,7 @@ discard block |
||
522 | 529 | * @param string. Optional. Path. Default is empty string. |
523 | 530 | * @param boolean. Optional. Secure. Default is false. |
524 | 531 | * @param boolean. Optional. HTTPOnly. Default is false. |
532 | + * @param string $name |
|
525 | 533 | * @return void |
526 | 534 | * @throws RequestHeadersAlreadySent |
527 | 535 | */ |
@@ -607,6 +615,7 @@ discard block |
||
607 | 615 | |
608 | 616 | /** |
609 | 617 | * @todo description missing |
618 | + * @param string $value |
|
610 | 619 | */ |
611 | 620 | public function parseSize($value) { |
612 | 621 | $l = strtolower(substr($value, -1)); |
@@ -873,7 +882,7 @@ discard block |
||
873 | 882 | |
874 | 883 | /** |
875 | 884 | * Read request body from the file given in REQUEST_BODY_FILE parameter. |
876 | - * @return void |
|
885 | + * @return false|null |
|
877 | 886 | */ |
878 | 887 | public function readBodyFile() { |
879 | 888 | if (!isset($this->attrs->server['REQUEST_BODY_FILE'])) { |
@@ -228,7 +228,10 @@ |
||
228 | 228 | |
229 | 229 | /** |
230 | 230 | * Handles the output from downstream requests. |
231 | - * @return boolean Succcess. |
|
231 | + * @param stdClass $req |
|
232 | + * @param integer $appStatus |
|
233 | + * @param integer $protoStatus |
|
234 | + * @return boolean|null Succcess. |
|
232 | 235 | */ |
233 | 236 | public function endRequest($req, $appStatus, $protoStatus) { |
234 | 237 | if ($protoStatus === -1) { |