MikoPBX\Core\System\Processes

Complexity

Total Complexity

80

Size/Duplication

Total Lines	834
Duplicated Lines	0 %

Importance

Changes

0

25 Methods

Rating	Name	Duplication	Size	Complexity
A	isValidAction()	0	3	1
A	mwExecBgWithTimeout()	0	15	3
A	getPidOfProcess()	0	19	2
A	mwExecBg()	0	21	2
A	safeTerminateProcess()	0	23	4
A	mwExec()	0	16	4
A	cleanupStalePidFiles()	0	18	5
B	processPHPWorker()	0	55	7
A	killByName()	0	8	2
A	isProcessRunning()	0	8	2
A	handleWorkerRestart()	0	13	2
A	waitForProcessStart()	0	16	3
A	processWorker()	0	25	3
A	handleStopAction()	0	5	2
B	handleStartAction()	0	57	8
A	handleWorkerStop()	0	6	2
A	getForkedPidFilePath()	0	4	1
A	handleWorkerAction()	0	35	4
A	getPidFilePath()	0	9	2
B	savePidFile()	0	38	8
A	handleRestartAction()	0	69	4
A	restartAllWorkers()	0	9	1
A	mwExecCommands()	0	15	3
A	safeStartDaemon()	0	32	3
A	handleWorkerStart()	0	11	2

<?php

/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2023 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace MikoPBX\Core\System;

use InvalidArgumentException;
use MikoPBX\Core\Workers\Cron\WorkerSafeScriptsCore;
use Phalcon\Di\Di;
use RuntimeException;
use Throwable;

/**
 * Class Processes
 *
 * Manages system and PHP processes with enhanced safety and reliability.
 *
 * @package MikoPBX\Core\System
 */
class Processes
{
    /**
     * Default timeout for background process execution in seconds
    */
    private const DEFAULT_BG_TIMEOUT = 4;

    /**
     * Default number of attempts for safe daemon start
     */
    private const DEFAULT_START_ATTEMPTS = 20;

    /**
     * Default timeout between attempts in microseconds
     */
    private const DEFAULT_ATTEMPT_TIMEOUT = 1000000;

    /**
     * Default output file for process logs
     */
    private const DEFAULT_OUTPUT_FILE = '/dev/null';

    /**
     * Directory for temporary shell scripts
     */
    private const TEMP_SCRIPTS_DIR = '/tmp';

    /**
     * Valid process actions
     */
    private const VALID_ACTIONS = ['start', 'stop', 'restart', 'status'];


    /**
     * Directory for process lock files
     */
    private const LOCK_FILE_DIR = '/var/run/php-workers';
    private const PID_FILE_SUFFIX = '.pid';

    /**
     * Cleans up stale PID files in the workers directory
     * 
     * @return void
     */
    private static function cleanupStalePidFiles(): void
    {
        if (!is_dir(self::LOCK_FILE_DIR)) {
            return;
        }

        $files = glob(self::LOCK_FILE_DIR . '/*' . self::PID_FILE_SUFFIX . '*');
        foreach ($files as $file) {
            // Read PID from file
            $pid = @file_get_contents($file);
            if ($pid === false) {
                @unlink($file);

It seems like you do not handle an error condition for unlink(). This can introduce security issues, and is generally not recommended.

                continue;
            }

            // Check if process is still running
            if (!self::isProcessRunning($pid)) {
                @unlink($file);
            }
        }
    }

    /**
     * Gets the path to the PID file for a given class name
     *
     * @param string $className The class name
     * @param int $instanceNum The instance number (for workers with multiple instances)
     * @return string Path to the PID file
     */
    public static function getPidFilePath(string $className, int $instanceNum = 1): string
    {
        // Ensure PID directory exists
        Util::mwMkdir(self::LOCK_FILE_DIR, true);
        $name = str_replace('\\', '-', $className);
        if ($instanceNum > 1) {
            return self::LOCK_FILE_DIR . "/$name-$instanceNum" . self::PID_FILE_SUFFIX;
        }
        return self::LOCK_FILE_DIR . "/$name" . self::PID_FILE_SUFFIX;
    }

    /**
     * Gets the path to the PID file for a forked process
     *
     * @param string $className The class name
     * @param int $pid Process ID
     * @param int $instanceNum The instance number
     * @return string Path to the forked process PID file
     */
    public static function getForkedPidFilePath(string $className, int $pid, int $instanceNum = 1): string
    {
        $basePidFile = self::getPidFilePath($className, $instanceNum);
        return sprintf('%s.%d', $basePidFile, $pid);
    }

    /**
     * Saves a PID to a file with proper locking
     *
     * @param string $pidFile Path to the PID file
     * @param int $pid Process ID to save
     * @throws RuntimeException If unable to write PID file
     */
    public static function savePidFile(string $pidFile, int $pid): void
    {
        try {
            $pidDir = dirname($pidFile);

            // Ensure PID directory exists
            if (!is_dir($pidDir) && !mkdir($pidDir, 0755, true)) {
                throw new RuntimeException("Could not create PID directory: $pidDir");
            }

            // Use exclusive file creation to avoid race conditions
            $handle = fopen($pidFile, 'c+');
            if ($handle === false) {
                throw new RuntimeException("Could not open PID file: $pidFile");
            }

            if (!flock($handle, LOCK_EX | LOCK_NB)) {
                fclose($handle);
                throw new RuntimeException("Could not acquire lock on PID file: $pidFile");
            }

            // Write PID to file
            if (ftruncate($handle, 0) === false || fwrite($handle, (string)$pid) === false) {
                flock($handle, LOCK_UN);
                fclose($handle);
                throw new RuntimeException("Could not write to PID file: $pidFile");
            }

            flock($handle, LOCK_UN);
            fclose($handle);

        } catch (Throwable $e) {
            SystemMessages::sysLogMsg(
                __CLASS__,
                "Failed to save PID file: " . $e->getMessage(),
                LOG_WARNING
            );
            throw new RuntimeException('PID file operation failed', 0, $e);
        }
    }

    /**
     * Validates process action.
     *
     * @param string $action Action to validate
     * @return bool
     */
    private static function isValidAction(string $action): bool
    {
        return in_array($action, self::VALID_ACTIONS, true);
    }

    /**
     * Checks if a process is running.
     *
     * @param string $processIdOrName Process ID or name
     * @return bool
     */
    public static function isProcessRunning(string $processIdOrName): bool
    {
        if (is_numeric($processIdOrName)) {
            // Check by PID
            return file_exists("/proc/$processIdOrName");
        }
        // Check by process name
        return self::getPidOfProcess($processIdOrName) !== '';
    }

    /**
     * Safely terminates a process with timeout.
     *
     * @param string $pid Process ID to terminate
     * @param int $timeout Timeout in seconds
     * @return bool Success status
     */
    private static function safeTerminateProcess(string $pid, int $timeout = 10): bool
    {
        if (empty($pid)) {
            return false;
        }

        $kill = Util::which('kill');

        // First try SIGTERM
        self::mwExec("$kill -SIGTERM $pid");

        // Wait for process to terminate
        $startTime = time();
        while (time() - $startTime < $timeout) {
            if (!self::isProcessRunning($pid)) {
                return true;
            }
            usleep(100000); // 100ms
        }

        // Force kill if still running
        self::mwExec("$kill -9 $pid");
        return !self::isProcessRunning($pid);
    }


    /**
     * Waits for a process to start.
     *
     * @param string $procName Process name
     * @param string $excludeName Process name to exclude
     * @param int $attempts Maximum number of attempts
     * @param int $timeout Timeout between attempts
     * @return string Process ID or empty string
     */
    private static function waitForProcessStart(
        string $procName,
        string $excludeName,
        int $attempts,
        int $timeout
    ): string {
        $attempt = 1;
        while ($attempt < $attempts) {
            $pid = self::getPidOfProcess($procName, $excludeName);
            if (!empty($pid)) {
                return $pid;
            }
            usleep($timeout);
            $attempt++;
        }
        return '';
    }

    /**
     * Kills a process/daemon by name.
     *
     * @param string $procName The name of the process/daemon to kill.
     * @return int|null The return code of the execution.
     */
    public static function killByName(string $procName): ?int
    {
        if (empty(trim($procName))) {
            throw new InvalidArgumentException('Process name cannot be empty');
        }

        $killallPath = Util::which('killall');
        return self::mwExec($killallPath . ' ' . escapeshellarg($procName));
    }

    /**
     * Executes a command using exec().
     *
     * @param string $command The command to execute.
     * @param array|null $outArr Reference to array for command output.
     * @param int|null $retVal Reference for return value.
     * @return int The return value of the execution.
     * @throws RuntimeException If command is empty.
     */
    public static function mwExec(string $command, ?array &$outArr = null, ?int &$retVal = null): int
    {
        if (empty(trim($command))) {
            throw new RuntimeException('Empty command provided to mwExec');
        }

        $retVal = 0;
        $outArr = [];
        $di = Di::getDefault();

        if ($di !== null && $di->getShared('config')->path('core.debugMode')) {
            echo "mwExec(): $command\n";
        } else {
            exec("$command 2>&1", $outArr, $retVal);
        }
        return $retVal;
    }

    /**
     * Executes a command as a background process with timeout.
     *
     * @param string $command The command to execute.
     * @param int $timeout The timeout value in seconds.
     * @param string $logName The name of the log file.
     */
    public static function mwExecBgWithTimeout(
        string $command,
        int $timeout = self::DEFAULT_BG_TIMEOUT,

The parameter $timeout is not used and could be removed.

        string $logName = self::DEFAULT_OUTPUT_FILE
    ): void {
        $di = Di::getDefault();

        if ($di !== null && $di->getShared('config')->path('core.debugMode')) {
            echo "mwExecBg(): $command\n";
            return;
        }

        $nohup = Util::which('nohup');
        $timeout = Util::which('timeout');
        exec("$nohup $timeout $timeout $command > $logName 2>&1 &");
    }

    /**
     * Executes multiple commands sequentially.
     *
     * @param array $arrCmds The array of commands to execute.
     * @param array|null $out Reference to array for output.
     * @param string $logname The log file name.
     */
    public static function mwExecCommands(array $arrCmds, ?array &$out = [], string $logname = ''): void
    {
        $out = [];
        foreach ($arrCmds as $cmd) {
            $out[] = "$cmd;";
            $outCmd = [];
            self::mwExec($cmd, $outCmd);
            $out = array_merge($out, $outCmd);

It seems like $outCmd can also be of type null; however, parameter $arrays of array_merge() does only seem to accept array, maybe add an additional type check?

        }

        if ($logname !== '') {
            $result = implode("\n", $out);
            file_put_contents(
                self::TEMP_SCRIPTS_DIR . "/{$logname}_commands.log",
                $result
            );
        }
    }

    /**
     * Restarts all workers in a separate process with improved pipeline.
     * 
     * The restart process:
     * 1. Starts WorkerSafeScriptsCore with restart parameter
     * 2. WorkerSafeScriptsCore collects all workers and their forks
     * 3. Starts new instances of each worker
     * 4. Gracefully shuts down old workers
     * 
     */
    public static function restartAllWorkers(): void
    {
        $workerSafeScriptsPath = Util::getFilePathByClassName(WorkerSafeScriptsCore::class);
        $php = Util::which('php');
                
        // First restart WorkerSafeScriptsCore itself
        // This will trigger the full restart pipeline
        $workerSafeScripts = "$php -f $workerSafeScriptsPath restart > /dev/null 2> /dev/null";
        self::mwExec($workerSafeScripts);
    }

    /**
     * Manages a PHP worker process.
     *
     * @param string $className The class name of the PHP worker.
     * @param string $paramForPHPWorker The parameter for the PHP worker.
     * @param string $action The action to perform.
     */
    public static function processPHPWorker(
        string $className,
        string $paramForPHPWorker = 'start',
        string $action = 'restart'
    ): void {
        // Clean up stale PID files before managing workers
        self::cleanupStalePidFiles();

        if (!self::isValidAction($action)) {
            throw new InvalidArgumentException("Invalid action: $action");
        }

        SystemMessages::sysLogMsg(
            __METHOD__,
            "processPHPWorker $className action-$action",
            LOG_DEBUG
        );

        $workerPath = Util::getFilePathByClassName($className);
        if (empty($workerPath) || !class_exists($className)) {
            return;
        }

        $php = Util::which('php');
        $command = "$php -f $workerPath";
        $kill = Util::which('kill');

        $activeProcesses = self::getPidOfProcess($className);
        $processes = array_filter(explode(' ', $activeProcesses));
        $currentProcCount = count($processes);
        
        // Определяем количество нужных экземпляров из maxProc класса
        $neededProcCount = 1; // По умолчанию 1 процесс
        
        if (class_exists($className)) {
            // Получаем значение maxProc из класса
            $reflectionClass = new \ReflectionClass($className);
            if ($reflectionClass->hasProperty('maxProc')) {
                $defaultProperties = $reflectionClass->getDefaultProperties();
                if (isset($defaultProperties['maxProc'])) {
                    $neededProcCount = (int)$defaultProperties['maxProc'];
                }
            }
        }

        self::handleWorkerAction(
            $action,
            $activeProcesses,
            $command,
            $paramForPHPWorker,
            $kill,
            $currentProcCount,
            $neededProcCount,
            $processes,
            $className
        );
    }

    /**
     * Handles worker process actions.
     *
     * @param string $action Action to perform
     * @param string $activeProcesses Active process IDs
     * @param string $command Command to execute
     * @param string $paramForPHPWorker Worker parameters
     * @param string $kill Kill command path
     * @param int $currentProcCount Current process count
     * @param int $neededProcCount Needed process count
     * @param array $processes Process IDs array
     * @param string $className Worker class name
     */
    private static function handleWorkerAction(
        string $action,
        string $activeProcesses,
        string $command,
        string $paramForPHPWorker,
        string $kill,
        int $currentProcCount,
        int $neededProcCount,
        array $processes,
        string $className = ''
    ): void {
        switch ($action) {
            case 'restart':
                self::handleRestartAction(
                    $activeProcesses,
                    $kill,
                    $command,
                    $paramForPHPWorker,
                    $className,
                    $neededProcCount
                );
                break;
            case 'stop':
                self::handleStopAction($activeProcesses, $kill);
                break;
            case 'start':
                self::handleStartAction(
                    $currentProcCount,
                    $neededProcCount,
                    $command,
                    $paramForPHPWorker,
                    $processes,
                    $kill
                );
                break;
        }
    }

    /**
     * Handles the restart action for a worker.
     *
     * @param string $activeProcesses Active process IDs
     * @param string $kill Kill command path
     * @param string $command Command to execute
     * @param string $paramForPHPWorker Worker parameters
     * @param string $workerClass Worker class name
     * @param int $neededProcCount Number of instances needed
     */
    private static function handleRestartAction(
        string $activeProcesses,
        string $kill,
        string $command,
        string $paramForPHPWorker,
        string $workerClass = '',
        int $neededProcCount = 1
    ): void {
        // Отладочное логирование
        SystemMessages::sysLogMsg(
            __METHOD__,
            sprintf(
                "Restarting worker: %s, neededProcCount=%d, activeProcesses=%s",
                $workerClass,
                $neededProcCount,
                $activeProcesses
            ),
            LOG_NOTICE
        );

        if ($activeProcesses !== '') {
            SystemMessages::sysLogMsg(
                __METHOD__,
                sprintf("SEND signal: %s", "SIGUSR1 $activeProcesses"),
                LOG_WARNING
            );

            // Send SIGUSR1 first to initiate graceful shutdown
            self::mwExec("$kill -SIGUSR1 $activeProcesses > /dev/null 2>&1");
            
            // Wait for 2 seconds to allow worker to handle SIGUSR1
            sleep(2);

            SystemMessages::sysLogMsg(
                __METHOD__,
                sprintf("SEND signal: %s", "SIGTERM $activeProcesses"),
                LOG_WARNING
            );

            // Then send SIGTERM
            self::mwExecBg("$kill -SIGTERM $activeProcesses");
        }

        // Запуск воркеров с поддержкой пула
        if ($neededProcCount > 1) {
            SystemMessages::sysLogMsg(
                __METHOD__,
                sprintf("Starting worker pool with %d instances for %s", $neededProcCount, $workerClass),
                LOG_NOTICE
            );
            
            // Запускаем необходимое количество экземпляров
            for ($i = 1; $i <= $neededProcCount; $i++) {
                $instanceParam = " --instance-id={$i}";
                
                SystemMessages::sysLogMsg(
                    __METHOD__,
                    sprintf("Starting worker instance %d/%d: %s", $i, $neededProcCount, $command . " " . $paramForPHPWorker . $instanceParam),
                    LOG_DEBUG
                );
                
                self::mwExecBg("{$command} {$paramForPHPWorker}{$instanceParam}");
                
                // Небольшая задержка между запусками экземпляров для предотвращения конфликтов
                usleep(250000); // 250ms
            }
        } else {
            // Start new instance (for non-pool workers)
            self::mwExecBg("$command $paramForPHPWorker");
        }
    }

    /**
     * Handles the stop action for a worker.
     *
     * @param string $activeProcesses Active process IDs
     * @param string $kill Kill command path
     */
    private static function handleStopAction(string $activeProcesses, string $kill): void
    {
        if ($activeProcesses !== '') {
            self::mwExec("$kill -SIGUSR2 $activeProcesses > /dev/null 2>&1 &");
            self::mwExecBg("$kill -SIGTERM $activeProcesses");
        }
    }

    /**
     * Handles the start action for a worker.
     *
     * @param int $currentProcCount Current process count
     * @param int $neededProcCount Needed process count
     * @param string $command Command to execute
     * @param string $paramForPHPWorker Worker parameters
     * @param array $processes Process IDs array
     * @param string $kill Kill command path
     */
    private static function handleStartAction(
        int $currentProcCount,
        int $neededProcCount,
        string $command,
        string $paramForPHPWorker,
        array $processes,
        string $kill
    ): void {
        if ($currentProcCount === $neededProcCount) {
            return;
        }

        // Добавляем отладочное логирование
        SystemMessages::sysLogMsg(
            __METHOD__,
            sprintf(
                "Starting worker pool: currentCount=%d, neededCount=%d, command=%s",
                $currentProcCount,
                $neededProcCount,
                $command
            ),
            LOG_DEBUG
        );

        if ($neededProcCount > $currentProcCount) {
            // Запускаем новые экземпляры с указанием instance ID
            for ($i = 0; $i < $neededProcCount; $i++) {
                $instanceParam = '';
                // Если мы запускаем больше одного экземпляра, добавляем параметр instanceId
                if ($neededProcCount > 1) {
                    $instanceId = $i + 1; // Нумеруем с 1
                    $instanceParam = " --instance-id={$instanceId}";
                }
                
                // Отладочное логирование
                SystemMessages::sysLogMsg(
                    __METHOD__,
                    sprintf(
                        "Launching instance #%d with command: %s %s%s",
                        ($i+1),
                        $command, 
                        $paramForPHPWorker,
                        $instanceParam
                    ),
                    LOG_DEBUG
                );
                
                self::mwExecBg("{$command} {$paramForPHPWorker}{$instanceParam}");
            }
        } elseif ($currentProcCount > $neededProcCount) {
            $countProc4Kill = $currentProcCount - $neededProcCount;
            for ($i = 0; $i < $countProc4Kill; $i++) {
                if (!isset($processes[$i])) {
                    break;
                }
                self::mwExec("$kill -SIGUSR1 {$processes[$i]} > /dev/null 2>&1 &");
                self::mwExecBg("$kill -SIGTERM {$processes[$i]}");
            }
        }
    }

    /**
     * Retrieves the PID of a process by its name.
     *
     * @param string $name Process name
     * @param string $exclude Process name to exclude
     * @return string Process IDs
     */
    public static function getPidOfProcess(string $name, string $exclude = ''): string
    {
        $ps = Util::which('ps');
        $grep = Util::which('grep');
        $awk = Util::which('awk');

        $name = addslashes($name);
        $filterCmd = '';
        if (!empty($exclude)) {
            $filterCmd = "| $grep -v " . escapeshellarg($exclude);
        }

        $out = [];
        self::mwExec(
            "$ps -A -o 'pid,args' $filterCmd | $grep '$name' | $grep -v grep | $awk '{print $1}'",
            $out
        );

        return trim(implode(' ', $out));

It seems like $out can also be of type null; however, parameter $pieces of implode() does only seem to accept array, maybe add an additional type check?

    }

    /**
     * Executes a command as a background process.
     *
     * @param string $command Command to execute
     * @param string $outFile Output file path
     * @param int $sleepTime Sleep time in seconds
     */
    public static function mwExecBg(
        string $command,
        string $outFile = self::DEFAULT_OUTPUT_FILE,
        int $sleepTime = 0
    ): void {
        $nohup = Util::which('nohup');
        $sh = Util::which('sh');
        $rm = Util::which('rm');
        $sleep = Util::which('sleep');

        if ($sleepTime > 0) {
            $filename = self::TEMP_SCRIPTS_DIR . '/' . time() . '_noop.sh';
            file_put_contents(
                $filename,
                "$sleep $sleepTime; $command; $rm -rf $filename"
            );
            $noopCommand = "$nohup $sh $filename > $outFile 2>&1 &";
        } else {
            $noopCommand = "$nohup $command > $outFile 2>&1 &";
        }
        exec($noopCommand);
    }

    /**
     * Manages a daemon/worker process.
     *
     * @param string $cmd Command to execute
     * @param string $param Command parameters
     * @param string $procName Process name
     * @param string $action Action to perform
     * @param string $outFile Output file path
     *
     * @return array|bool Process status or operation result
     * @throws InvalidArgumentException If action is invalid
     */
    public static function processWorker(
        string $cmd,
        string $param,
        string $procName,
        string $action,
        string $outFile = self::DEFAULT_OUTPUT_FILE
    ): bool|array {
        if (!self::isValidAction($action)) {
            throw new InvalidArgumentException("Invalid action: $action");
        }

        $kill = Util::which('kill');
        $nohup = Util::which('nohup');
        $workerPID = self::getPidOfProcess($procName);

        return match ($action) {
            'status' => [
                'status' => ($workerPID !== '') ? 'Started' : 'Stopped',
                'app' => $procName,
                'PID' => $workerPID
            ],
            'restart' => self::handleWorkerRestart($kill, $workerPID, $nohup, $cmd, $param, $outFile),
            'stop' => self::handleWorkerStop($kill, $workerPID),
            'start' => self::handleWorkerStart($workerPID, $nohup, $cmd, $param, $outFile),
            default => throw new InvalidArgumentException("Unsupported action: $action"),
        };
    }

    /**
     * Handles worker restart operation.
     *
     * @param string $kill Kill command path
     * @param string $workerPID Worker process ID
     * @param string $nohup Nohup command path
     * @param string $cmd Command to execute
     * @param string $param Command parameters
     * @param string $outFile Output file path
     * @return bool
     */
    private static function handleWorkerRestart(
        string $kill,

The parameter $kill is not used and could be removed.

        string $workerPID,
        string $nohup,
        string $cmd,
        string $param,
        string $outFile
    ): bool {
        if ($workerPID !== '') {
            self::safeTerminateProcess($workerPID);
        }
        self::mwExec("$nohup $cmd $param > $outFile 2>&1 &");
        return true;
    }

    /**
     * Handles worker stop operation.
     *
     * @param string $kill Kill command path
     * @param string $workerPID Worker process ID
     * @return bool
     */
    private static function handleWorkerStop(string $kill, string $workerPID): bool

The parameter $kill is not used and could be removed.

    {
        if ($workerPID !== '') {
            self::safeTerminateProcess($workerPID);
        }
        return true;
    }

    /**
     * Handles worker start operation.
     *
     * @param string $workerPID Worker process ID
     * @param string $nohup Nohup command path
     * @param string $cmd Command to execute
     * @param string $param Command parameters
     * @param string $outFile Output file path
     * @return bool
     */
    private static function handleWorkerStart(
        string $workerPID,
        string $nohup,
        string $cmd,
        string $param,
        string $outFile
    ): bool {
        if ($workerPID === '') {
            self::mwExec("$nohup $cmd $param > $outFile 2>&1 &");
        }
        return true;
    }

    /**
     * Starts a daemon process with failure control.
     *
     * @param string $procName Process name
     * @param string $args Process arguments
     * @param int $attemptsCount Number of attempts to start
     * @param int $timeout Timeout between attempts in microseconds
     * @param string $outFile Output file path
     * @return bool Success status
     */
    public static function safeStartDaemon(
        string $procName,
        string $args,
        int $attemptsCount = self::DEFAULT_START_ATTEMPTS,
        int $timeout = self::DEFAULT_ATTEMPT_TIMEOUT,
        string $outFile = self::DEFAULT_OUTPUT_FILE
    ): bool {
        $result = true;
        $baseName = "safe-$procName";
        $safeLink = "/sbin/$baseName";

        try {
            Util::createUpdateSymlink('/etc/rc/worker_reload', $safeLink);
            self::killByName($baseName);
            self::killByName($procName);

            // Start the process in the background
            self::mwExecBg("$safeLink $args", $outFile);

            // Wait for the process to start with timeout
            $pid = self::waitForProcessStart($procName, $baseName, $attemptsCount, $timeout);

            if (empty($pid)) {
                SystemMessages::echoWithSyslog(" - Wait for start '$procName' fail" . PHP_EOL);
                $result = false;
            }
        } catch (Throwable $e) {
            SystemMessages::echoWithSyslog("Error starting daemon '$procName': " . $e->getMessage());
            $result = false;
        }

        return $result;
    }

}