class DocumentIndexDaemonThreaded

Traits

Constants

private QUEUE_CHECK_INTERVAL

private JOBS_PER_THREAD

private SQL_GENERIC_LIMIT

private MAX_REQUEUE_RETRIES

Methods

__construct(SystemDaemon $DaemonControllerObject)

DocumentIndexDaemonThreaded constructor.

prepare()

Initializes the index process.

bool
process()

Main Daemon Process used to orchestrate all working threads Important: Must not contain any blocking operations

processDocumentIndexByHooks(DocumentIndex $document_index, string $status, int $user_id)

Loads all index hooks and executes them to process the document index.

processMaintenance()

Run various Maintenance Tasks

bool
processNextJob()

Processes a single job Fetches a single job and executes all relevant tasks. If finished it calls itself again until the jobs per thread limit is reached.

bool
processThread()

Main Processing Function which is being called per Thread

setMaxThreads(int $maxThreads)

No description

Details

at line 54
__construct(SystemDaemon $DaemonControllerObject)

DocumentIndexDaemonThreaded constructor.

Parameters

SystemDaemon $DaemonControllerObject

at line 72
prepare()

Initializes the index process.

Prepares the process by requeue jobs in case of a restart/crash, create missing document indexes and delete all old document indexes in batch mode.

at line 89
bool process()

Main Daemon Process used to orchestrate all working threads Important: Must not contain any blocking operations

Return Value

bool

in DaemonHelperTrait at line 22
processDocumentIndexByHooks(DocumentIndex $document_index, string $status, int $user_id)

Loads all index hooks and executes them to process the document index.

Parameters

DocumentIndex $document_index
string $status
int $user_id

at line 337
processMaintenance()

Run various Maintenance Tasks

at line 232
bool processNextJob()

Processes a single job Fetches a single job and executes all relevant tasks. If finished it calls itself again until the jobs per thread limit is reached.

(Must be PUBLIC as it is being used as a callback)

Return Value

bool

TRUE if no job is left to be processed

at line 207
bool processThread()

Main Processing Function which is being called per Thread

Return Value

bool

at line 62
setMaxThreads(int $maxThreads)

No description

Parameters

int $maxThreads

Sets the number of the maximum Threads which should be used for processing