org.alfresco.solr.tracker

Class AclTracker

java.lang.Object

org.alfresco.solr.tracker.AbstractTracker

org.alfresco.solr.tracker.AclTracker

All Implemented Interfaces:

Tracker

public class AclTracker
extends AbstractTracker

Multithreaded ACL Tracker implementation.

Author:

Matt Ward

Nested Class Summary

Nested classes/interfaces inherited from interface org.alfresco.solr.tracker.Tracker

Tracker.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

Fields inherited from class org.alfresco.solr.tracker.AbstractTracker

alfrescoVersion, batchCount, client, coreName, infoSrv, isMaster, isSlave, props, rollback, runPostModelLoadInit, SHARD_METHOD_ACLID, SHARD_METHOD_DBID, shardCount, shardInstance, shardMethod, shardTemplate, state, storeRef, threadHandler, TIME_STEP_1_HR_IN_MS, TIME_STEP_32_DAYS_IN_MS, trackerStats, transformContent, type

Constructor Summary

Constructors

Constructor and Description
AclTracker(Properties p, SOLRAPIClient client, String coreName, InformationServer informationServer)

Method Summary

Modifier and Type	Method and Description
void	addAclChangeSetToIndex(Long aclChangeSetToIndex)
void	addAclChangeSetToPurge(Long aclChangeSetToPurge)
void	addAclChangeSetToReindex(Long aclChangeSetToReindex)
void	addAclToIndex(Long aclToIndex)
void	addAclToPurge(Long aclToPurge)
void	addAclToReindex(Long aclToReindex)
AclReport	checkAcl(Long aclid)
IndexHealthReport	checkIndex(Long toTx, Long toAclTx, Long fromTime, Long toTime)
protected void	doTrack() Subclasses must implement behaviour that completes the following steps, in order: Purge Reindex Index Track repository
List<Long>	getAclsForDbAclTransaction(Long acltxid)
protected Long	getChangeSetFromCommitTime(BoundedDeque<AclChangeSet> changeSetsFound, long lastGoodChangeSetCommitTimeInIndex)
List<Node>	getFullNodesForDbTransaction(Long txid)
protected AclChangeSets	getSomeAclChangeSets(BoundedDeque<AclChangeSet> changeSetsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
boolean	hasMaintenance()
protected void	indexAcl(List<AclReaders> aclReaderList, boolean overwrite)
protected void	indexAclChangeSets()
protected void	indexAcls()
void	invalidateState()
void	maintenance()
protected void	purgeAclChangeSets()
protected void	purgeAcls()
protected void	reindexAclChangeSets()
protected void	reindexAcls()
protected void	trackAclChangeSets()
protected void	trackRepository()

Methods inherited from class org.alfresco.solr.tracker.AbstractTracker

checkShutdown, getAlfrescoVersion, getMaxLiveSearchers, getProps, getRollback, getRunLock, getTrackerState, getType, getWriteLock, setRollback, setShutdown, shutdown, track, waitForAsynchronous

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

Constructor Detail

AclTracker

public AclTracker(Properties p,
                  SOLRAPIClient client,
                  String coreName,
                  InformationServer informationServer)

Method Detail

doTrack

protected void doTrack()
                throws Throwable

Description copied from class: AbstractTracker

Subclasses must implement behaviour that completes the following steps, in order:

1. Purge
2. Reindex
3. Index
4. Track repository

Specified by:

doTrack in class AbstractTracker

Throws:

Throwable

maintenance

public void maintenance()
                 throws Exception

Throws:

Exception

hasMaintenance

public boolean hasMaintenance()

indexAclChangeSets

protected void indexAclChangeSets()
                           throws org.alfresco.httpclient.AuthenticationException,
                                  IOException,
                                  org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

indexAcls

protected void indexAcls()
                  throws org.alfresco.httpclient.AuthenticationException,
                         IOException,
                         org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

reindexAclChangeSets

protected void reindexAclChangeSets()
                             throws org.alfresco.httpclient.AuthenticationException,
                                    IOException,
                                    org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

reindexAcls

protected void reindexAcls()
                    throws org.alfresco.httpclient.AuthenticationException,
                           IOException,
                           org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

purgeAclChangeSets

protected void purgeAclChangeSets()
                           throws org.alfresco.httpclient.AuthenticationException,
                                  IOException,
                                  org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

purgeAcls

protected void purgeAcls()
                  throws org.alfresco.httpclient.AuthenticationException,
                         IOException,
                         org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

addAclChangeSetToReindex

public void addAclChangeSetToReindex(Long aclChangeSetToReindex)

addAclChangeSetToIndex

public void addAclChangeSetToIndex(Long aclChangeSetToIndex)

addAclChangeSetToPurge

public void addAclChangeSetToPurge(Long aclChangeSetToPurge)

addAclToReindex

public void addAclToReindex(Long aclToReindex)

addAclToIndex

public void addAclToIndex(Long aclToIndex)

addAclToPurge

public void addAclToPurge(Long aclToPurge)

trackRepository

protected void trackRepository()
                        throws IOException,
                               org.alfresco.httpclient.AuthenticationException,
                               org.json.JSONException

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

getChangeSetFromCommitTime

protected Long getChangeSetFromCommitTime(BoundedDeque<AclChangeSet> changeSetsFound,
                                          long lastGoodChangeSetCommitTimeInIndex)

Parameters:

changeSetsFound - BoundedDeque

lastGoodChangeSetCommitTimeInIndex - long

Returns:

Long

getSomeAclChangeSets

protected AclChangeSets getSomeAclChangeSets(BoundedDeque<AclChangeSet> changeSetsFound,
                                             Long fromCommitTime,
                                             long timeStep,
                                             int maxResults,
                                             long endTime)
                                      throws org.alfresco.httpclient.AuthenticationException,
                                             IOException,
                                             org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

indexAcl

protected void indexAcl(List<AclReaders> aclReaderList,
                        boolean overwrite)
                 throws IOException

Parameters:

aclReaderList - List

overwrite - boolean

Throws:

IOException

checkIndex

public IndexHealthReport checkIndex(Long toTx,
                                    Long toAclTx,
                                    Long fromTime,
                                    Long toTime)
                             throws org.alfresco.httpclient.AuthenticationException,
                                    IOException,
                                    org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

getFullNodesForDbTransaction

public List<Node> getFullNodesForDbTransaction(Long txid)

getAclsForDbAclTransaction

public List<Long> getAclsForDbAclTransaction(Long acltxid)

Parameters:

acltxid - Long

Returns:

List

checkAcl

public AclReport checkAcl(Long aclid)

trackAclChangeSets

protected void trackAclChangeSets()
                           throws org.alfresco.httpclient.AuthenticationException,
                                  IOException,
                                  org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

invalidateState

public void invalidateState()

Specified by:

invalidateState in interface Tracker

Overrides:

invalidateState in class AbstractTracker