edefimov / async-sockets

src/Socket/AsyncSelector.php

Spacing +3 added lines, -4 removed lines

@@ -108,8 +108,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;
         }
@@ -328,8 +327,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);

src/Socket/Io/AbstractIo.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
         $lastError = error_get_last();
         if ($lastError) {
             $phpMessage = explode(':', $lastError['message'], 2);
-            $phpMessage = trim(trim(end($phpMessage)), '.') . '.';
+            $phpMessage = trim(trim(end($phpMessage)), '.').'.';
             return $phpMessage;
         }
 

src/Socket/AbstractSocket.php

Spacing +2 added lines, -3 removed lines

@@ -174,8 +174,7 @@ 
                 '[#%s, %s]',
                 preg_replace('/Resource id #(\d+)/i', '$1', (string) $this->resource),
                 $this->remoteAddress
-            ) :
-            '[closed socket]';
+            ) : '[closed socket]';
     }
 
     /**
@@ -218,7 +217,7 @@ 
             'unix' => self::SOCKET_TYPE_UNIX,
         ];
 
-        $regexp = '#^('. implode('|', array_keys($map)) . ')_socket$#';
+        $regexp = '#^('.implode('|', array_keys($map)).')_socket$#';
         foreach ($parts as $part) {
             if (preg_match($regexp, $part, $pockets)) {
                 return $map[$pockets[1]];

src/RequestExecutor/Pipeline/AbstractOobHandler.php

Spacing +11 added lines, -12 removed lines

@@ -113,7 +113,7 @@ 
         $event  = new ReadEvent(
             $executor,
             $socket,
-            $meta[ RequestExecutorInterface::META_USER_CONTEXT ],
+            $meta[RequestExecutorInterface::META_USER_CONTEXT],
             $frame,
             true
         );
@@ -140,8 +140,7 @@ 
         if (!$counter) {
             $meta    = $descriptor->getMetadata();
             $counter = new SpeedRateCounter($minRate, $duration);
-            $time    = $meta[RequestExecutorInterface::META_LAST_IO_START_TIME] ?:
-                        $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME];
+            $time    = $meta[RequestExecutorInterface::META_LAST_IO_START_TIME] ?: $meta[RequestExecutorInterface::META_CONNECTION_FINISH_TIME];
             $counter->advance($time, 0);
             $descriptor->registerCounter($name, $counter);
         }
@@ -204,26 +203,26 @@ 
         $map = [
             RequestDescriptor::COUNTER_RECV_MIN_RATE => [
                 'resetCounter' => RequestDescriptor::COUNTER_SEND_MIN_RATE,
-                'minSpeed'     => $meta[ RequestExecutorInterface::META_MIN_RECEIVE_SPEED ],
-                'duration'     => $meta[ RequestExecutorInterface::META_MIN_RECEIVE_SPEED_DURATION ],
+                'minSpeed'     => $meta[RequestExecutorInterface::META_MIN_RECEIVE_SPEED],
+                'duration'     => $meta[RequestExecutorInterface::META_MIN_RECEIVE_SPEED_DURATION],
                 'bytesCounter' => RequestExecutorInterface::META_BYTES_RECEIVED,
                 'speedCounter' => RequestExecutorInterface::META_RECEIVE_SPEED,
-                'exception'    => [ 'AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataReceiving' ],
+                'exception'    => ['AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataReceiving'],
             ],
             RequestDescriptor::COUNTER_SEND_MIN_RATE => [
                 'resetCounter' => RequestDescriptor::COUNTER_RECV_MIN_RATE,
-                'minSpeed'     => $meta[ RequestExecutorInterface::META_MIN_SEND_SPEED ],
-                'duration'     => $meta[ RequestExecutorInterface::META_MIN_SEND_SPEED_DURATION ],
+                'minSpeed'     => $meta[RequestExecutorInterface::META_MIN_SEND_SPEED],
+                'duration'     => $meta[RequestExecutorInterface::META_MIN_SEND_SPEED_DURATION],
                 'bytesCounter' => RequestExecutorInterface::META_BYTES_SENT,
                 'speedCounter' => RequestExecutorInterface::META_SEND_SPEED,
-                'exception'    => [ 'AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataSending' ],
+                'exception'    => ['AsyncSockets\Exception\SlowSpeedTransferException', 'tooSlowDataSending'],
             ],
         ];
 
-        if (!isset($map[ $name ])) {
-            throw new \LogicException('Can not process counter ' . $name . ' in transfer operation');
+        if (!isset($map[$name])) {
+            throw new \LogicException('Can not process counter '.$name.' in transfer operation');
         }
 
-        return $map[ $name ];
+        return $map[$name];
     }
 }

src/Socket/Io/StreamedClientIo.php

Spacing +5 added lines, -7 removed lines

@@ -52,8 +52,7 @@ 
         $this->verifySendResult('', stream_socket_sendto($resource, ''));
 
         $written = $isOutOfBand ?
-            $this->writeOobData($resource, $data) :
-            fwrite($resource, $data, strlen($data));
+            $this->writeOobData($resource, $data) : fwrite($resource, $data, strlen($data));
 
         $this->verifySendResult($data, $written);
 
@@ -74,7 +73,7 @@ 
         if ($sendResult === false || $sendResult < 0) {
             throw new SendDataException(
                 $this->socket,
-                trim('Failed to send data. ' . $this->getLastPhpErrorMessage())
+                trim('Failed to send data. '.$this->getLastPhpErrorMessage())
             );
         }
 
@@ -148,7 +147,7 @@ 
             if ($data === false) {
                 throw new RecvDataException(
                     $this->socket,
-                    trim('Failed to read data. ' . $this->getLastPhpErrorMessage())
+                    trim('Failed to read data. '.$this->getLastPhpErrorMessage())
                 );
             }
 
@@ -202,9 +201,8 @@ 
     private function resolveReadAttempts(array $context, $currentAttempts)
     {
         return ($context['countCycles'] === 1 && empty($context['dataBeforeIo'])) ||
-               ($context['countCycles'] > 1   && $context['isStreamDataEmpty']) ?
-            $currentAttempts - 1 :
-            self::READ_ATTEMPTS;
+               ($context['countCycles'] > 1 && $context['isStreamDataEmpty']) ?
+            $currentAttempts - 1 : self::READ_ATTEMPTS;
 
     }
 

src/Configuration/Configuration.php

Spacing +12 added lines, -12 removed lines

@@ -95,11 +95,11 @@ 
     {
         $options += $this->getDefaultOptions();
 
-        $this->connectTimeout   = (double) $options[ 'connectTimeout' ];
-        $this->ioTimeout        = (double) $options[ 'ioTimeout' ];
-        $this->preferredEngines = (array) $options[ 'preferredEngines' ];
+        $this->connectTimeout   = (double) $options['connectTimeout'];
+        $this->ioTimeout        = (double) $options['ioTimeout'];
+        $this->preferredEngines = (array) $options['preferredEngines'];
 
-        $this->streamContext = new StreamContext($options[ 'streamContext' ]);
+        $this->streamContext = new StreamContext($options['streamContext']);
         foreach (['minReceiveSpeed', 'minReceiveSpeedDuration', 'minSendSpeed', 'minSendSpeedDuration'] as $k) {
             $this->{$k} = $options[$k] !== null ? (int) $options[$k] : null;
         }
@@ -195,14 +195,14 @@ 
         $result        = [];
         $socketTimeout = (double) ini_get('default_socket_timeout');
 
-        $result[ 'connectTimeout' ]          = $socketTimeout;
-        $result[ 'ioTimeout' ]               = $socketTimeout;
-        $result[ 'preferredEngines' ]        = [ 'libevent', 'native' ];
-        $result[ 'streamContext' ]           = null;
-        $result[ 'minReceiveSpeed' ]         = null;
-        $result[ 'minReceiveSpeedDuration' ] = null;
-        $result[ 'minSendSpeed' ]            = null;
-        $result[ 'minSendSpeedDuration' ]    = null;
+        $result['connectTimeout']          = $socketTimeout;
+        $result['ioTimeout']               = $socketTimeout;
+        $result['preferredEngines']        = ['libevent', 'native'];
+        $result['streamContext']           = null;
+        $result['minReceiveSpeed']         = null;
+        $result['minReceiveSpeedDuration'] = null;
+        $result['minSendSpeed']            = null;
+        $result['minSendSpeedDuration']    = null;
 
         return $result;
     }

src/Configuration/StreamContext.php

Spacing +2 added lines, -2 removed lines

@@ -59,8 +59,8 @@
             return $settings;
         } elseif (is_array($settings)) {
             return stream_context_create(
-                isset($settings[ 'options' ]) ? $settings[ 'options' ] : [ ],
-                isset($settings[ 'params' ]) ? $settings[ 'params' ] : [ ]
+                isset($settings['options']) ? $settings['options'] : [],
+                isset($settings['params']) ? $settings['params'] : []
             );
         } elseif ($settings === null) {
             return stream_context_get_default();

src/RequestExecutor/Pipeline/ConnectStage.php

Spacing +3 added lines, -3 removed lines

@@ -56,7 +56,7 @@ 
             } elseif ($decision === LimitationSolverInterface::DECISION_SKIP_CURRENT) {
                 continue;
             } elseif ($decision !== LimitationSolverInterface::DECISION_OK) {
-                throw new \LogicException('Unknown decision ' . $decision . ' received.');
+                throw new \LogicException('Unknown decision '.$decision.' received.');
             }
 
             if ($this->connectSocket($descriptor)) {
@@ -117,8 +117,8 @@ 
             $meta = $descriptor->getMetadata();
 
             $socket->open(
-                $meta[ RequestExecutorInterface::META_ADDRESS ],
-                $meta[ RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
+                $meta[RequestExecutorInterface::META_ADDRESS],
+                $meta[RequestExecutorInterface::META_SOCKET_STREAM_CONTEXT]
             );
 
             $descriptor->setRunning(true);

src/RequestExecutor/Metadata/SocketBag.php

Spacing +1 added lines, -1 removed lines

@@ -178,7 +178,7 @@
         ];
 
         if (!is_array($key)) {
-            $key = [ $key => $value ];
+            $key = [$key => $value];
         }
 
         $key = array_intersect_key($key, $writableKeys);