50 lines
937 B
PHP
50 lines
937 B
PHP
<?php
|
|
|
|
namespace Icinga\Module\Director\Job;
|
|
|
|
use Icinga\Module\Director\Db;
|
|
use Icinga\Module\Director\Objects\DirectorJob;
|
|
|
|
class JobRunner
|
|
{
|
|
public function __construct(Db $db)
|
|
{
|
|
$this->db = $db;
|
|
}
|
|
|
|
public function runPendingJobs()
|
|
{
|
|
foreach ($this->getConfiguredJobs() as $job) {
|
|
if ($job->shouldRun()) {
|
|
$this->run($job);
|
|
}
|
|
}
|
|
}
|
|
|
|
protected function run(DirectorJob $job)
|
|
{
|
|
if ($this->shouldFork()) {
|
|
$this->fork($job);
|
|
} else {
|
|
$job->run();
|
|
}
|
|
}
|
|
|
|
protected function fork(DirectorJob $job)
|
|
{
|
|
$cmd = 'icingacli director job run ' . $job->id;
|
|
$output = `$cmd`;
|
|
}
|
|
|
|
protected function shouldFork()
|
|
{
|
|
return false;
|
|
return true;
|
|
}
|
|
|
|
protected function getConfiguredJobs()
|
|
{
|
|
return DirectorJob::loadAll($this->db);
|
|
}
|
|
}
|