edefimov / async-sockets

src/RequestExecutor/Pipeline/IoStage.php

Spacing +1 added lines, -1 removed lines

@@ -155,7 +155,7 @@
     private function setConnectionFinishTime(OperationMetadata $operationMetadata)
     {
         $meta         = $operationMetadata->getMetadata();
-        $wasConnected = $meta[ RequestExecutorInterface::META_CONNECTION_FINISH_TIME ] !== null;
+        $wasConnected = $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null;
         $this->setSocketOperationTime($operationMetadata, RequestExecutorInterface::META_CONNECTION_FINISH_TIME);
         if (!$wasConnected) {
             $event = $this->createEvent($operationMetadata, EventType::CONNECTED);

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/ConnectStage.php

Spacing +4 added lines, -4 removed lines

@@ -105,13 +105,13 @@ 
      */
     private function getStreamContextFromMetaData($meta)
     {
-        $metaStreamContext = $meta[ RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT ];
+        $metaStreamContext = $meta[RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT];
         if (is_resource($metaStreamContext)) {
             return $metaStreamContext;
         } elseif (is_array($metaStreamContext)) {
             return stream_context_create(
-                isset($metaStreamContext[ 'options' ]) ? $metaStreamContext[ 'options' ] : [ ],
-                isset($metaStreamContext[ 'params' ]) ? $metaStreamContext[ 'params' ] : [ ]
+                isset($metaStreamContext['options']) ? $metaStreamContext['options'] : [],
+                isset($metaStreamContext['params']) ? $metaStreamContext['params'] : []
             );
         }
 
@@ -138,7 +138,7 @@ 
             $this->setSocketOperationTime($item, RequestExecutorInterface::META_CONNECTION_START_TIME);
 
             $socket->open(
-                $meta[ RequestExecutorInterface::META_ADDRESS ],
+                $meta[RequestExecutorInterface::META_ADDRESS],
                 $this->getStreamContextFromMetaData($meta)
             );
 

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/Socket/AsyncSocketFactory.php

Spacing +5 added lines, -7 removed lines

@@ -75,15 +75,13 @@
     {
         switch ($type) {
             case self::SOCKET_CLIENT:
-                $isPersistent  = isset($options[ self::SOCKET_OPTION_IS_PERSISTENT ]) &&
-                                 $options[ self::SOCKET_OPTION_IS_PERSISTENT ];
-                $persistentKey = isset($options[ self::SOCKET_OPTION_PERSISTENT_KEY ]) ?
-                    $options[ self::SOCKET_OPTION_PERSISTENT_KEY ] :
-                    null;
+                $isPersistent  = isset($options[self::SOCKET_OPTION_IS_PERSISTENT]) &&
+                                 $options[self::SOCKET_OPTION_IS_PERSISTENT];
+                $persistentKey = isset($options[self::SOCKET_OPTION_PERSISTENT_KEY]) ?
+                    $options[self::SOCKET_OPTION_PERSISTENT_KEY] : null;
 
                 return $isPersistent ?
-                    new PersistentClientSocket($persistentKey) :
-                    new ClientSocket();
+                    new PersistentClientSocket($persistentKey) : new ClientSocket();
             case self::SOCKET_SERVER:
                 return new ServerSocket();
             default:

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/TimeoutStage.php

Spacing +2 added lines, -3 removed lines

@@ -24,7 +24,7 @@ 
     public function processStage(array $operations)
     {
         /** @var OperationMetadata[] $operations */
-        $result    = [ ];
+        $result    = [];
         $microTime = microtime(true);
         foreach ($operations as $key => $operation) {
             if ($this->isSingleSocketTimeout($operation, $microTime)) {
@@ -53,8 +53,7 @@ 
             $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] !== null &&
             !($descriptor->getSocket() instanceof ServerSocket) ?
-                TimeoutEvent::DURING_IO :
-                TimeoutEvent::DURING_CONNECTION
+                TimeoutEvent::DURING_IO : TimeoutEvent::DURING_CONNECTION
         );
         try {
             $this->callSocketSubscribers($descriptor, $event);

Indentation +10 added lines, -10 removed lines

@@ -1,12 +1,12 @@ 
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\RequestExecutor\Pipeline;
 
 use AsyncSockets\Event\TimeoutEvent;
@@ -114,10 +114,10 @@ 
 
         return ($desiredTimeout !== RequestExecutorInterface::WAIT_FOREVER) &&
                (
-                   ($hasConnected && $lastOperationTime !== null) ||
+                    ($hasConnected && $lastOperationTime !== null) ||
                    !$hasConnected
-               ) &&
+                ) &&
                ($microTime - $lastOperationTime >= $desiredTimeout)
-               ;
+                ;
     }
 }

src/Exception/UnmanagedSocketException.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         return new self(
             $socket,
             sprintf(
-                'System has detected a zombie connection %s and closed it. '.
+                'System has detected a zombie connection %s and closed it. ' .
                 'If you see this message it means that application ' .
                 'has lost control on one of its sockets.',
                 (string) $socket

src/Socket/AsyncSelector.php

Spacing +3 added lines, -4 removed lines

@@ -239,8 +239,8 @@ 
      */
     public function removeAllSocketOperations(StreamResourceInterface $streamResource)
     {
-        $opList = [ OperationInterface::OPERATION_READ,
-                    OperationInterface::OPERATION_WRITE  ];
+        $opList = [OperationInterface::OPERATION_READ,
+                    OperationInterface::OPERATION_WRITE];
 
         foreach ($opList as $op) {
             $this->removeSocketOperation($streamResource, $op);
@@ -281,8 +281,7 @@ 
      */
     private function calculateAttemptsCount($seconds, $usec)
     {
-        $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) :
-            self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
+        $result = $seconds !== null ? ceil(($seconds * 1E6 + $usec) / self::ATTEMPT_DELAY) : self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
         if ($result < self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT) {
             $result = self::ATTEMPT_COUNT_FOR_INFINITE_TIMEOUT;
         }

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/ConnectStageReturningAllActiveSockets.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
     private function isDescriptorActive(OperationMetadata $descriptor)
     {
         $meta = $descriptor->getMetadata();
-        return !$meta[ RequestExecutorInterface::META_REQUEST_COMPLETE ] &&
+        return !$meta[RequestExecutorInterface::META_REQUEST_COMPLETE] &&
                     $descriptor->isRunning() &&
                     !$descriptor->isPostponed();
     }

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/AbstractTimeAwareStage.php

Spacing +3 added lines, -5 removed lines

@@ -41,8 +41,7 @@ 
     {
         $meta = $operation->getMetadata();
         return !$this->hasConnected($operation) ?
-            $meta[ RequestExecutorInterface::META_CONNECTION_TIMEOUT ] :
-            $meta[ RequestExecutorInterface::META_IO_TIMEOUT ];
+            $meta[RequestExecutorInterface::META_CONNECTION_TIMEOUT] : $meta[RequestExecutorInterface::META_IO_TIMEOUT];
     }
 
     /**
@@ -56,8 +55,7 @@ 
     {
         $meta = $operation->getMetadata();
         return !$this->hasConnected($operation) ?
-            $meta[ RequestExecutorInterface::META_CONNECTION_START_TIME ] :
-            $meta[ RequestExecutorInterface::META_LAST_IO_START_TIME ];
+            $meta[RequestExecutorInterface::META_CONNECTION_START_TIME] : $meta[RequestExecutorInterface::META_LAST_IO_START_TIME];
     }
 
     /**
@@ -74,7 +72,7 @@ 
         $meta  = $operationMetadata->getMetadata();
         $table = [
             RequestExecutorInterface::META_CONNECTION_START_TIME =>
-                $meta[ RequestExecutorInterface::META_CONNECTION_START_TIME ] === null,
+                $meta[RequestExecutorInterface::META_CONNECTION_START_TIME] === null,
 
             RequestExecutorInterface::META_CONNECTION_FINISH_TIME =>
                 $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME] === null,

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;

src/RequestExecutor/Pipeline/SelectStage.php

Doc Comments +1 added lines, -1 removed lines

@@ -137,7 +137,7 @@
      * @param OperationMetadata $operation Operation object
      * @param double $microTime Current time with microseconds
      *
-     * @return double|null
+     * @return double
      */
     private function getSingleSocketTimeout(OperationMetadata $operation, $microTime)
     {

Spacing +2 added lines, -4 removed lines

@@ -127,8 +127,7 @@ 
     private function getMinTimeout($newValue, $oldValue)
     {
         return (($newValue > 0 && $newValue < $oldValue) || $oldValue === null) ?
-            $newValue :
-            $oldValue;
+            $newValue : $oldValue;
     }
 
     /**
@@ -149,8 +148,7 @@ 
         }
 
         $result = $lastOperationTime === null ?
-            $desiredTimeout :
-            $desiredTimeout - ($microTime - $lastOperationTime);
+            $desiredTimeout : $desiredTimeout - ($microTime - $lastOperationTime);
 
         return $result >= 0 ? $result : 0;
     }

Indentation +7 added lines, -7 removed lines

@@ -1,12 +1,12 @@
 <?php
 /**
- * Async sockets
- *
- * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
- *
- * This source file is subject to the MIT license that is bundled
- * with this source code in the file LICENSE.
- */
+     * Async sockets
+     *
+     * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
+     *
+     * This source file is subject to the MIT license that is bundled
+     * with this source code in the file LICENSE.
+     */
 namespace AsyncSockets\Socket;
 
 use AsyncSockets\Frame\FramePickerInterface;