Package org.alfresco.solr.tracker

Class AclTracker

java.lang.Object

org.alfresco.solr.tracker.AbstractTracker

org.alfresco.solr.tracker.ActivatableTracker

org.alfresco.solr.tracker.AclTracker

All Implemented Interfaces:

Tracker

public class AclTracker
extends ActivatableTracker

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	Description
protected static org.slf4j.Logger	log

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

isEnabled

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

client, coreName, logger, props, rollback, shardCount, shardInstance, shardKey, shardProperty, state, trackerId, transformContent, type

Constructor Summary

Constructors

Constructor	Description
AclTracker(Properties p, org.alfresco.solr.client.SOLRAPIClient client, String coreName, InformationServer informationServer)

Method Summary

Modifier and Type	Method	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)
org.alfresco.solr.AclReport	checkAcl(Long aclid)
org.alfresco.solr.tracker.IndexHealthReport	checkIndex(Long toTx, Long toAclTx, Long fromTime, Long toTime)
protected void	clearScheduledMaintenanceWork()	Cleans up the scheduled maintenance work collected by this tracker.
protected void	doTrack(String iterationId)	Subclasses must implement behaviour that completes the following steps, in order: Purge Reindex Index Track repository
List<Long>	getAclsForDbAclTransaction(Long acltxid)
protected Long	getChangeSetFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound, long lastGoodChangeSetCommitTimeInIndex)
List<org.alfresco.solr.client.Node>	getFullNodesForDbTransaction(Long txid)
protected org.alfresco.solr.client.AclChangeSets	getSomeAclChangeSets(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
boolean	hasMaintenance()
protected void	indexAcl(List<org.alfresco.solr.client.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.ActivatableTracker

disable, enable, isDisabled, isEnabled, logAndClear, track

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

checkNode, getDocRouter, getProps, getRollback, getTrackerState, getType, getWriteLock, isAlreadyInShutDownMode, setRollback, setShutdown, shutdown

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,
                  org.alfresco.solr.client.SOLRAPIClient client,
                  String coreName,
                  InformationServer informationServer)

Method Detail

doTrack

protected void doTrack(String iterationId)
                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

Parameters:

iterationId - an identifier which is uniquely associated with a given iteration.

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)

clearScheduledMaintenanceWork

protected void clearScheduledMaintenanceWork()

Description copied from class: ActivatableTracker

Cleans up the scheduled maintenance work collected by this tracker.

Overrides:

clearScheduledMaintenanceWork in class ActivatableTracker

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(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.AclChangeSet> changeSetsFound,
                                          long lastGoodChangeSetCommitTimeInIndex)

Parameters:

changeSetsFound - BoundedDeque

lastGoodChangeSetCommitTimeInIndex - long

Returns:

Long

getSomeAclChangeSets

protected org.alfresco.solr.client.AclChangeSets getSomeAclChangeSets(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.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<org.alfresco.solr.client.AclReaders> aclReaderList,
                        boolean overwrite)
                 throws IOException

Parameters:

aclReaderList - List

overwrite - boolean

Throws:

IOException

checkIndex

public org.alfresco.solr.tracker.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<org.alfresco.solr.client.Node> getFullNodesForDbTransaction(Long txid)

getAclsForDbAclTransaction

public List<Long> getAclsForDbAclTransaction(Long acltxid)

Parameters:

acltxid - Long

Returns:

List

checkAcl

public org.alfresco.solr.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