@@ -1,12 +1,12 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Pipeline; |
| 11 | 11 | |
| 12 | 12 | use AsyncSockets\Event\TimeoutEvent; |
@@ -114,10 +114,10 @@ discard block |
||
| 114 | 114 | |
| 115 | 115 | return ($desiredTimeout !== RequestExecutorInterface::WAIT_FOREVER) && |
| 116 | 116 | ( |
| 117 | - ($hasConnected && $lastOperationTime !== null) || |
|
| 117 | + ($hasConnected && $lastOperationTime !== null) || |
|
| 118 | 118 | !$hasConnected |
| 119 | - ) && |
|
| 119 | + ) && |
|
| 120 | 120 | ($microTime - $lastOperationTime >= $desiredTimeout) |
| 121 | - ; |
|
| 121 | + ; |
|
| 122 | 122 | } |
| 123 | 123 | } |
@@ -1,12 +1,12 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Pipeline; |
| 11 | 11 | |
| 12 | 12 | use AsyncSockets\Event\DataAlertEvent; |
@@ -119,9 +119,9 @@ discard block |
||
| 119 | 119 | $operation = $descriptor->getOperation(); |
| 120 | 120 | return ($operation instanceof NullOperation) || |
| 121 | 121 | ( |
| 122 | - $operation instanceof ReadOperation && |
|
| 122 | + $operation instanceof ReadOperation && |
|
| 123 | 123 | $operation->getFramePicker() instanceof EmptyFramePicker |
| 124 | - ); |
|
| 124 | + ); |
|
| 125 | 125 | } |
| 126 | 126 | |
| 127 | 127 | /** |
@@ -1,12 +1,12 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Pipeline; |
| 11 | 11 | |
| 12 | 12 | use AsyncSockets\Event\EventType; |
@@ -136,13 +136,13 @@ discard block |
||
| 136 | 136 | private function isDisconnectRequired(SocketInterface $socket) |
| 137 | 137 | { |
| 138 | 138 | return ( |
| 139 | - ($socket instanceof PersistentClientSocket) && |
|
| 139 | + ($socket instanceof PersistentClientSocket) && |
|
| 140 | 140 | ( |
| 141 | - feof($socket->getStreamResource()) !== false || |
|
| 141 | + feof($socket->getStreamResource()) !== false || |
|
| 142 | 142 | !stream_socket_get_name($socket->getStreamResource(), true) |
| 143 | - ) |
|
| 144 | - ) || ( |
|
| 145 | - !($socket instanceof PersistentClientSocket) |
|
| 146 | - ); |
|
| 143 | + ) |
|
| 144 | + ) || ( |
|
| 145 | + !($socket instanceof PersistentClientSocket) |
|
| 146 | + ); |
|
| 147 | 147 | } |
| 148 | 148 | } |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |
@@ -1,12 +1,12 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Async sockets |
|
| 4 | - * |
|
| 5 | - * @copyright Copyright (c) 2015-2016, 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-2016, 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\Frame\FramePickerInterface; |