Мощь можества ядер для укрощения кодека AV1

1. Получаем кусочек, сохраняем его в папку
2. Генерим CMD файл с командой для кодирования и удаление самого CMD файла в конце
3. Запускаем CMD файл

1. Есть исходный файл, есть файл результата и есть CMD файл кодирование еще идет
2. Есть исходный файл, есть файл результата и CMD файла нет кодирование завершено

<?phpfunction getRoot(){$root = $_SERVER['DOCUMENT_ROOT'];if (strlen($root) == 0){$root = dirname(__FILE__)."\\..";}return $root;}function getStoragePath(){return getRoot()."\\storage";}function get_total_cpu_cores(){$coresFileName = getRoot()."\\cores.txt";if (file_exists($coresFileName)){return intval(file_get_contents($coresFileName));}return (int) ((PHP_OS_FAMILY == 'Windows')?(getenv("NUMBER_OF_PROCESSORS")+0):substr_count(file_get_contents("/proc/cpuinfo"),"processor"));}function antiHack($str){$strOld = "";while ($strOld != $str){$strOld = $str;  $str = str_replace("\\", "", $str);  $str = str_replace("/", "",$str);  $str = str_replace("|","", $str);  $str = str_replace("..","", $str);}  return $str;}$filesDir = getStoragePath()."\\encfiles";if (!is_dir($filesDir)){mkdir($filesDir);}$resultDir = $filesDir."\\result";if (!is_dir($resultDir)){mkdir($resultDir);}$active = glob($filesDir.'\\*.cmd');$all = glob($resultDir.'\\*.*');$info = ["active" => count($active),"total" => get_total_cpu_cores(),"inProgress" => [],"done" => []];foreach ($all as $key){$pi = pathinfo($key);$commandFile = $pi["filename"].".cmd";$sourceFile = $pi["filename"];if (file_exists($filesDir.'\\'.$sourceFile)){if (file_exists($filesDir.'\\'.$commandFile)){$info["inProgress"][] = $sourceFile;}else{$info["done"][] = $sourceFile;}}}if (isset($_GET["action"])){if ($_GET["action"] == "upload" && isset($_FILES['encfile']) && isset($_POST["params"])){$params = json_decode(hex2bin($_POST["params"]), true);$fileName = $_FILES['encfile']['name'];$fileToProcess = $filesDir."\\".$fileName;move_uploaded_file($_FILES['encfile']['tmp_name'], $fileToProcess);$commandFile = $fileToProcess.".cmd";$resultFile = $resultDir."\\".$fileName.$params["outputExt"];$command = $params["commandLine"];$command = str_replace("%SRC%", $fileToProcess, $command);$command = str_replace("%DST%", $resultFile, $command);$command .= PHP_EOL.'DEL /Q "'.$commandFile.'"';file_put_contents($commandFile, $command);pclose(popen('start "" /B "'.$commandFile.'"', "r"));}if ($_GET["action"] == "info"){header("Content-Type: application/json");echo json_encode($info);die();}if ($_GET["action"] == "get"){if (isset($_POST["name"]) && isset($_POST["params"])){$params = json_decode(hex2bin($_POST["params"]), true);$fileName = antiHack($_POST["name"]);$fileToGet = $filesDir."\\".$fileName;$commandFile = $fileToGet.".cmd";$resultFile = $resultDir."\\".$fileName.$params["outputExt"];if (file_exists($fileToGet) && !file_exists($commandFile) && file_exists($resultFile)){$fp = fopen($resultFile, 'rb');header("Content-Type: application/octet-stream");header("Content-Length: ".filesize($resultFile));fpassthru($fp);exit;}}}if ($_GET["action"] == "remove"){if (isset($_POST["name"]) && isset($_POST["params"])){$params = json_decode(hex2bin($_POST["params"]), true);$fileName = antiHack($_POST["name"]);$fileToGet = $filesDir."\\".$fileName;$commandFile = $fileToGet.".cmd";$resultFile = $resultDir."\\".$fileName.$params["outputExt"];if (file_exists($fileToGet) && !file_exists($commandFile)){if (file_exists($resultFile)){unlink($resultFile);}unlink($fileToGet);header("Content-Type: application/json");echo json_encode([ "result" => true ]);die();}}header("Content-Type: application/json");echo json_encode([ "result" => false ]);die();}}echo "URL Correct";?>

• c:\Apps\OneDrive\commands\bin\ffmpeg\ffmpeg.exe из Zeranoe builds
• c:\Apps\OneDrive\commands\bin\ffmpeg\rav1e.exe из проекта rav1e

$servers = ["LOCAL" => "http://127.0.0.1:8000/remote/encoding.php","SERVER2" => "http://192.168.100.25:8000/remote/encoding.php",];

<?php$ffmpeg = '"c:\Apps\OneDrive\commands\bin\ffmpeg\ffmpeg.exe"';$params = ["commandLine" => '"c:\Apps\OneDrive\commands\bin\ffmpeg\ffmpeg" -i "%SRC%" -an -pix_fmt yuv420p -f yuv4mpegpipe - | "c:\Apps\OneDrive\commands\bin\ffmpeg\rav1e" - -s 5 --quantizer 130  -y --output "%DST%"',"outputExt" => ".ivf"];$paramsData = bin2hex(json_encode($params));$servers = ["LOCAL" => "http://127.0.0.1:8000/remote/encoding.php","SERVER2" => "http://192.168.100.25:8000/remote/encoding.php",];if (isset($argc)){if ($argc > 1){$fileToEncode = $argv[1];$timeBegin = time();$pi = pathinfo($fileToEncode);$filePartName = $pi["dirname"]."\\".$pi["filename"]."_part%04d.mkv";$fileList = $pi["dirname"]."\\".$pi["filename"]."_list.txt";$joinedFileName = $pi["dirname"]."\\".$pi["filename"]."_joined.mkv";$audioFileName = $pi["dirname"]."\\".$pi["filename"]."_audio.opus";$finalFileName = $pi["dirname"]."\\".$pi["filename"]."_AV1.mkv";exec($ffmpeg.' -i "'.$fileToEncode.'" -c copy -an -segment_time 00:00:10 -reset_timestamps 1 -f segment -y "'.$filePartName.'"');exec($ffmpeg.' -i "'.$fileToEncode.'" -vn -acodec libopus -ab 128k -y "'.$audioFileName.'"');$files = glob($pi["dirname"]."\\".$pi["filename"]."_part*.mkv");$sourceParts = $files;$resultParts = [];$resultFiles = [];$inProgress = [];while (count($files) || count($inProgress)){foreach ($servers as $server => $url){if( $curl = curl_init() ){curl_setopt($curl, CURLOPT_URL, $url."?action=info");curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);$out = curl_exec($curl);curl_close($curl);$info = json_decode($out, true);//var_dump($info);if (count($files)){if (intval($info["active"]) < intval($info["total"])){$fileName = $files[0];$key = pathinfo($fileName)["basename"];$inProgress[] = $key;//echo "Server: ".$url."\r\n";echo "Sending part ".$key."[TO ".$server."]...";if (!in_array($key, $info["done"]) && !in_array($key, $info["inProgress"])){$cFile = curl_file_create($fileName);$post = ['encfile'=> $cFile, 'params' => $paramsData];$ch = curl_init();curl_setopt($ch, CURLOPT_URL, $url."?action=upload");curl_setopt($ch, CURLOPT_POST,1);curl_setopt($ch, CURLOPT_POSTFIELDS, $post);curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);$result = curl_exec($ch);curl_close ($ch);}echo " DONE\r\n";echo "  Total: ".count($sourceParts).", In Progress: ".count($inProgress).", Left: ".count($files)."\r\n";$files = array_slice($files, 1);}}if (count($info["done"])){foreach ($info["done"] as $file){if (($key = array_search($file, $inProgress)) !== false){set_time_limit(0);echo "Receiving part ".$file."... [FROM ".$server."]...";$resultFile = $pi["dirname"]."\\".$file.".result".$params["outputExt"];$fp = fopen($resultFile, 'w+');$post = ['name' => $file, 'params' => $paramsData];$ch = curl_init();curl_setopt($ch, CURLOPT_URL, $url."?action=get");curl_setopt($ch, CURLOPT_POST,1);curl_setopt($ch, CURLOPT_POSTFIELDS, $post);curl_setopt($ch, CURLOPT_FILE, $fp); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);//curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);curl_exec($ch); curl_close($ch);//fclose($fp);$resultFiles[] = "file ".$resultFile;$resultParts[] = $resultFile;$post = ['name' => $file, 'params' => $paramsData];$ch = curl_init();curl_setopt($ch, CURLOPT_URL, $url."?action=remove");curl_setopt($ch, CURLOPT_POST,1);curl_setopt($ch, CURLOPT_POSTFIELDS, $post);curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);curl_exec($ch); curl_close($ch);fclose($fp);unset($inProgress[$key]);echo " DONE\r\n";echo "  Total: ".count($sourceParts).", In Progress: ".count($inProgress).", Left: ".count($files)."\r\n";}}}}}usleep(300000);}asort($resultFiles);file_put_contents($fileList, str_replace("\\", "/", implode("\r\n", $resultFiles)));exec($ffmpeg.' -safe 0 -f concat -i "'.$fileList.'" -c copy -y "'.$joinedFileName.'"');exec($ffmpeg.' -i "'.$joinedFileName.'" -i "'.$audioFileName.'" -c copy -y "'.$finalFileName.'"');unlink($fileList);unlink($audioFileName);unlink($joinedFileName);foreach ($sourceParts as $part){unlink($part);}foreach ($resultParts as $part){unlink($part);}echo "Total Time: ".(time() - $timeBegin)."s\r\n";}}?>