@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket\Io; |
11 | 11 | |
12 | 12 | use AsyncSockets\Exception\NetworkSocketException; |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket\Io; |
11 | 11 | |
12 | 12 | use AsyncSockets\Frame\FramePickerInterface; |
@@ -64,9 +64,8 @@ |
||
64 | 64 | private function resolveReadAttempts(array $context, $currentAttempts) |
65 | 65 | { |
66 | 66 | return ($context['countCycles'] === 1 && $context['dataBeforeIo'] === false) || |
67 | - ($context['countCycles'] > 1 && $context['isStreamDataEmpty']) ? |
|
68 | - $currentAttempts - 1 : |
|
69 | - self::READ_ATTEMPTS; |
|
67 | + ($context['countCycles'] > 1 && $context['isStreamDataEmpty']) ? |
|
68 | + $currentAttempts - 1 : self::READ_ATTEMPTS; |
|
70 | 69 | |
71 | 70 | } |
72 | 71 |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket\Io; |
11 | 11 | |
12 | 12 | use AsyncSockets\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket\Io; |
11 | 11 | |
12 | 12 | use AsyncSockets\Exception\ConnectionException; |
@@ -143,8 +143,7 @@ |
||
143 | 143 | $resource = $this->socket->getStreamResource(); |
144 | 144 | if (!is_resource($resource)) { |
145 | 145 | $message = $this->state === self::STATE_CONNECTED ? |
146 | - 'Connection was unexpectedly closed.' : |
|
147 | - 'Can not start io operation on uninitialized socket.'; |
|
146 | + 'Connection was unexpectedly closed.' : 'Can not start io operation on uninitialized socket.'; |
|
148 | 147 | throw new ConnectionException($this->socket, $message); |
149 | 148 | } |
150 | 149 |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket\Io; |
11 | 11 | |
12 | 12 | use AsyncSockets\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | |
11 | 11 | namespace AsyncSockets\Socket; |
12 | 12 |
@@ -184,7 +184,7 @@ |
||
184 | 184 | 'unix' => self::SOCKET_TYPE_UNIX, |
185 | 185 | ]; |
186 | 186 | |
187 | - $regexp = '#^('. implode('|', array_keys($map)) . ')_socket$#'; |
|
187 | + $regexp = '#^(' . implode('|', array_keys($map)) . ')_socket$#'; |
|
188 | 188 | foreach ($parts as $part) { |
189 | 189 | if (preg_match($regexp, $part, $pockets)) { |
190 | 190 | return $map[$pockets[1]]; |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Socket; |
11 | 11 | |
12 | 12 | use AsyncSockets\Exception\NetworkSocketException; |
@@ -68,9 +68,8 @@ |
||
68 | 68 | 'udg' => 1, |
69 | 69 | ]; |
70 | 70 | |
71 | - return isset($connectionLessMap[ $scheme ]) ? |
|
72 | - STREAM_SERVER_BIND : |
|
73 | - STREAM_SERVER_BIND | STREAM_SERVER_LISTEN; |
|
71 | + return isset($connectionLessMap[$scheme]) ? |
|
72 | + STREAM_SERVER_BIND : STREAM_SERVER_BIND | STREAM_SERVER_LISTEN; |
|
74 | 73 | } |
75 | 74 | |
76 | 75 | /** {@inheritdoc} */ |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\Configuration; |
11 | 11 | |
12 | 12 | /** |
@@ -50,9 +50,9 @@ discard block |
||
50 | 50 | { |
51 | 51 | $options = $options + $this->getDefaultOptions(); |
52 | 52 | |
53 | - $this->connectTimeout = (double) $options[ 'connectTimeout' ]; |
|
54 | - $this->ioTimeout = (double) $options[ 'ioTimeout' ]; |
|
55 | - $this->preferredEngines = (array) $options[ 'preferredEngines' ]; |
|
53 | + $this->connectTimeout = (double) $options['connectTimeout']; |
|
54 | + $this->ioTimeout = (double) $options['ioTimeout']; |
|
55 | + $this->preferredEngines = (array) $options['preferredEngines']; |
|
56 | 56 | } |
57 | 57 | |
58 | 58 | /** |
@@ -95,9 +95,9 @@ discard block |
||
95 | 95 | $result = []; |
96 | 96 | $socketTimeout = (double) ini_get('default_socket_timeout'); |
97 | 97 | |
98 | - $result[ 'connectTimeout' ] = $socketTimeout; |
|
99 | - $result[ 'ioTimeout' ] = $socketTimeout; |
|
100 | - $result[ 'preferredEngines' ] = [ 'libevent', 'native' ]; |
|
98 | + $result['connectTimeout'] = $socketTimeout; |
|
99 | + $result['ioTimeout'] = $socketTimeout; |
|
100 | + $result['preferredEngines'] = ['libevent', 'native']; |
|
101 | 101 | |
102 | 102 | return $result; |
103 | 103 | } |
@@ -1,12 +1,12 @@ |
||
1 | 1 | <?php |
2 | 2 | /** |
3 | - * Async sockets |
|
4 | - * |
|
5 | - * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | - * |
|
7 | - * This source file is subject to the MIT license that is bundled |
|
8 | - * with this source code in the file LICENSE. |
|
9 | - */ |
|
3 | + * Async sockets |
|
4 | + * |
|
5 | + * @copyright Copyright (c) 2015, Efimov Evgenij <[email protected]> |
|
6 | + * |
|
7 | + * This source file is subject to the MIT license that is bundled |
|
8 | + * with this source code in the file LICENSE. |
|
9 | + */ |
|
10 | 10 | namespace AsyncSockets\RequestExecutor; |
11 | 11 | |
12 | 12 | use AsyncSockets\Socket\SocketInterface; |