rd.matisec.com:443

Linux webm017.cluster127.gra.hosting.ovh.net 5.15.167-ovh-vps-grsec-zfs-classid #1 SMP Tue Sep 17 08:14:20 UTC 2024 x86_64
Apache
10.127.20.17

File Name : BatchRequestTransfer.php

<?php

namespace Guzzle\Batch;

use Guzzle\Batch\BatchTransferInterface;
use Guzzle\Batch\BatchDivisorInterface;
use Guzzle\Common\Exception\InvalidArgumentException;
use Guzzle\Http\Message\RequestInterface;

/**
 * Batch transfer strategy used to efficiently transfer a batch of requests.
 * This class is to be used with {@see Guzzle\Batch\BatchInterface}
 */
class BatchRequestTransfer implements BatchTransferInterface, BatchDivisorInterface
{
    /** @var int Size of each command batch */
    protected $batchSize;

/**
     * Constructor used to specify how large each batch should be
     *
     * @param int $batchSize Size of each batch
     */
    public function __construct($batchSize = 50)
    {
        $this->batchSize = $batchSize;
    }

/**
     * Creates batches of requests by grouping requests by their associated curl multi object.
     * {@inheritdoc}
     */
    public function createBatches(\SplQueue $queue)
    {
        // Create batches by client objects
        $groups = new \SplObjectStorage();
        foreach ($queue as $item) {
            if (!$item instanceof RequestInterface) {
                throw new InvalidArgumentException('All items must implement Guzzle\Http\Message\RequestInterface');
            }
            $client = $item->getClient();
            if (!$groups->contains($client)) {
                $groups->attach($client, array($item));
            } else {
                $current = $groups[$client];
                $current[] = $item;
                $groups[$client] = $current;
            }
        }

$batches = array();
        foreach ($groups as $batch) {
            $batches = array_merge($batches, array_chunk($groups[$batch], $this->batchSize));
        }

return $batches;
    }

public function transfer(array $batch)
    {
        if ($batch) {
            reset($batch)->getClient()->send($batch);
        }
    }
}

System Information
*ReClick For Close
File : Negat1ve /JFR/.thumb35363/index.php

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	matisecojj/users	0755	2026-01-12 02:22:04
..	dir	-	matisecojj/users	0755	2026-01-12 02:22:04
Exception	dir	-	matisecojj/users	0755	2026-01-12 02:22:04
AbstractBatchDecorator.php	text/x-php	1.47 KB	matisecojj/users	0644	2026-01-12 02:22:04
Batch.php	text/x-php	2.96 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchBuilder.php	text/x-php	5.48 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchClosureDivisor.php	text/x-php	1.11 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchClosureTransfer.php	text/x-php	1.19 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchCommandTransfer.php	text/x-php	2.17 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchDivisorInterface.php	text/x-php	510 B	matisecojj/users	0644	2026-01-12 02:22:04
BatchInterface.php	text/x-php	589 B	matisecojj/users	0644	2026-01-12 02:22:04
BatchRequestTransfer.php	text/x-php	1.88 KB	matisecojj/users	0644	2026-01-12 02:22:04
BatchSizeDivisor.php	text/x-php	875 B	matisecojj/users	0644	2026-01-12 02:22:04
BatchTransferInterface.php	text/x-php	284 B	matisecojj/users	0644	2026-01-12 02:22:04
ExceptionBufferingBatch.php	text/x-php	1.21 KB	matisecojj/users	0644	2026-01-12 02:22:04
FlushingBatch.php	text/x-php	1.44 KB	matisecojj/users	0644	2026-01-12 02:22:04
HistoryBatch.php	text/x-php	758 B	matisecojj/users	0644	2026-01-12 02:22:04
NotifyingBatch.php	text/x-php	957 B	matisecojj/users	0644	2026-01-12 02:22:04
composer.json	application/json	815 B	matisecojj/users	0644	2026-01-12 02:22:04