REDROOM

Edit File Size: 2.54 KB

/home/getspomw/royalsquad.us/vendor/laravel/framework/src/Illuminate/Concurrency/ConcurrencyManager.php

Text Base64

<?php

namespace Illuminate\Concurrency;

use Illuminate\Process\Factory as ProcessFactory;
use Illuminate\Support\MultipleInstanceManager;
use RuntimeException;
use Spatie\Fork\Fork;

/**
 * @mixin \Illuminate\Contracts\Concurrency\Driver
 */
class ConcurrencyManager extends MultipleInstanceManager
{
    /**
     * Get a driver instance by name.
     *
     * @param  string|null  $name
     * @return mixed
     */
    public function driver($name = null)
    {
        return $this->instance($name);
    }

/**
     * Create an instance of the process concurrency driver.
     *
     * @param  array  $config
     * @return \Illuminate\Concurrency\ProcessDriver
     */
    public function createProcessDriver(array $config)
    {
        return new ProcessDriver($this->app->make(ProcessFactory::class));
    }

/**
     * Create an instance of the fork concurrency driver.
     *
     * @param  array  $config
     * @return \Illuminate\Concurrency\ForkDriver
     *
     * @throws \RuntimeException
     */
    public function createForkDriver(array $config)
    {
        if (! $this->app->runningInConsole()) {
            throw new RuntimeException('Due to PHP limitations, the fork driver may not be used within web requests.');
        }

if (! class_exists(Fork::class)) {
            throw new RuntimeException('Please install the "spatie/fork" Composer package in order to utilize the "fork" driver.');
        }

return new ForkDriver;
    }

/**
     * Create an instance of the sync concurrency driver.
     *
     * @param  array  $config
     * @return \Illuminate\Concurrency\SyncDriver
     */
    public function createSyncDriver(array $config)
    {
        return new SyncDriver;
    }

/**
     * Get the default instance name.
     *
     * @return string
     */
    public function getDefaultInstance()
    {
        return $this->app['config']['concurrency.default']
            ?? $this->app['config']['concurrency.driver']
            ?? 'process';
    }

/**
     * Set the default instance name.
     *
     * @param  string  $name
     * @return void
     */
    public function setDefaultInstance($name)
    {
        $this->app['config']['concurrency.default'] = $name;
        $this->app['config']['concurrency.driver'] = $name;
    }

/**
     * Get the instance specific configuration.
     *
     * @param  string  $name
     * @return array
     */
    public function getInstanceConfig($name)
    {
        return $this->app['config']->get(
            'concurrency.driver.'.$name, ['driver' => $name],
        );
    }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
Console DIR	-	drwxrwxrwx	2025-09-17 06:52:59	Edit Download recursive recursive
composer.json	964 B	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
ConcurrencyManager.php	2.54 KB	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
ConcurrencyServiceProvider.php	692 B	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
ForkDriver.php	773 B	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
LICENSE.md	1.05 KB	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
ProcessDriver.php	2.32 KB	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive
SyncDriver.php	790 B	lrw-rw-rw-	2025-09-17 06:52:59	Edit Download recursive recursive

Directory Contents