iframe-proxy | Sunbelt Computer Software

154 lines (134 loc) · 4.24 KB
 * Copyright 2018 Glu Mobile Inc.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *     http://www.apache.org/licenses/LICENSE-2.0
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
declare(strict_types=1);
namespace CrowdStar\BackgroundProcessing;
use CrowdStar\BackgroundProcessing\Exception\AlreadyInvokedException;
use CrowdStar\BackgroundProcessing\Exception\BackgroundProcessingFailedException;
use CrowdStar\BackgroundProcessing\Exception\InvalidEnvironmentException;
use CrowdStar\BackgroundProcessing\Timer\AbstractTimer;
 * Class BackgroundProcessing
class BackgroundProcessing
     * Stop execution immediately when a closure throws an exception. The exception is thrown as-is.
    const EXECUTION_TYPE_STOP_ON_ERROR = 0;
     * Continue executing remaining closures when one throws an exception. After all closures have been executed, a
     * BackgroundProcessingFailedException is thrown containing all collected exceptions.
    const EXECUTION_TYPE_CONTINUE_ON_ERROR = 1;
     * @var \Closure[]
    protected static $closures = [];
     * @var AbstractTimer[]
    protected static $timers = [];
     * @var bool
    protected static $invoked = false;
     * @var int
    protected static $executionType = self::EXECUTION_TYPE_STOP_ON_ERROR;
     * @param bool $stopTiming Stop timing the current transaction or not before starting processing tasks in background
     * @return void
     * @throws AlreadyInvokedException|InvalidEnvironmentException|BackgroundProcessingFailedException|\Throwable
    public static function run(bool $stopTiming = false)
        if (self::isInvoked()) {
            throw new AlreadyInvokedException('background process invoked already');
        self::setInvoked(true);
        if (!function_exists('fastcgi_finish_request')) {
            throw new InvalidEnvironmentException('background process invokable under PHP-FPM only');
        if (session_status() === PHP_SESSION_ACTIVE) {
            session_write_close();
        fastcgi_finish_request(); // @phpstan-ignore function.resultUnused
        if ($stopTiming) {
            // Stop timing the current transaction before starting processing tasks in background.
            foreach (self::$timers as $timer) {
                $timer->stopTiming();
        if (self::$executionType === self::EXECUTION_TYPE_STOP_ON_ERROR) {
            foreach (self::$closures as $closure) {
                $closure();
        } else {
            $exceptions = [];
            foreach (self::$closures as $closure) {
                    $closure();
                } catch (\Throwable $e) {
                    $exceptions[] = $e;
            if (!empty($exceptions)) {
                throw new BackgroundProcessingFailedException($exceptions);
     * @param array<mixed> ...$params
     * @return void
    public static function add(\Closure $op, ...$params)
        self::$closures[] = function () use ($op, $params) {
            return $op(...$params);
     * @return void
    public static function addTimer(AbstractTimer $timer)
        self::$timers[] = $timer;
     * @return void
    public static function setExecutionType(int $executionType)
        self::$executionType = $executionType;
    public static function getExecutionType(): int
        return self::$executionType;
     * @return void
    protected static function setInvoked(bool $invoked)
        self::$invoked = $invoked;
    protected static function isInvoked(): bool
        return self::$invoked;
Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

BackgroundProcessing.php

Latest commit

History

BackgroundProcessing.php

File metadata and controls
