org.nuxeo.elasticsearch.core

Class IndexingMonitor

java.lang.Object

org.nuxeo.elasticsearch.core.IndexingMonitor

public class IndexingMonitor
extends Object

Monitor indexing state

Since:

7.2

Field Summary

Fields

Modifier and Type	Field and Description
static Condition	indexingDone

Constructor Summary

Constructors

Constructor and Description
IndexingMonitor()

Method Summary

Methods

Modifier and Type	Method and Description
void	decrementWorker() Decrement worker and running worker counts
int	getPendingWorkerCount()
int	getRunningWorkerCount()
int	getTotalWorkerCount()
void	incrementRunningWorker()
void	incrementWorker()
void	waitForWorkerToComplete() Return when there are no active worker.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

indexingDone

public static final Condition indexingDone

Constructor Detail

IndexingMonitor

public IndexingMonitor()

Method Detail

getTotalWorkerCount

public int getTotalWorkerCount()

getPendingWorkerCount

public int getPendingWorkerCount()

getRunningWorkerCount

public int getRunningWorkerCount()

incrementWorker

public void incrementWorker()

incrementRunningWorker

public void incrementRunningWorker()

decrementWorker

public void decrementWorker()

Decrement worker and running worker counts

waitForWorkerToComplete

public void waitForWorkerToComplete()

Return when there are no active worker.