. /** * Task executor for adhoc tasks. * * @package tool_task * @copyright 2018 Andrew Nicols * @license http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later */ define('CLI_SCRIPT', true); require(__DIR__ . '/../../../../config.php'); require_once("{$CFG->libdir}/clilib.php"); require_once("{$CFG->libdir}/cronlib.php"); list($options, $unrecognized) = cli_get_params( [ 'execute' => false, 'help' => false, 'keep-alive' => 0, 'showsql' => false, 'showdebugging' => false, ], [ 'h' => 'help', 'e' => 'execute', 'k' => 'keep-alive', ] ); if ($unrecognized) { $unrecognized = implode("\n ", $unrecognized); cli_error(get_string('cliunknowoption', 'admin', $unrecognized)); } if ($options['help'] or empty($options['execute'])) { $help = <<set_debug(true); } if (CLI_MAINTENANCE) { echo "CLI maintenance mode active, cron execution suspended.\n"; exit(1); } if (moodle_needs_upgrading()) { echo "Moodle upgrade pending, cron execution suspended.\n"; exit(1); } if (empty($options['execute'])) { exit(0); } if (empty($options['keep-alive'])) { $options['keep-alive'] = 0; } if (!empty($CFG->showcronsql)) { $DB->set_debug(true); } if (!empty($CFG->showcrondebugging)) { set_debugging(DEBUG_DEVELOPER, true); } core_php_time_limit::raise(); // Increase memory limit. raise_memory_limit(MEMORY_EXTRA); // Emulate normal session - we use admin account by default. cron_setup_user(); // Start output log. $timestart = time(); $timenow = $timestart; $finishtime = $timenow + (int)$options['keep-alive']; $humantimenow = date('r', $timenow); mtrace("Server Time: {$humantimenow}\n"); // Run all adhoc tasks. $taskcount = 0; $waiting = false; while (!\core\task\manager::static_caches_cleared_since($timestart)) { $task = \core\task\manager::get_next_adhoc_task($timenow); if ($task) { if ($waiting) { cli_writeln(''); } $waiting = false; cron_run_inner_adhoc_task($task); $taskcount++; unset($task); } else { if (time() > $finishtime) { break; } if (!$waiting) { cli_write('Waiting for more adhoc tasks to be queued '); } else { cli_write('.'); } $waiting = true; sleep(1); $timenow = time(); } } if ($waiting) { cli_writeln(''); } mtrace("Ran {$taskcount} adhoc tasks found at {$humantimenow}");