BitMaster/main
1
0
Fork 0
mirror of https://github.com/Vateron-Media/XC_VM.git synced 2026-04-07 05:18:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

The isStreamRunning() function has been rewritten to optimize MPEGTS streaming

Browse Source
This commit is contained in:
Divarion-D
2026-01-21 19:13:58 +03:00
parent c6323dacbf
commit 8f1f471df9
1 changed files with 37 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
src/includes/streaming.php
View File

@@ -1207,27 +1207,42 @@ class StreamingUtilities {
}
return false;
}
public static function isStreamRunning($rPID, $rStreamID) {
if (!empty($rPID)) {
clearstatcache(true);
if (!(file_exists('/proc/' . $rPID) && is_readable('/proc/' . $rPID . '/exe'))) {
} else {
if (strpos(basename(readlink('/proc/' . $rPID . '/exe')), 'ffmpeg') === 0) {
$rCommand = trim(file_get_contents('/proc/' . $rPID . '/cmdline'));
if (!(stristr($rCommand, '/' . $rStreamID . '_.m3u8') || stristr($rCommand, '/' . $rStreamID . '_%d.ts'))) {
} else {
return true;
}
} else {
if (strpos(basename(readlink('/proc/' . $rPID . '/exe')), 'php') !== 0) {
} else {
return true;
}
}
}
public static function isStreamRunning($pid, $streamID) {
if ($pid <= 1 || !is_int($pid)) {
return false;
}
return false;
$procDir = "/proc/$pid";
if (!file_exists($procDir)) {
return false;
}
// Опционально — проверяем, что это исполняемый файл (ffmpeg или php)
$exeLink = $procDir . '/exe';
if (!is_link($exeLink)) {
return false;
}
// Если очень важно — можно оставить проверку cmdline, но реже
// (например, кэшировать результат на 3–5 секунд)
static $cache = [];
$cacheKey = $pid . '|' . $streamID;
if (isset($cache[$cacheKey]) && $cache[$cacheKey]['time'] > time() - 4) {
return $cache[$cacheKey]['alive'];
}
$cmd = @file_get_contents("/proc/$pid/cmdline");
if ($cmd === false) {
$alive = false;
} else {
$cmd = str_replace("\0", ' ', $cmd);
$alive = stripos($cmd, $streamID) !== false; // упростил — обычно достаточно
}
$cache[$cacheKey] = ['alive' => $alive, 'time' => time()];
return $alive;
}
public static function isProcessRunning($rPID, $rEXE) {
if (!empty($rPID)) {
@@ -1577,11 +1592,11 @@ class StreamingUtilities {
$rActivePIDs[] = $rPID;
}
}
if (in_array($rActivePIDs, $rAddPID)) {
if (in_array($rAddPID, $rActivePIDs, true)) {
} else {
$rActivePIDs[] = $rAddPID;
}
file_put_contents(SIGNALS_TMP_PATH . 'queue_' . intval($rStreamID), igbinary_serialize($rActivePIDs));
file_put_contents(SIGNALS_TMP_PATH . 'queue_' . intval($rStreamID), igbinary_serialize($rActivePIDs), LOCK_EX);
}
public static function removeFromQueue($rStreamID, $rPID) {
$rActivePIDs = array();
@@ -1592,7 +1607,7 @@ class StreamingUtilities {
}
}
if (0 < count($rActivePIDs)) {
file_put_contents(SIGNALS_TMP_PATH . 'queue_' . intval($rStreamID), igbinary_serialize($rActivePIDs));
file_put_contents(SIGNALS_TMP_PATH . 'queue_' . intval($rStreamID), igbinary_serialize($rActivePIDs), LOCK_EX);
} else {
unlink(SIGNALS_TMP_PATH . 'queue_' . intval($rStreamID));
}