CallbackDuration.php

Go to the documentation of this file.

<?php declare(strict_types=1);

namespace ILIAS\HTTP\Duration;

use Closure;

class CallbackDuration extends Duration
{
    public function stretch(callable $callback)
    {
        $start_time = microtime(true);
        $halted = true;

        register_shutdown_function(static function () use (&$halted) {
            if ($halted) {
                throw new \LogicException("Callback could not be stretched because it halted the programm.");
            }
        });

        $return = $callback();
        $halted = false;

        $elapsed_time_in_us = ((microtime(true) - $start_time) * self::S_TO_US);
        $duration_in_us = ($this->duration_in_ms * self::MS_TO_US);

        if ($elapsed_time_in_us > $duration_in_us) {
            throw new \RuntimeException("Execution of callback exceeded the given duration and could not be stretched.");
        }

        if ($elapsed_time_in_us < $duration_in_us) {
            usleep((int) round($duration_in_us - $elapsed_time_in_us));
        }

        return $return;
    }
}