composer/iTop
6
0
Fork 0
mirror of https://github.com/Combodo/iTop.git synced 2026-05-19 07:12:26 +02:00
Code Issues Packages Projects Releases Wiki Activity

N°1342 cron task validity checks :

Browse Source 
* checks are now made one by one
* new class_exists() test

SVN:trunk[5371]
This commit is contained in:
Pierre Goiffon
2018-02-27 15:20:55 +00:00
parent 3b3f4044cb
commit d8c141b1c9
1 changed files with 37 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
webservices/cron.php
View File

@@ -169,23 +169,47 @@ function CronExec($oP, $aProcesses, $bVerbose)
// Reset the next planned execution to take into account new settings // Reset the next planned execution to take into account new settings
$oSearch = new DBObjectSearch('BackgroundTask'); $oSearch = new DBObjectSearch('BackgroundTask');
/** @var DBObjectSet $oTasks */
$oTasks = new DBObjectSet($oSearch); $oTasks = new DBObjectSet($oSearch);
while ($oTask = $oTasks->Fetch()) while (
/** @var BackgroundTask $oTask */
$oTask = $oTasks->Fetch())
{ {
$sTaskClass = $oTask->Get('class_name'); if ($oTask->Get('status') != 'active')
$oRefClass = new ReflectionClass($sTaskClass);
$oNow = new DateTime();
if ($oRefClass->implementsInterface('iScheduledProcess') && (($oTask->Get('status') != 'active') || ($oTask->Get('next_run_date') > $oNow->format('Y-m-d H:i:s'))))
{ {
if ($bVerbose) continue;
{
$oP->p("Resetting the next run date for $sTaskClass");
}
$oProcess = $aProcesses[$sTaskClass];
$oNextOcc = $oProcess->GetNextOccurrence();
$oTask->Set('next_run_date', $oNextOcc->format('Y-m-d H:i:s'));
$oTask->DBUpdate();
} }
$oNow = new DateTime();
if ($oTask->Get('next_run_date') > $oNow->format('Y-m-d H:i:s'))
{
continue;
}
$sTaskClass = $oTask->Get('class_name');
if (!class_exists($sTaskClass)) // we could also try/catch when instanciating ReflectionClass, but sometimes old recipes are good too ;)
{
$oP->p("ERROR : the background task was paused because it references the non existing class '$sTaskClass'");
$oTask->Set('status', 'paused');
$oTask->DBUpdate();
continue;
}
$oRefClass = new ReflectionClass($sTaskClass);
if (!$oRefClass->implementsInterface('iScheduledProcess'))
{
continue;
}
if ($bVerbose)
{
$oP->p("Resetting the next run date for $sTaskClass");
}
$oProcess = $aProcesses[$sTaskClass];
$oNextOcc = $oProcess->GetNextOccurrence();
$oTask->Set('next_run_date', $oNextOcc->format('Y-m-d H:i:s'));
$oTask->DBUpdate();
} }
$iCronSleep = MetaModel::GetConfig()->Get('cron_sleep'); $iCronSleep = MetaModel::GetConfig()->Get('cron_sleep');