Gecko [ v3.cesa.co.za ]

Name	Size	Permission	Date
Http	[ DIR ]	drwxr-xr-x	2026-07-12 06:24
AuthHelper.php	13.64 KB	-rw-r--r--	2023-03-21 10:50
Bitbucket.php	9.7 KB	-rw-r--r--	2023-03-21 10:50
ComposerMirror.php	2.34 KB	-rw-r--r--	2023-03-21 10:50
ConfigValidator.php	9.05 KB	-rw-r--r--	2023-03-21 10:50
ErrorHandler.php	2.44 KB	-rw-r--r--	2023-03-21 10:50
Filesystem.php	27.82 KB	-rw-r--r--	2023-03-21 10:50
Git.php	22.09 KB	-rw-r--r--	2023-03-21 10:50
GitHub.php	8.46 KB	-rw-r--r--	2026-05-14 09:28
GitLab.php	12 KB	-rw-r--r--	2023-03-21 10:50
Hg.php	3.19 KB	-rw-r--r--	2023-03-21 10:50
HttpDownloader.php	17.63 KB	-rw-r--r--	2023-03-21 10:50
IniHelper.php	1.61 KB	-rw-r--r--	2023-03-21 10:50
Loop.php	3.47 KB	-rw-r--r--	2023-03-21 10:50
MetadataMinifier.php	650 B	-rw-r--r--	2023-03-21 10:50
NoProxyPattern.php	10.62 KB	-rw-r--r--	2023-03-21 10:50
PackageInfo.php	964 B	-rw-r--r--	2023-03-21 10:50
PackageSorter.php	4.08 KB	-rw-r--r--	2023-03-21 10:50
Perforce.php	18.47 KB	-rw-r--r--	2026-05-14 09:28
Platform.php	8.57 KB	-rw-r--r--	2023-03-21 10:50
ProcessExecutor.php	13.82 KB	-rw-r--r--	2026-05-14 09:28
RemoteFilesystem.php	26.83 KB	-rw-r--r--	2023-03-21 10:50
Silencer.php	2.05 KB	-rw-r--r--	2023-03-21 10:50
StreamContextFactory.php	9.32 KB	-rw-r--r--	2023-03-21 10:50
Svn.php	9.66 KB	-rw-r--r--	2023-03-21 10:50
SyncHelper.php	2.39 KB	-rw-r--r--	2023-03-21 10:50
Tar.php	1.73 KB	-rw-r--r--	2023-03-21 10:50
TlsHelper.php	6.88 KB	-rw-r--r--	2023-03-21 10:50
Url.php	5.23 KB	-rw-r--r--	2026-05-14 09:28
Zip.php	3.31 KB	-rw-r--r--	2023-03-21 10:50

Rename

<?php declare(strict_types=1);

/*
 * This file is part of Composer.
 *
 * (c) Nils Adermann <naderman@naderman.de>
 *     Jordi Boggiano <j.boggiano@seld.be>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Composer\Util;

use React\Promise\CancellablePromiseInterface;
use Symfony\Component\Console\Helper\ProgressBar;
use React\Promise\PromiseInterface;

/**
 * @author Jordi Boggiano <j.boggiano@seld.be>
 */
class Loop
{
    /** @var HttpDownloader */
    private $httpDownloader;
    /** @var ProcessExecutor|null */
    private $processExecutor;
    /** @var PromiseInterface[][] */
    private $currentPromises = [];
    /** @var int */
    private $waitIndex = 0;

public function __construct(HttpDownloader $httpDownloader, ?ProcessExecutor $processExecutor = null)
    {
        $this->httpDownloader = $httpDownloader;
        $this->httpDownloader->enableAsync();

$this->processExecutor = $processExecutor;
        if ($this->processExecutor) {
            $this->processExecutor->enableAsync();
        }
    }

public function getHttpDownloader(): HttpDownloader
    {
        return $this->httpDownloader;
    }

public function getProcessExecutor(): ?ProcessExecutor
    {
        return $this->processExecutor;
    }

/**
     * @param  PromiseInterface[] $promises
     * @param  ?ProgressBar       $progress
     */
    public function wait(array $promises, ?ProgressBar $progress = null): void
    {
        /** @var \Exception|null */
        $uncaught = null;

\React\Promise\all($promises)->then(
            static function (): void {
            },
            static function ($e) use (&$uncaught): void {
                $uncaught = $e;
            }
        );

// keep track of every group of promises that is waited on, so abortJobs can
        // cancel them all, even if wait() was called within a wait()
        $waitIndex = $this->waitIndex++;
        $this->currentPromises[$waitIndex] = $promises;

if ($progress) {
            $totalJobs = 0;
            $totalJobs += $this->httpDownloader->countActiveJobs();
            if ($this->processExecutor) {
                $totalJobs += $this->processExecutor->countActiveJobs();
            }
            $progress->start($totalJobs);
        }

$lastUpdate = 0;
        while (true) {
            $activeJobs = 0;

$activeJobs += $this->httpDownloader->countActiveJobs();
            if ($this->processExecutor) {
                $activeJobs += $this->processExecutor->countActiveJobs();
            }

if ($progress && microtime(true) - $lastUpdate > 0.1) {
                $lastUpdate = microtime(true);
                $progress->setProgress($progress->getMaxSteps() - $activeJobs);
            }

if (!$activeJobs) {
                break;
            }
        }

// as we skip progress updates if they are too quick, make sure we do one last one here at 100%
        if ($progress) {
            $progress->finish();
        }

unset($this->currentPromises[$waitIndex]);
        if ($uncaught) {
            throw $uncaught;
        }
    }

public function abortJobs(): void
    {
        foreach ($this->currentPromises as $promiseGroup) {
            foreach ($promiseGroup as $promise) {
                if ($promise instanceof CancellablePromiseInterface) {
                    $promise->cancel();
                }
            }
        }
    }
}