@@ -24,7 +24,6 @@ discard block |
||
| 24 | 24 | /** |
| 25 | 25 | * @param string $filename fifo filename |
| 26 | 26 | * @param int $mode |
| 27 | - * @param bool $block if blocking |
|
| 28 | 27 | */ |
| 29 | 28 | public function __construct($filename = '/tmp/simple-fork.pipe', $mode = 0666) |
| 30 | 29 | { |
@@ -55,7 +54,7 @@ discard block |
||
| 55 | 54 | * get value from the queue of channel |
| 56 | 55 | * |
| 57 | 56 | * @param bool $block if block when the queue is empty |
| 58 | - * @return bool|string |
|
| 57 | + * @return null|string |
|
| 59 | 58 | */ |
| 60 | 59 | public function get($block = false) |
| 61 | 60 | { |
@@ -94,7 +93,7 @@ discard block |
||
| 94 | 93 | /** |
| 95 | 94 | * remove the queue resource |
| 96 | 95 | * |
| 97 | - * @return bool |
|
| 96 | + * @return boolean|null |
|
| 98 | 97 | */ |
| 99 | 98 | public function remove() |
| 100 | 99 | { |
@@ -49,9 +49,9 @@ discard block |
||
| 49 | 49 | /** |
| 50 | 50 | * 添加或覆盖一个key |
| 51 | 51 | * @param string $key |
| 52 | - * @param mixed $value |
|
| 52 | + * @param integer $value |
|
| 53 | 53 | * @param int $expire expire time in seconds |
| 54 | - * @return mixed |
|
| 54 | + * @return boolean |
|
| 55 | 55 | */ |
| 56 | 56 | public function set($key, $value, $expire = 0) |
| 57 | 57 | { |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | /** |
| 84 | 84 | * 创建缓存文件 |
| 85 | 85 | * @param $key |
| 86 | - * @return bool|string |
|
| 86 | + * @return false|string |
|
| 87 | 87 | */ |
| 88 | 88 | private function createCacheFile($key) |
| 89 | 89 | { |
@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | /** |
| 105 | 105 | * 判断Key是否存在 |
| 106 | 106 | * @param $key |
| 107 | - * @return mixed |
|
| 107 | + * @return boolean |
|
| 108 | 108 | */ |
| 109 | 109 | public function has($key) |
| 110 | 110 | { |
@@ -185,7 +185,7 @@ discard block |
||
| 185 | 185 | |
| 186 | 186 | /** |
| 187 | 187 | * 清楚所有缓存 |
| 188 | - * @return mixed |
|
| 188 | + * @return boolean |
|
| 189 | 189 | */ |
| 190 | 190 | public function flush() |
| 191 | 191 | { |
@@ -194,7 +194,7 @@ discard block |
||
| 194 | 194 | |
| 195 | 195 | /** |
| 196 | 196 | * 递归删除目录 |
| 197 | - * @param $dir |
|
| 197 | + * @param string $dir |
|
| 198 | 198 | * @return bool |
| 199 | 199 | */ |
| 200 | 200 | function delTree($dir) |
@@ -121,7 +121,7 @@ discard block |
||
| 121 | 121 | * get or set name |
| 122 | 122 | * |
| 123 | 123 | * @param string|null $name |
| 124 | - * @return mixed |
|
| 124 | + * @return null|string |
|
| 125 | 125 | */ |
| 126 | 126 | public function name($name = null) |
| 127 | 127 | { |
@@ -300,7 +300,7 @@ discard block |
||
| 300 | 300 | /** |
| 301 | 301 | * kill self |
| 302 | 302 | * |
| 303 | - * @param bool|true $block |
|
| 303 | + * @param boolean $block |
|
| 304 | 304 | * @param int $signal |
| 305 | 305 | */ |
| 306 | 306 | public function shutdown($block = true, $signal = SIGTERM) |
@@ -322,7 +322,7 @@ discard block |
||
| 322 | 322 | /** |
| 323 | 323 | * waiting for the sub process exit |
| 324 | 324 | * |
| 325 | - * @param bool|true $block if block the process |
|
| 325 | + * @param boolean $block if block the process |
|
| 326 | 326 | * @param int $sleep default 0.1s check sub process status |
| 327 | 327 | * every $sleep milliseconds. |
| 328 | 328 | */ |
@@ -88,8 +88,8 @@ discard block |
||
| 88 | 88 | /** |
| 89 | 89 | * init queue |
| 90 | 90 | * |
| 91 | - * @param $ipc_filename |
|
| 92 | - * @param $msg_type |
|
| 91 | + * @param string $ipc_filename |
|
| 92 | + * @param integer $msg_type |
|
| 93 | 93 | * @throws \Exception |
| 94 | 94 | */ |
| 95 | 95 | protected function initQueue($ipc_filename, $msg_type) |
@@ -223,7 +223,7 @@ discard block |
||
| 223 | 223 | /** |
| 224 | 224 | * check the privilege of update the queue's status |
| 225 | 225 | * |
| 226 | - * @param $key |
|
| 226 | + * @param string $key |
|
| 227 | 227 | * @throws \Exception |
| 228 | 228 | */ |
| 229 | 229 | private function checkSetPrivilege($key) |
@@ -241,7 +241,7 @@ discard block |
||
| 241 | 241 | * update the max size of queue |
| 242 | 242 | * need root |
| 243 | 243 | * |
| 244 | - * @param $size |
|
| 244 | + * @param integer $size |
|
| 245 | 245 | * @throws \Exception |
| 246 | 246 | * @return bool |
| 247 | 247 | */ |