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