edefimov / async-sockets

src/Socket/AsyncSocketFactory.php

Spacing +6 added lines, -8 removed lines

@@ -74,19 +74,17 @@
     {
         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:
-                throw new \InvalidArgumentException("Unexpected type {$type} used in " . __FUNCTION__);
+                throw new \InvalidArgumentException("Unexpected type {$type} used in ".__FUNCTION__);
         }
     }
 

src/Socket/PersistentClientSocket.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
     protected function createSocketResource($address, $context)
     {
         $resource = stream_socket_client(
-            $address . ($this->persistentKey ? '/' . $this->persistentKey : ''),
+            $address.($this->persistentKey ? '/'.$this->persistentKey : ''),
             $errno,
             $errstr,
             null,

src/Socket/Io/DatagramClientIo.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
         parent::__construct($socket, 0);
         if ($remoteAddress) {
             $components = parse_url($remoteAddress);
-            $this->remoteAddress = $components['host'] . ':' . $components['port'];
+            $this->remoteAddress = $components['host'].':'.$components['port'];
         }
     }
 

src/RequestExecutor/LibEvent/LeBase.php

Spacing +3 added lines, -3 removed lines

@@ -211,9 +211,9 @@
     private function onEvent(LeEvent $event, $eventFlags)
     {
         $map = [
-            LeCallbackInterface::EVENT_READ    => [ EV_READ, RequestDescriptor::RDS_READ ],
-            LeCallbackInterface::EVENT_WRITE   => [ EV_WRITE, RequestDescriptor::RDS_WRITE ],
-            LeCallbackInterface::EVENT_TIMEOUT => [ EV_TIMEOUT, 0 ],
+            LeCallbackInterface::EVENT_READ    => [EV_READ, RequestDescriptor::RDS_READ],
+            LeCallbackInterface::EVENT_WRITE   => [EV_WRITE, RequestDescriptor::RDS_WRITE],
+            LeCallbackInterface::EVENT_TIMEOUT => [EV_TIMEOUT, 0],
         ];
 
         $descriptor = $event->getRequestDescriptor();

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/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;
     }