PhabricatorTaskmasterDaemon.php
51cb7a3db9e8master

PhabricatorTaskmasterDaemon.php
View Options

			<?php

			final class PhabricatorTaskmasterDaemon extends PhabricatorDaemon {

			protected function run() {
			do {
			PhabricatorCaches::destroyRequestCache();

			$tasks = id(new PhabricatorWorkerLeaseQuery())
			->setLimit(1)
			->execute();

			if ($tasks) {
			$this->willBeginWork();

			foreach ($tasks as $task) {
			$id = $task->getID();
			$class = $task->getTaskClass();

			$this->log(pht('Working on task %d (%s)...', $id, $class));

			$task = $task->executeTask();
			$ex = $task->getExecutionException();
			if ($ex) {
			if ($ex instanceof PhabricatorWorkerPermanentFailureException) {
			// NOTE: Make sure these reach the daemon log, even when not
			// running in verbose mode. See T12803 for discussion.
			$log_exception = new PhutilProxyException(
			pht(
			'Task "%s" encountered a permanent failure and was '.
			'cancelled.',
			$id),
			$ex);
			phlog($log_exception);
			} else if ($ex instanceof PhabricatorWorkerYieldException) {
			$this->log(pht('Task %s yielded.', $id));
			} else {
			$this->log(pht('Task %d failed!', $id));
			throw new PhutilProxyException(
			pht('Error while executing Task ID %d.', $id),
			$ex);
			}
			} else {
			$this->log(pht('Task %s complete! Moved to archive.', $id));
			}
			}

			$sleep = 0;
			} else {

			if ($this->getIdleDuration() > 15) {
			$hibernate_duration = phutil_units('3 minutes in seconds');
			if ($this->shouldHibernate($hibernate_duration)) {
			break;
			}
			}

			// When there's no work, sleep for one second. The pool will
			// autoscale down if we're continuously idle for an extended period
			// of time.
			$this->willBeginIdle();
			$sleep = 1;
			}

			$this->sleep($sleep);
			} while (!$this->shouldExit());
			}

			}