@@ -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 |