org.alfresco.solr.tracker

Class CoreTracker

java.lang.Object

org.alfresco.solr.tracker.CoreTracker

All Implemented Interfaces:

org.apache.solr.core.CloseHook

Direct Known Subclasses:

MultiThreadedCoreTracker

public class CoreTracker
extends Object
implements org.apache.solr.core.CloseHook

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CoreTracker.IndexTrackingShutdownException

Field Summary

Fields

Modifier and Type	Field and Description
protected long	batchCount
protected SOLRAPIClient	client
protected static org.slf4j.Logger	log
protected org.alfresco.solr.tracker.CoreTracker.TrackerState	state
protected org.alfresco.service.cmr.repository.StoreRef	storeRef
protected TrackerStats	trackerStats

Method Summary

Methods

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)
void	addNodeToIndex(Long nodeToIndex)
void	addNodeToPurge(Long nodeToPurge)
void	addNodeToReindex(Long nodeToReindex)
void	addTransactionToIndex(Long transactionToIndex)
void	addTransactionToPurge(Long transactionToPurge)
void	addTransactionToReindex(Long transactionToReindex)
AclReport	checkAcl(Long aclid)
IndexHealthReport	checkIndex(Long fromTx, Long toTx, Long fromAclTx, Long toAclTx, Long fromTime, Long toTime)
NodeReport	checkNode(Long dbid)
NodeReport	checkNode(Node node)
NodeReport	checkNodeCommon(NodeReport nodeReport)
protected void	checkShutdown()
void	close(org.apache.solr.core.SolrCore core)
void	deleteByAclChangeSetId(org.apache.solr.search.SolrIndexSearcher solrIndexSearcher, Long aclChangeSetId)
void	deleteByAclId(org.apache.solr.search.SolrIndexSearcher solrIndexSearcher, Long aclId)
void	ensureFirstModelSync()
List<Long>	getAclsForDbAclTransaction(Long acltxid)
String	getAlfrescoVersion()
protected Long	getChangeSetFromCommitTime(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<AclChangeSet> changeSetsFound, long lastGoodChangeSetCommitTimeInIndex)
org.apache.solr.common.util.NamedList<Object>	getCoreStats()
Set<Long>	getErrorDocIds()
List<Node>	getFullNodesForDbTransaction(Long txid)
long	getLastChangeSetCommitTimeOnServer()
long	getLastChangeSetIdOnServer()
long	getLastIndexedChangeSetCommitTime()
long	getLastIndexedChangeSetId()
long	getLastIndexedTxCommitTime()
long	getLastIndexedTxId()
long	getLastTxCommitTimeOnServer()
long	getLastTxIdOnServer()
int	getMaxLiveSearchers()
Map<String,Set<String>>	getModelErrors()
protected int	getRegisteredSearcherCount()
protected List<org.apache.solr.search.SolrIndexSearcher>	getRegisteredSearchers()
protected org.alfresco.httpclient.AlfrescoHttpClient	getRepoClient(org.apache.solr.core.SolrResourceLoader loader)
protected AclChangeSets	getSomeAclChangeSets(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<AclChangeSet> changeSetsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
protected Transactions	getSomeTransactions(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<Transaction> txnsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
TrackerStats	getTrackerStats()
protected Long	getTxFromCommitTime(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<Transaction> txnsFound, long lastGoodTxCommitTimeInIndex)
protected void	indexAcl(List<AclReaders> aclReaderList, boolean overwrite)
void	indexAclChangeSets()
void	indexAcls()
protected void	indexAclTransaction(AclChangeSet changeSet, boolean overwrite)
protected void	indexNode(Node node, org.apache.solr.search.SolrIndexSearcher solrIndexSearcher, boolean overwrite)
protected void	indexTransaction(Transaction info, boolean overwrite)
boolean	isCheck()
boolean	isRunning()
void	purgeAclChangeSets()
void	purgeAcls()
void	reindexAclChangeSets()
void	reindexAcls()
void	setCheck(boolean check)
static org.apache.lucene.document.Document	toDocument(org.apache.solr.common.SolrInputDocument doc, org.apache.solr.schema.IndexSchema schema, AlfrescoSolrDataModel model)
protected void	trackAclChangeSets()
void	trackModels(boolean onlyFirstTime)
void	trackRepository()
protected void	trackTransactions()
void	updateIndex()

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

client

protected SOLRAPIClient client

state

protected org.alfresco.solr.tracker.CoreTracker.TrackerState state

storeRef

protected org.alfresco.service.cmr.repository.StoreRef storeRef

batchCount

protected long batchCount

trackerStats

protected TrackerStats trackerStats

Method Detail

getLastIndexedTxCommitTime

public long getLastIndexedTxCommitTime()

getLastIndexedChangeSetCommitTime

public long getLastIndexedChangeSetCommitTime()

getLastIndexedTxId

public long getLastIndexedTxId()

getLastIndexedChangeSetId

public long getLastIndexedChangeSetId()

isRunning

public boolean isRunning()

getLastTxCommitTimeOnServer

public long getLastTxCommitTimeOnServer()

getLastChangeSetCommitTimeOnServer

public long getLastChangeSetCommitTimeOnServer()

getLastTxIdOnServer

public long getLastTxIdOnServer()

getLastChangeSetIdOnServer

public long getLastChangeSetIdOnServer()

getTrackerStats

public TrackerStats getTrackerStats()

getModelErrors

public Map<String,Set<String>> getModelErrors()

getMaxLiveSearchers

public int getMaxLiveSearchers()

getRepoClient

protected org.alfresco.httpclient.AlfrescoHttpClient getRepoClient(org.apache.solr.core.SolrResourceLoader loader)

isCheck

public boolean isCheck()

Returns:

the check

setCheck

public void setCheck(boolean check)

Parameters:

check - the check to set

updateIndex

public void updateIndex()

indexAclChangeSets

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

indexAcls

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

reindexAclChangeSets

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

reindexAcls

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

purgeAclChangeSets

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

checkShutdown

protected void checkShutdown()

purgeAcls

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

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

deleteByAclChangeSetId

public void deleteByAclChangeSetId(org.apache.solr.search.SolrIndexSearcher solrIndexSearcher,
                          Long aclChangeSetId)
                            throws IOException

Throws:

IOException

deleteByAclId

public void deleteByAclId(org.apache.solr.search.SolrIndexSearcher solrIndexSearcher,
                 Long aclId)
                   throws IOException

Throws:

IOException

addTransactionToReindex

public void addTransactionToReindex(Long transactionToReindex)

addTransactionToIndex

public void addTransactionToIndex(Long transactionToIndex)

addTransactionToPurge

public void addTransactionToPurge(Long transactionToPurge)

addNodeToReindex

public void addNodeToReindex(Long nodeToReindex)

addNodeToIndex

public void addNodeToIndex(Long nodeToIndex)

addNodeToPurge

public void addNodeToPurge(Long nodeToPurge)

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

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

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

trackTransactions

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

Parameters:

solrIndexSearcher -

reader -

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

trackAclChangeSets

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

Parameters:

reader -

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

getTxFromCommitTime

protected Long getTxFromCommitTime(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<Transaction> txnsFound,
                       long lastGoodTxCommitTimeInIndex)

Parameters:

txnsFound -

lastGoodTxCommitTimeInIndex -

Returns:

getChangeSetFromCommitTime

protected Long getChangeSetFromCommitTime(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<AclChangeSet> changeSetsFound,
                              long lastGoodChangeSetCommitTimeInIndex)

Parameters:

changeSetsFound -

lastGoodChangeSetCommitTimeInIndex -

Returns:

getSomeAclChangeSets

protected AclChangeSets getSomeAclChangeSets(org.alfresco.solr.tracker.CoreTracker.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

getSomeTransactions

protected Transactions getSomeTransactions(org.alfresco.solr.tracker.CoreTracker.BoundedDeque<Transaction> txnsFound,
                               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:

acl -

readers -

Throws:

IOException

indexTransaction

protected void indexTransaction(Transaction info,
                    boolean overwrite)
                         throws IOException

Parameters:

dataModel -

info -

Throws:

IOException

indexAclTransaction

protected void indexAclTransaction(AclChangeSet changeSet,
                       boolean overwrite)
                            throws IOException

Parameters:

dataModel -

info -

Throws:

IOException

indexNode

protected void indexNode(Node node,
             org.apache.solr.search.SolrIndexSearcher solrIndexSearcher,
             boolean overwrite)
                  throws IOException,
                         org.alfresco.httpclient.AuthenticationException,
                         org.json.JSONException

Parameters:

dataModel -

node -

Throws:

IOException

org.json.JSONException

org.alfresco.httpclient.AuthenticationException

checkIndex

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

Parameters:

refCounted -

Throws:

IOException

org.json.JSONException

org.alfresco.httpclient.AuthenticationException

getErrorDocIds

public Set<Long> getErrorDocIds()
                         throws IOException

Throws:

IOException

toDocument

public static org.apache.lucene.document.Document toDocument(org.apache.solr.common.SolrInputDocument doc,
                                             org.apache.solr.schema.IndexSchema schema,
                                             AlfrescoSolrDataModel model)

getRegisteredSearcherCount

protected int getRegisteredSearcherCount()

getRegisteredSearchers

protected List<org.apache.solr.search.SolrIndexSearcher> getRegisteredSearchers()

checkNodeCommon

public NodeReport checkNodeCommon(NodeReport nodeReport)

checkNode

public NodeReport checkNode(Node node)

checkNode

public NodeReport checkNode(Long dbid)

Parameters:

dbid -

Returns:

getFullNodesForDbTransaction

public List<Node> getFullNodesForDbTransaction(Long txid)

getAclsForDbAclTransaction

public List<Long> getAclsForDbAclTransaction(Long acltxid)

Parameters:

acltxid -

Returns:

checkAcl

public AclReport checkAcl(Long aclid)

Parameters:

aclid -

Returns:

close

public void close(org.apache.solr.core.SolrCore core)

Specified by:

close in interface org.apache.solr.core.CloseHook

getCoreStats

public org.apache.solr.common.util.NamedList<Object> getCoreStats()
                                                           throws IOException

Returns:

Throws:

IOException

trackModels

public void trackModels(boolean onlyFirstTime)
                 throws org.alfresco.httpclient.AuthenticationException,
                        IOException,
                        org.json.JSONException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

ensureFirstModelSync

public void ensureFirstModelSync()

getAlfrescoVersion

public String getAlfrescoVersion()

Returns:

Alfresco version Solr was built for