Package io.jmix.search.index.impl

Class IndexingLocker

java.lang.Object

io.jmix.search.index.impl.IndexingLocker

@Component("search_IndexingLocker")
public class IndexingLocker
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,ReentrantLock>	enqueueAllLocks
protected final Map<String,ReentrantLock>	enqueueingSessionOperationLocks
protected final IndexConfigurationManager	indexConfigurationManager
protected final ReentrantLock	indexingQueueProcessingLock
protected final ReentrantLock	reindexingLock

Constructor Summary

Constructors

Constructor	Description
IndexingLocker(IndexConfigurationManager indexConfigurationManager)

Method Summary

Modifier and Type	Method	Description
protected ReentrantLock	acquireEnqueueingSessionLock(String entityName)
protected void	checkEntityInIndexingScope(String entityName)
boolean	isQueueProcessingLocked()
boolean	isReindexingLocked()
boolean	tryLockEnqueueingSession(String entityName)
boolean	tryLockEnqueueingSession(String entityName, long timeout, TimeUnit unit)
boolean	tryLockEntityForEnqueueIndexAll(String entityName)
boolean	tryLockQueueProcessing()
boolean	tryLockQueueProcessing(long timeout, TimeUnit unit)
boolean	tryLockReindexing()
boolean	tryLockReindexing(long timeout, TimeUnit unit)
void	unlockEnqueueingSession(String entityName)
void	unlockEntityForEnqueueIndexAll(String entityName)
void	unlockQueueProcessing()
void	unlockReindexing()

Methods inherited from class java.lang.Object

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

Field Details

indexingQueueProcessingLock

protected final ReentrantLock indexingQueueProcessingLock

reindexingLock

protected final ReentrantLock reindexingLock

enqueueAllLocks

protected final Map<String,ReentrantLock> enqueueAllLocks

enqueueingSessionOperationLocks

protected final Map<String,ReentrantLock> enqueueingSessionOperationLocks

indexConfigurationManager

protected final IndexConfigurationManager indexConfigurationManager

Constructor Details

IndexingLocker

@Autowired
public IndexingLocker(IndexConfigurationManager indexConfigurationManager)

Method Details

tryLockQueueProcessing

public boolean tryLockQueueProcessing()

tryLockQueueProcessing

public boolean tryLockQueueProcessing(long timeout,
 TimeUnit unit)
                               throws InterruptedException

Throws:

InterruptedException

unlockQueueProcessing

public void unlockQueueProcessing()

isQueueProcessingLocked

public boolean isQueueProcessingLocked()

tryLockReindexing

public boolean tryLockReindexing()

tryLockReindexing

public boolean tryLockReindexing(long timeout,
 TimeUnit unit)
                          throws InterruptedException

Throws:

InterruptedException

unlockReindexing

public void unlockReindexing()

isReindexingLocked

public boolean isReindexingLocked()

tryLockEntityForEnqueueIndexAll

public boolean tryLockEntityForEnqueueIndexAll(String entityName)

unlockEntityForEnqueueIndexAll

public void unlockEntityForEnqueueIndexAll(String entityName)

tryLockEnqueueingSession

public boolean tryLockEnqueueingSession(String entityName)

tryLockEnqueueingSession

public boolean tryLockEnqueueingSession(String entityName,
 long timeout,
 TimeUnit unit)

unlockEnqueueingSession

public void unlockEnqueueingSession(String entityName)

acquireEnqueueingSessionLock

protected ReentrantLock acquireEnqueueingSessionLock(String entityName)

checkEntityInIndexingScope

protected void checkEntityInIndexingScope(String entityName)