Модели управления процессами¶

ProcessManager централизует проверку процессов Linux, завершение работы, проверку PID-файлов и блокировку cron. Он заменяет разрозненные специальные проверки posix_kill, ps и /proc.

Основные операции¶

Проверьте, запущен ли процесс¶

ProcessManager::isRunning(int $pid, ?string $exe = null): bool

без $exe: проверяет наличие /proc/{pid}
с помощью $exe: проверяет имя исполняемого файла с помощью /proc/{pid}/exe

Проверьте именованный процесс¶

ProcessManager::isNamedProcessRunning(
    int $pid,
    string $processName,
    int|string $identifier,
    ?string $exe = null
): bool

Соответствует шаблону командной строки NAME[ID] (для работников, основанных на названии процесса).

Проверка потокового процесса¶

ProcessManager::isStreamRunning(int $pid, int $streamId): bool

ffmpeg: проверяет шаблон вывода для конкретного потока в командной строке
xc_fanout: только собственный ремультиплексор (xc_fanout remux … /<id>_.m3u8) — демонический процесс сам по себе использует исполняемый файл, но не называет список воспроизведения потока
php: считается активным для контекста stream worker

Для запроса "есть ли что-нибудь наблюдающий в этом потоке" используйте StreamProcess::isWatched($streamId, $monitorPid): monitor_pid контролируемого потока принадлежит демону xc_fanout, который isMonitorAlive() (an XC_VM[<id>] PHP-процесс) справедливо отклоняет.

Больше проверок и помощников¶

ProcessManager::isStreamAlive($pid, $streamID): bool     // loose: stream ID appears in the ffmpeg/php cmdline (case-insensitive) — no output check
ProcessManager::isMonitorAlive($pid, $streamID, $exe = null): bool  // the stream's watchdog (MonitorCommand) is alive
ProcessManager::startMonitor($streamID, $restart = 0): bool         // (re)spawn the watchdog for a stream (returns true)
ProcessManager::isNginxRunning(): bool
ProcessManager::getProcessAge($pid): int                 // seconds since the process started (from /proc mtime)
ProcessManager::findProcessPIDs(array $terms, $limit = 0): array     // pids whose cmdline matches ANY of $terms (first match wins)
ProcessManager::isAnyProcessRunning(array $terms): bool

isStreamRunning() - это проверка более строгий: она подтверждает командную строку процесса ffmpeg ссылается на этот поток выходные файлы ({id}_.m3u8 / {id}_%d.ts), т.е. на самом деле это создающий этот поток. isStreamAlive() - это более точное, нечувствительное к регистру соответствие подстроки в идентификатор потока в командной строке — дешевле, но он не проверяет вывод. Используйте isStreamRunning(), когда "создается ли этот поток?" имеет значение, isStreamAlive() для краткости "это процесс для этого идентификатора поблизости?".

Процессор и память для каждого потока¶

ProcessManager::resourceSample($pid): ?array          // ['ticks' => CPU ticks so far, 'rss' => bytes, 'at' => microtime, 'start' => ticks after boot]
ProcessManager::cpuPercent(array $now, array $prev): ?float   // percent of ONE core between two samples
ProcessManager::cpuPercentSinceStart(array $sample): ?float   // lifetime average, as `ps` shows it
ProcessManager::producerKind($pid): ?string           // 'fanout' (xc_fanout remux) | 'ffmpeg' | 'php'

Считывается непосредственно из /proc/PID/stat (поля 14/15 для CPU, 24 для RSS; размер страницы является производным из собственного значения этого процесса statm против status, поскольку 64 тыс. Страниц являются нормальными для arm64). Процессор в /proc is cumulative, so a percentage needs two samples: cpuPercent() returns null when the pair ничего не говорит — ни о предыдущих показаниях, ни о двух показаниях за один и тот же момент, ни о счетчике, который отключился. в обратном направлении, потому что производитель перезапустился в том же потоке.

cron:streams производит выборку каждого запущенного потока один раз за проход и сводит результат к этому JSON-файл потока progress_info (cpu, mem, producer). Значение, полученное при следующем проходе, вычитается из хранится рядом с файлами потока в <streams>/<id>_.usage (удаляется вместе с остальными файлами <id>_* когда поток прекращается) — узел-локальная бухгалтерия, так что это не зависит от того, переживет ли он поездку туда и обратно через строку базы данных также перезаписывается другой код. Там, где нет пригодного для использования предыдущего чтения (a первый проход производителя или новый pid после перезапуска) указывается среднее время жизни, поэтому столбец сразу показывает цифру. Время, необходимое для этого, определяется временем начала процесса в /proc/PID/stat по сравнению с /proc/uptime, а не с /proc/PID mtime, который устанавливается, когда что-то сначала просматривает каталог и может быть намного позже, чем в начале.

Только узел, запускающий поток, может считывать свой собственный /proc, поэтому выборка происходит там и перемещается на панель в строке, которую cron уже записывает; список потоков администратора отображает это как столбец Ресурсы (значок производителя, процент процессора, объем оперативной памяти).

Завершение процесса¶

ProcessManager::kill(int $pid, int $signal = SIGKILL): bool

Используйте SIGTERM для плавного завершения работы, когда это возможно.

Блокировка Cron¶

ProcessManager::acquireCronLock(string $pidFile, int $maxAge = 1800): bool

Поведение:

активная блокировка -> завершает текущий запуск
устаревшая блокировка (старше $maxAge секунд) -> удалена и заменена
в случае успеха -> записывает текущий PID в файл блокировки и возвращает true

Крайний случай. acquireCronLock() регистрирует ли нет обработчик завершения работы — он никогда автоматически снимает блокировку при выходе. Блокировка восстанавливается только в том случае, если при последующем запуске обнаруживается, что она старше $maxAge. Так что следите за тем, чтобы $maxAge было удобно выше реального времени выполнения задания (медленный, но живой запуск в прошлом $maxAge может быть восстановлено ошибочно), и не полагайтесь на то, что блокировка исчезнет в момент выполнения задания заканчивает.

`/proc` Проверить кэш¶

isRunning() использует короткий TTL-кэш для /proc проверок (1 секунда), чтобы сократить количество повторных операций ввода-вывода в узких циклах.

Ловушка. Поскольку результат кэшируется в течение ~1 секунды, процесс, который завершается (или запускается) внутри этого окно по—прежнему считывается в своем предыдущем состоянии - жесткий цикл может воздействовать на устаревшее "запущенное"/ "мертвое" окно. ответ. Вызовите ProcessManager::clearCache(), чтобы удалить кэш, когда вам понадобится новое чтение (например, сразу после удаления pid и перед его повторной проверкой).

Соглашение об именовании¶

Общий формат названия процесса:

XC_VM[{id}] — сторожевой таймер для каждого потока (MonitorCommand, созданный startMonitor())
Thumbnail[{id}] — генератор миниатюр для потока {id}
TVArchive[{id}] — регистратор временного сдвига/архивирования для потока {id}

Рабочие задают эти заголовки с помощью cli_set_process_title(); isNamedProcessRunning() и findProcessPIDs() соответствует им (смотрите список демонов в Инструменты CLI и ссылка на консоль).

Запуск подпроцессов: `Thread` и `Multithread`¶

ProcessManager проверяет и уничтожает существующий процессов. Для запуск новых процессов из PHP:

Thread (src/Core/Process/Thread.php) — тонкая оболочка proc_open вокруг одного фоновая команда (запустите ее, опросите/дождитесь ее, прочитайте ее выходные данные).
Multithread (src/Core/Process/Multithread.php) — запускает несколько команд оболочки. одновременно и собирает выходные данные каждого из них; используйте его для разветвленной работы (например, для проверки многих исходники сразу), а не ручной цикл proc_open.

Связанные файлы¶

Файл	Цель
`src/Core/Process/ProcessManager.php`	технологические операции
`src/Core/Process/Multithread.php`	многопоточные помощники
`src/Core/Process/Thread.php`	обертка для нитей
`src/bootstrap.php`	Контекст процесса CLI