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