Thomas/Piwigo_Bratonien_Tools
1
0
Fork 0
mirror of https://github.com/Terranom674/Piwigo_Bratonien_Tools.git synced 2026-09-19 12:54:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Queue sync warmup until active worker yields

Browse Source
This commit is contained in:
Terranom674
2026-09-03 14:18:04 +02:00
parent 662d22c533
commit 1368c8e5b7
1 changed files with 19 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
runtime/webdav-warmup-dispatch.php
View File

@@ -58,11 +58,17 @@ if (!function_exists('exec'))
}
$worker = realpath(BRATONIEN_TOOLS_PATH.'runtime/lib/webdav-cache-warmup.php');
$priority_waiter = realpath(BRATONIEN_TOOLS_PATH.'runtime/lib/run-webdav-priority-wait.sh');
if (!$worker || !is_file($worker))
{
fwrite(STDERR, "WebDAV-Cache-Warmup-Worker wurde nicht gefunden.\n");
exit(1);
}
if (!$priority_waiter || !is_file($priority_waiter))
{
fwrite(STDERR, "WebDAV-Prioritäts-Warter wurde nicht gefunden.\n");
exit(1);
}
$log = PHPWG_ROOT_PATH.PWG_LOCAL_DIR.'bratonien-webdav-warmup.log';
$result = 0;
@@ -129,14 +135,22 @@ foreach (bratonien_tools_nc_connector_connections() as $connection)
@chmod($priority_file, 0664);
}
// Der Worker schützt nur die kurze produktive Materialisierungsphase eines
// einzelnen Bildes mit webdav-sync.lock. Downloads und Batchgrenzen bleiben
// frei, damit ein Connector-Sync neue Alben erkennen und Stufe 2 sicher
// zwischen zwei vollständig restaurierten Batches priorisieren kann.
$base = escapeshellarg(PHP_BINARY).' '.escapeshellarg($worker)
$worker_command = escapeshellarg(PHP_BINARY).' '.escapeshellarg($worker)
.' --connection-id='.$connection_id
.' --mode='.escapeshellarg($mode);
if ($mode === 'sync')
{
// Ein bereits laufender Worker darf seinen aktuellen Bild-/Batchvorgang
// vollständig restaurieren. Der Waiter startet den priorisierten Sync-Lauf
// danach automatisch, statt die Prioritätsmarke verloren gehen zu lassen.
$base = escapeshellarg('/bin/bash').' '.escapeshellarg($priority_waiter).' '.escapeshellarg($state_dir).' '.$worker_command;
}
else
{
$base = $worker_command;
}
if ($wait)
{
$output = array();