@@ -21,10 +21,10 @@ |
||
| 21 | 21 | const HEADER_HTTP1_1 = 'HTTP/1.1 101 Web Socket Protocol Handshake'; |
| 22 | 22 | const HEADER_WEBSOCKET_ACCEPT_HASH = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'; |
| 23 | 23 | const HEADERS_UPGRADE_KEY = 'Upgrade', |
| 24 | - HEADERS_CONNECTION_KEY = 'Connection', |
|
| 25 | - HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
| 24 | + HEADERS_CONNECTION_KEY = 'Connection', |
|
| 25 | + HEADERS_SEC_WEBSOCKET_ACCEPT_KEY = 'Sec-WebSocket-Accept'; |
|
| 26 | 26 | const HEADERS_UPGRADE_VALUE = 'websocket', |
| 27 | - HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
| 27 | + HEADERS_CONNECTION_VALUE = 'Upgrade'; |
|
| 28 | 28 | const HEADERS_EOL = "\r\n"; |
| 29 | 29 | const SEC_WEBSOCKET_KEY_PTRN = '/Sec-WebSocket-Key:\s(.*)\n/'; |
| 30 | 30 | |
@@ -70,7 +70,7 @@ |
||
| 70 | 70 | $server = stream_socket_server("tcp://{$this->config->getHost()}:{$this->config->getPort()}", $errno, $errorMessage); |
| 71 | 71 | |
| 72 | 72 | if ($server === false) { |
| 73 | - throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET); |
|
| 73 | + throw new WebSocketException('Could not bind to socket: ' . $errno . ' - ' . $errorMessage . PHP_EOL, CommonsContract::SERVER_COULD_NOT_BIND_TO_SOCKET); |
|
| 74 | 74 | } |
| 75 | 75 | |
| 76 | 76 | @cli_set_process_title(self::PROC_TITLE); |
@@ -184,10 +184,10 @@ |
||
| 184 | 184 | } |
| 185 | 185 | |
| 186 | 186 | /** |
| 187 | - * @param $final |
|
| 188 | - * @param $payload |
|
| 189 | - * @param $opcode |
|
| 190 | - * @param $masked |
|
| 187 | + * @param boolean $final |
|
| 188 | + * @param string $payload |
|
| 189 | + * @param string $opcode |
|
| 190 | + * @param boolean $masked |
|
| 191 | 191 | * @throws ConnectionException |
| 192 | 192 | * @throws \Exception |
| 193 | 193 | */ |
@@ -108,7 +108,7 @@ discard block |
||
| 108 | 108 | } |
| 109 | 109 | |
| 110 | 110 | /** |
| 111 | - * @return mixed|resource |
|
| 111 | + * @return resource|null |
|
| 112 | 112 | * @throws \InvalidArgumentException |
| 113 | 113 | */ |
| 114 | 114 | private function getStreamContext() |
@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | /** |
| 208 | 208 | * Sends message to opened socket connection client->server |
| 209 | 209 | * |
| 210 | - * @param $payload |
|
| 210 | + * @param string $payload |
|
| 211 | 211 | * @param string $opcode |
| 212 | 212 | * @throws \InvalidArgumentException |
| 213 | 213 | * @throws BadOpcodeException |
@@ -277,7 +277,7 @@ discard block |
||
| 277 | 277 | * |
| 278 | 278 | * @param integer $status http://tools.ietf.org/html/rfc6455#section-7.4 |
| 279 | 279 | * @param string $message A closing message, max 125 bytes. |
| 280 | - * @return bool|null|string |
|
| 280 | + * @return null|string |
|
| 281 | 281 | * @throws \InvalidArgumentException |
| 282 | 282 | * @throws BadOpcodeException |
| 283 | 283 | * @throws BadUriException |