protected function AcquiaPurgeProcessorRuntime::processQueueChunk in Acquia Purge 7

Attempt to process a chunk from the queue.

When processing already occurred earlier during this request, it can occur that this call will not process anything anymore. AcquiaPurgeCapacity keeps the number of claimable items per request and can reach 0 when other processors already called ::process() before.

Parameters

bool $log: (optional) Whether diagnostic failure should be logged or not.

Overrides AcquiaPurgeProcessorBase::processQueueChunk

3 calls to AcquiaPurgeProcessorRuntime::processQueueChunk()

AcquiaPurgeProcessorRuntime::onExit in lib/processor/AcquiaPurgeProcessorRuntime.php

Implements event onExit.

AcquiaPurgeProcessorRuntime::onShutdown in lib/processor/AcquiaPurgeProcessorRuntime.php

Custom shutdown function from which we check if work needs to be done.

AcquiaPurgeProcessorRuntime::__destruct in lib/processor/AcquiaPurgeProcessorRuntime.php

Destruct a AcquiaPurgeProcessorRuntime instance.

File

lib/processor/AcquiaPurgeProcessorRuntime.php, line 53

Contains AcquiaPurgeProcessorRuntime.

Class

AcquiaPurgeProcessorRuntime

Processes the queue at the end of EVERY request.

Code

protected function processQueueChunk($log = TRUE) {
  if (!$this->processingOccurred) {
    parent::processQueueChunk($log);
    $this->processingOccurred = TRUE;
  }
}