PhabricatorSearchWorker.php
View Options

	<?php

	final class PhabricatorSearchWorker extends PhabricatorWorker {

	public static function queueDocumentForIndexing(
	$phid,
	$parameters = null,
	$is_strict = false) {

	if ($parameters === null) {
	$parameters = array();
	}

	parent::scheduleTask(
	__CLASS__,
	array(
	'documentPHID' => $phid,
	'parameters' => $parameters,
	'strict' => $is_strict,
	),
	array(
	'priority' => parent::PRIORITY_INDEX,
	'objectPHID' => $phid,
	));
	}

	protected function doWork() {
	$data = $this->getTaskData();
	$object_phid = idx($data, 'documentPHID');

	// See T12425. By the time we run an indexing task, the object it indexes
	// may have been deleted. This is unusual, but not concerning, and failing
	// to index these objects is correct.

	// To avoid showing these non-actionable errors to users, don't report
	// indexing exceptions unless we're in "strict" mode. This mode is set by
	// the "bin/search index" tool.

	$is_strict = idx($data, 'strict', false);

	try {
	$object = $this->loadObjectForIndexing($object_phid);
	} catch (PhabricatorWorkerPermanentFailureException $ex) {
	if ($is_strict) {
	throw $ex;
	} else {
	return;
	}
	}

	$engine = id(new PhabricatorIndexEngine())
	->setObject($object);

	$parameters = idx($data, 'parameters', array());
	$engine->setParameters($parameters);

	if (!$engine->shouldIndexObject()) {
	return;
	}

	$lock = PhabricatorGlobalLock::newLock(
	'index',
	array(
	'objectPHID' => $object_phid,
	));

	try {
	$lock->lock(1);
	} catch (PhutilLockException $ex) {
	// If we fail to acquire the lock, just yield. It's expected that we may
	// contend on this lock occasionally if a large object receives many
	// updates in a short period of time, and it's appropriate to just retry
	// rebuilding the index later.
	throw new PhabricatorWorkerYieldException(15);
	}

	$caught = null;
	try {
	// Reload the object now that we have a lock, to make sure we have the
	// most current version.
	$object = $this->loadObjectForIndexing($object->getPHID());

	$engine->setObject($object);
	$engine->indexObject();
	} catch (Exception $ex) {
	$caught = $ex;
	}

	// Release the lock before we deal with the exception.
	$lock->unlock();

	if ($caught) {
	if (!($caught instanceof PhabricatorWorkerPermanentFailureException)) {
	$caught = new PhabricatorWorkerPermanentFailureException(
	pht(
	'Failed to update search index for document "%s": %s',
	$object_phid,
	$caught->getMessage()));
	}

	if ($is_strict) {
	throw $caught;
	}
	}
	}

	private function loadObjectForIndexing($phid) {
	$viewer = PhabricatorUser::getOmnipotentUser();

	$object = id(new PhabricatorObjectQuery())
	->setViewer($viewer)
	->withPHIDs(array($phid))
	->executeOne();

	if (!$object) {
	throw new PhabricatorWorkerPermanentFailureException(
	pht(
	'Unable to load object "%s" to rebuild indexes.',
	$phid));
	}

	return $object;
	}

	}

File Metadata

Mime Type: text/x-php
Expires: Thu, Nov 13, 7:10 PM (10 h, 19 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 336496
Default Alt Text: PhabricatorSearchWorker.php (3 KB)

PhabricatorSearchWorker.php
No OneTemporary
Actions

PhabricatorSearchWorker.php
View Options

File Metadata

Event Timeline

PhabricatorSearchWorker.phpNo OneTemporaryActions

PhabricatorSearchWorker.phpView Options

File Metadata

Event Timeline

PhabricatorSearchWorker.php
No OneTemporary
Actions

PhabricatorSearchWorker.php
View Options