@@ -327,11 +327,11 @@ |
||
| 327 | 327 | foreach (ClassLoader::getRegisteredLoaders() as $vendorDir => $loader) { |
| 328 | 328 | if (isset(self::$installedByVendor[$vendorDir])) { |
| 329 | 329 | $installed[] = self::$installedByVendor[$vendorDir]; |
| 330 | - } elseif (is_file($vendorDir.'/composer/installed.php')) { |
|
| 330 | + } elseif (is_file($vendorDir . '/composer/installed.php')) { |
|
| 331 | 331 | /** @var array{root: array{name: string, pretty_version: string, version: string, reference: string|null, type: string, install_path: string, aliases: string[], dev: bool}, versions: array<string, array{pretty_version?: string, version?: string, reference?: string|null, type?: string, install_path?: string, aliases?: string[], dev_requirement: bool, replaced?: string[], provided?: string[]}>} $required */ |
| 332 | - $required = require $vendorDir.'/composer/installed.php'; |
|
| 332 | + $required = require $vendorDir . '/composer/installed.php'; |
|
| 333 | 333 | $installed[] = self::$installedByVendor[$vendorDir] = $required; |
| 334 | - if (null === self::$installed && strtr($vendorDir.'/composer', '\\', '/') === strtr(__DIR__, '\\', '/')) { |
|
| 334 | + if (null === self::$installed && strtr($vendorDir . '/composer', '\\', '/') === strtr(__DIR__, '\\', '/')) { |
|
| 335 | 335 | self::$installed = $installed[count($installed) - 1]; |
| 336 | 336 | } |
| 337 | 337 | } |
@@ -34,7 +34,7 @@ |
||
| 34 | 34 | $loader->register(true); |
| 35 | 35 | |
| 36 | 36 | $filesToLoad = \Composer\Autoload\ComposerStaticInit6e0324fc886fd55694e53338d30399bc::$files; |
| 37 | - $requireFile = \Closure::bind(static function ($fileIdentifier, $file) { |
|
| 37 | + $requireFile = \Closure::bind(static function($fileIdentifier, $file) { |
|
| 38 | 38 | if (empty($GLOBALS['__composer_autoload_files'][$fileIdentifier])) { |
| 39 | 39 | $GLOBALS['__composer_autoload_files'][$fileIdentifier] = true; |
| 40 | 40 | |
@@ -14,9 +14,9 @@ |
||
| 14 | 14 | } |
| 15 | 15 | if (!ini_get('display_errors')) { |
| 16 | 16 | if (PHP_SAPI === 'cli' || PHP_SAPI === 'phpdbg') { |
| 17 | - fwrite(STDERR, 'Composer detected issues in your platform:' . PHP_EOL.PHP_EOL . implode(PHP_EOL, $issues) . PHP_EOL.PHP_EOL); |
|
| 17 | + fwrite(STDERR, 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . implode(PHP_EOL, $issues) . PHP_EOL . PHP_EOL); |
|
| 18 | 18 | } elseif (!headers_sent()) { |
| 19 | - echo 'Composer detected issues in your platform:' . PHP_EOL.PHP_EOL . str_replace('You are running '.PHP_VERSION.'.', '', implode(PHP_EOL, $issues)) . PHP_EOL.PHP_EOL; |
|
| 19 | + echo 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . str_replace('You are running ' . PHP_VERSION . '.', '', implode(PHP_EOL, $issues)) . PHP_EOL . PHP_EOL; |
|
| 20 | 20 | } |
| 21 | 21 | } |
| 22 | 22 | trigger_error( |
@@ -95,7 +95,7 @@ discard block |
||
| 95 | 95 | |
| 96 | 96 | $errno = 0; |
| 97 | 97 | $errstr = ''; |
| 98 | - \set_error_handler(function ($_, $error) use (&$errno, &$errstr) { |
|
| 98 | + \set_error_handler(function($_, $error) use (&$errno, &$errstr) { |
|
| 99 | 99 | // Match errstr from PHP's warning message. |
| 100 | 100 | // fopen(php://fd/3): Failed to open stream: Error duping file descriptor 3; possibly it doesn't exist: [9]: Bad file descriptor |
| 101 | 101 | \preg_match('/\[(\d+)\]: (.*)/', $error, $m); |
@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | } |
| 189 | 189 | |
| 190 | 190 | $that = $this; |
| 191 | - $this->loop->addReadStream($this->master, function ($master) use ($that) { |
|
| 191 | + $this->loop->addReadStream($this->master, function($master) use ($that) { |
|
| 192 | 192 | try { |
| 193 | 193 | $newSocket = SocketServer::accept($master); |
| 194 | 194 | } catch (\RuntimeException $e) { |
@@ -49,14 +49,14 @@ discard block |
||
| 49 | 49 | $resolved = null; |
| 50 | 50 | |
| 51 | 51 | return new Promise\Promise( |
| 52 | - function ($resolve, $reject) use (&$promise, &$resolved, $uri, $connector, $host, $parts) { |
|
| 52 | + function($resolve, $reject) use (&$promise, &$resolved, $uri, $connector, $host, $parts) { |
|
| 53 | 53 | // resolve/reject with result of DNS lookup |
| 54 | - $promise->then(function ($ip) use (&$promise, &$resolved, $uri, $connector, $host, $parts) { |
|
| 54 | + $promise->then(function($ip) use (&$promise, &$resolved, $uri, $connector, $host, $parts) { |
|
| 55 | 55 | $resolved = $ip; |
| 56 | 56 | |
| 57 | 57 | return $promise = $connector->connect( |
| 58 | 58 | Connector::uri($parts, $host, $ip) |
| 59 | - )->then(null, function (\Exception $e) use ($uri) { |
|
| 59 | + )->then(null, function(\Exception $e) use ($uri) { |
|
| 60 | 60 | if ($e instanceof \RuntimeException) { |
| 61 | 61 | $message = \preg_replace('/^(Connection to [^ ]+)[&?]hostname=[^ &]+/', '$1', $e->getMessage()); |
| 62 | 62 | $e = new \RuntimeException( |
@@ -88,11 +88,11 @@ discard block |
||
| 88 | 88 | |
| 89 | 89 | throw $e; |
| 90 | 90 | }); |
| 91 | - }, function ($e) use ($uri, $reject) { |
|
| 92 | - $reject(new \RuntimeException('Connection to ' . $uri .' failed during DNS lookup: ' . $e->getMessage(), 0, $e)); |
|
| 91 | + }, function($e) use ($uri, $reject) { |
|
| 92 | + $reject(new \RuntimeException('Connection to ' . $uri . ' failed during DNS lookup: ' . $e->getMessage(), 0, $e)); |
|
| 93 | 93 | })->then($resolve, $reject); |
| 94 | 94 | }, |
| 95 | - function ($_, $reject) use (&$promise, &$resolved, $uri) { |
|
| 95 | + function($_, $reject) use (&$promise, &$resolved, $uri) { |
|
| 96 | 96 | // cancellation should reject connection attempt |
| 97 | 97 | // reject DNS resolution with custom reason, otherwise rely on connection cancellation below |
| 98 | 98 | if ($resolved === null) { |
@@ -69,13 +69,13 @@ discard block |
||
| 69 | 69 | |
| 70 | 70 | $errno = 0; |
| 71 | 71 | $errstr = ''; |
| 72 | - \set_error_handler(function ($_, $error) use (&$errno, &$errstr) { |
|
| 72 | + \set_error_handler(function($_, $error) use (&$errno, &$errstr) { |
|
| 73 | 73 | // PHP does not seem to report errno/errstr for Unix domain sockets (UDS) right now. |
| 74 | 74 | // This only applies to UDS server sockets, see also https://3v4l.org/NAhpr. |
| 75 | 75 | // Parse PHP warning message containing unknown error, HHVM reports proper info at least. |
| 76 | 76 | if (\preg_match('/\(([^\)]+)\)|\[(\d+)\]: (.*)/', $error, $match)) { |
| 77 | 77 | $errstr = isset($match[3]) ? $match['3'] : $match[1]; |
| 78 | - $errno = isset($match[2]) ? (int)$match[2] : 0; |
|
| 78 | + $errno = isset($match[2]) ? (int) $match[2] : 0; |
|
| 79 | 79 | } |
| 80 | 80 | }); |
| 81 | 81 | |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | } |
| 127 | 127 | |
| 128 | 128 | $that = $this; |
| 129 | - $this->loop->addReadStream($this->master, function ($master) use ($that) { |
|
| 129 | + $this->loop->addReadStream($this->master, function($master) use ($that) { |
|
| 130 | 130 | try { |
| 131 | 131 | $newSocket = SocketServer::accept($master); |
| 132 | 132 | } catch (\RuntimeException $e) { |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | { |
| 58 | 58 | // swap arguments for legacy constructor signature |
| 59 | 59 | if (($context instanceof LoopInterface || $context === null) && (\func_num_args() <= 1 || \is_array($loop))) { |
| 60 | - $swap = $loop === null ? array(): $loop; |
|
| 60 | + $swap = $loop === null ? array() : $loop; |
|
| 61 | 61 | $loop = $context; |
| 62 | 62 | $context = $swap; |
| 63 | 63 | } |
@@ -78,7 +78,7 @@ discard block |
||
| 78 | 78 | ); |
| 79 | 79 | |
| 80 | 80 | if ($context['timeout'] === true) { |
| 81 | - $context['timeout'] = (float)\ini_get("default_socket_timeout"); |
|
| 81 | + $context['timeout'] = (float) \ini_get("default_socket_timeout"); |
|
| 82 | 82 | } |
| 83 | 83 | |
| 84 | 84 | if ($context['tcp'] instanceof ConnectorInterface) { |
@@ -164,7 +164,7 @@ discard block |
||
| 164 | 164 | { |
| 165 | 165 | $scheme = 'tcp'; |
| 166 | 166 | if (\strpos($uri, '://') !== false) { |
| 167 | - $scheme = (string)\substr($uri, 0, \strpos($uri, '://')); |
|
| 167 | + $scheme = (string) \substr($uri, 0, \strpos($uri, '://')); |
|
| 168 | 168 | } |
| 169 | 169 | |
| 170 | 170 | if (!isset($this->connectors[$scheme])) { |
@@ -88,10 +88,10 @@ |
||
| 88 | 88 | $this->server = $server; |
| 89 | 89 | |
| 90 | 90 | $that = $this; |
| 91 | - $server->on('connection', function (ConnectionInterface $conn) use ($that) { |
|
| 91 | + $server->on('connection', function(ConnectionInterface $conn) use ($that) { |
|
| 92 | 92 | $that->emit('connection', array($conn)); |
| 93 | 93 | }); |
| 94 | - $server->on('error', function (Exception $error) use ($that) { |
|
| 94 | + $server->on('error', function(Exception $error) use ($that) { |
|
| 95 | 95 | $that->emit('error', array($error)); |
| 96 | 96 | }); |
| 97 | 97 | } |
@@ -66,9 +66,9 @@ discard block |
||
| 66 | 66 | public function connect() |
| 67 | 67 | { |
| 68 | 68 | $that = $this; |
| 69 | - return new Promise\Promise(function ($resolve, $reject) use ($that) { |
|
| 70 | - $lookupResolve = function ($type) use ($that, $resolve, $reject) { |
|
| 71 | - return function (array $ips) use ($that, $type, $resolve, $reject) { |
|
| 69 | + return new Promise\Promise(function($resolve, $reject) use ($that) { |
|
| 70 | + $lookupResolve = function($type) use ($that, $resolve, $reject) { |
|
| 71 | + return function(array $ips) use ($that, $type, $resolve, $reject) { |
|
| 72 | 72 | unset($that->resolverPromises[$type]); |
| 73 | 73 | $that->resolved[$type] = true; |
| 74 | 74 | |
@@ -82,29 +82,29 @@ discard block |
||
| 82 | 82 | }; |
| 83 | 83 | |
| 84 | 84 | $that->resolverPromises[Message::TYPE_AAAA] = $that->resolve(Message::TYPE_AAAA, $reject)->then($lookupResolve(Message::TYPE_AAAA)); |
| 85 | - $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function (array $ips) use ($that) { |
|
| 85 | + $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function(array $ips) use ($that) { |
|
| 86 | 86 | // happy path: IPv6 has resolved already (or could not resolve), continue with IPv4 addresses |
| 87 | 87 | if ($that->resolved[Message::TYPE_AAAA] === true || !$ips) { |
| 88 | 88 | return $ips; |
| 89 | 89 | } |
| 90 | 90 | |
| 91 | 91 | // Otherwise delay processing IPv4 lookup until short timer passes or IPv6 resolves in the meantime |
| 92 | - $deferred = new Promise\Deferred(function () use (&$ips) { |
|
| 92 | + $deferred = new Promise\Deferred(function() use (&$ips) { |
|
| 93 | 93 | // discard all IPv4 addresses if cancelled |
| 94 | 94 | $ips = array(); |
| 95 | 95 | }); |
| 96 | - $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function () use ($deferred, $ips) { |
|
| 96 | + $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function() use ($deferred, $ips) { |
|
| 97 | 97 | $deferred->resolve($ips); |
| 98 | 98 | }); |
| 99 | 99 | |
| 100 | - $that->resolverPromises[Message::TYPE_AAAA]->then(function () use ($that, $timer, $deferred, &$ips) { |
|
| 100 | + $that->resolverPromises[Message::TYPE_AAAA]->then(function() use ($that, $timer, $deferred, &$ips) { |
|
| 101 | 101 | $that->loop->cancelTimer($timer); |
| 102 | 102 | $deferred->resolve($ips); |
| 103 | 103 | }); |
| 104 | 104 | |
| 105 | 105 | return $deferred->promise(); |
| 106 | 106 | })->then($lookupResolve(Message::TYPE_A)); |
| 107 | - }, function ($_, $reject) use ($that) { |
|
| 107 | + }, function($_, $reject) use ($that) { |
|
| 108 | 108 | $reject(new \RuntimeException( |
| 109 | 109 | 'Connection to ' . $that->uri . ' cancelled' . (!$that->connectionPromises ? ' during DNS lookup' : '') . ' (ECONNABORTED)', |
| 110 | 110 | \defined('SOCKET_ECONNABORTED') ? \SOCKET_ECONNABORTED : 103 |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | public function resolve($type, $reject) |
| 127 | 127 | { |
| 128 | 128 | $that = $this; |
| 129 | - return $that->resolver->resolveAll($that->host, $type)->then(null, function (\Exception $e) use ($type, $reject, $that) { |
|
| 129 | + return $that->resolver->resolveAll($that->host, $type)->then(null, function(\Exception $e) use ($type, $reject, $that) { |
|
| 130 | 130 | unset($that->resolverPromises[$type]); |
| 131 | 131 | $that->resolved[$type] = true; |
| 132 | 132 | |
@@ -170,13 +170,13 @@ discard block |
||
| 170 | 170 | $index = \key($this->connectionPromises); |
| 171 | 171 | |
| 172 | 172 | $that = $this; |
| 173 | - $that->connectionPromises[$index]->then(function ($connection) use ($that, $index, $resolve) { |
|
| 173 | + $that->connectionPromises[$index]->then(function($connection) use ($that, $index, $resolve) { |
|
| 174 | 174 | unset($that->connectionPromises[$index]); |
| 175 | 175 | |
| 176 | 176 | $that->cleanUp(); |
| 177 | 177 | |
| 178 | 178 | $resolve($connection); |
| 179 | - }, function (\Exception $e) use ($that, $index, $ip, $resolve, $reject) { |
|
| 179 | + }, function(\Exception $e) use ($that, $index, $ip, $resolve, $reject) { |
|
| 180 | 180 | unset($that->connectionPromises[$index]); |
| 181 | 181 | |
| 182 | 182 | $that->failureCount++; |
@@ -218,7 +218,7 @@ discard block |
||
| 218 | 218 | // Allow next connection attempt in 100ms: https://tools.ietf.org/html/rfc8305#section-5 |
| 219 | 219 | // Only start timer when more IPs are queued or when DNS query is still pending (might add more IPs) |
| 220 | 220 | if ($this->nextAttemptTimer === null && (\count($this->connectQueue) > 0 || $this->resolved[Message::TYPE_A] === false || $this->resolved[Message::TYPE_AAAA] === false)) { |
| 221 | - $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function () use ($that, $resolve, $reject) { |
|
| 221 | + $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function() use ($that, $resolve, $reject) { |
|
| 222 | 222 | $that->nextAttemptTimer = null; |
| 223 | 223 | |
| 224 | 224 | if ($that->connectQueue) { |
@@ -329,6 +329,6 @@ discard block |
||
| 329 | 329 | $message = ': ' . $message; |
| 330 | 330 | } |
| 331 | 331 | |
| 332 | - return 'Connection to ' . $this->uri . ' failed' . $message; |
|
| 332 | + return 'Connection to ' . $this->uri . ' failed' . $message; |
|
| 333 | 333 | } |
| 334 | 334 | } |