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