mirror of
https://github.com/Alfresco/SearchServices.git
synced 2025-10-08 14:51:20 +00:00
Merged HEAD-BUG-FIX (5.0/Cloud) to HEAD (5.0/Cloud)
85044: Merged PLATFORM1 (5.0/Cloud) to HEAD-BUG-FIX (5.0/Cloud) 84314: ACE-1037: SOLR 4 - Information server implementation - the rest - report and checking index git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@85359 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
@@ -16,8 +16,8 @@
|
|||||||
* You should have received a copy of the GNU Lesser General Public License
|
* You should have received a copy of the GNU Lesser General Public License
|
||||||
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
|
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
|
||||||
*/
|
*/
|
||||||
package org.alfresco.solr;
|
|
||||||
|
|
||||||
|
package org.alfresco.solr;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This class was moved from org.alfresco.solr.tracker.CoreTracker
|
* This class was moved from org.alfresco.solr.tracker.CoreTracker
|
||||||
@@ -48,6 +48,9 @@ public class TrackerState
|
|||||||
private volatile boolean running = false;
|
private volatile boolean running = false;
|
||||||
|
|
||||||
private volatile boolean checkedFirstTransactionTime = false;
|
private volatile boolean checkedFirstTransactionTime = false;
|
||||||
|
private volatile boolean checkedFirstAclTransactionTime = false;
|
||||||
|
private volatile boolean checkedLastAclTransactionTime = false;
|
||||||
|
private volatile boolean checkedLastTransactionTime = false;
|
||||||
|
|
||||||
private volatile boolean check = false;
|
private volatile boolean check = false;
|
||||||
|
|
||||||
@@ -55,7 +58,7 @@ public class TrackerState
|
|||||||
|
|
||||||
private long lastGoodChangeSetCommitTimeInIndex;
|
private long lastGoodChangeSetCommitTimeInIndex;
|
||||||
|
|
||||||
private long lastGoodTxCommitTimeInIndex ;
|
private long lastGoodTxCommitTimeInIndex;
|
||||||
|
|
||||||
private long timeBeforeWhichThereCanBeNoHoles;
|
private long timeBeforeWhichThereCanBeNoHoles;
|
||||||
|
|
||||||
@@ -229,22 +232,63 @@ public class TrackerState
|
|||||||
this.timeBeforeWhichThereCanBeNoHoles = timeBeforeWhichThereCanBeNoHoles;
|
this.timeBeforeWhichThereCanBeNoHoles = timeBeforeWhichThereCanBeNoHoles;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
/*
|
||||||
|
* (non-Javadoc)
|
||||||
* @see java.lang.Object#toString()
|
* @see java.lang.Object#toString()
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public String toString()
|
public String toString()
|
||||||
{
|
{
|
||||||
return "TrackerState [lastChangeSetIdOnServer="
|
return "TrackerState [lastChangeSetIdOnServer=" + lastChangeSetIdOnServer
|
||||||
+ lastChangeSetIdOnServer + ", lastChangeSetCommitTimeOnServer=" + lastChangeSetCommitTimeOnServer + ", lastIndexedChangeSetId=" + lastIndexedChangeSetId
|
+ ", lastChangeSetCommitTimeOnServer=" + lastChangeSetCommitTimeOnServer
|
||||||
+ ", lastIndexedTxCommitTime=" + lastIndexedTxCommitTime + ", lastIndexedTxId=" + lastIndexedTxId + ", lastIndexedChangeSetCommitTime="
|
+ ", lastIndexedChangeSetId=" + lastIndexedChangeSetId
|
||||||
+ lastIndexedChangeSetCommitTime + ", lastTxCommitTimeOnServer=" + lastTxCommitTimeOnServer + ", lastTxIdOnServer=" + lastTxIdOnServer
|
+ ", lastIndexedTxCommitTime=" + lastIndexedTxCommitTime
|
||||||
+ ", lastIndexedTxIdBeforeHoles=" + lastIndexedTxIdBeforeHoles + ", lastIndexedChangeSetIdBeforeHoles=" + lastIndexedChangeSetIdBeforeHoles + ", running="
|
+ ", lastIndexedTxId=" + lastIndexedTxId
|
||||||
+ running + ", checkedFirstTransactionTime=" + checkedFirstTransactionTime + ", check=" + check + ", timeToStopIndexing=" + timeToStopIndexing
|
+ ", lastIndexedChangeSetCommitTime=" + lastIndexedChangeSetCommitTime
|
||||||
+ ", lastGoodChangeSetCommitTimeInIndex=" + lastGoodChangeSetCommitTimeInIndex + ", lastGoodTxCommitTimeInIndex=" + lastGoodTxCommitTimeInIndex
|
+ ", lastTxCommitTimeOnServer=" + lastTxCommitTimeOnServer
|
||||||
|
+ ", lastTxIdOnServer=" + lastTxIdOnServer
|
||||||
|
+ ", lastIndexedTxIdBeforeHoles=" + lastIndexedTxIdBeforeHoles
|
||||||
|
+ ", lastIndexedChangeSetIdBeforeHoles=" + lastIndexedChangeSetIdBeforeHoles
|
||||||
|
+ ", running=" + running
|
||||||
|
+ ", checkedFirstTransactionTime=" + checkedFirstTransactionTime
|
||||||
|
+ ", checkedFirstAclTransactionTime=" + this.checkedFirstAclTransactionTime
|
||||||
|
+ ", checkedLastTransactionTime=" + this.checkedLastTransactionTime
|
||||||
|
+ ", checkedLastAclTransactionTime=" + this.checkedLastAclTransactionTime
|
||||||
|
+ ", check=" + check
|
||||||
|
+ ", timeToStopIndexing=" + timeToStopIndexing
|
||||||
|
+ ", lastGoodChangeSetCommitTimeInIndex=" + lastGoodChangeSetCommitTimeInIndex
|
||||||
|
+ ", lastGoodTxCommitTimeInIndex=" + lastGoodTxCommitTimeInIndex
|
||||||
+ ", timeBeforeWhichThereCanBeNoHoles=" + timeBeforeWhichThereCanBeNoHoles + "]";
|
+ ", timeBeforeWhichThereCanBeNoHoles=" + timeBeforeWhichThereCanBeNoHoles + "]";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public boolean isCheckedFirstAclTransactionTime()
|
||||||
|
{
|
||||||
|
return checkedFirstAclTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCheckedFirstAclTransactionTime(boolean checkedFirstAclTransactionTime)
|
||||||
|
{
|
||||||
|
this.checkedFirstAclTransactionTime = checkedFirstAclTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean isCheckedLastTransactionTime()
|
||||||
|
{
|
||||||
|
return checkedLastTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCheckedLastTransactionTime(boolean checkedLastTransactionTime)
|
||||||
|
{
|
||||||
|
this.checkedLastTransactionTime = checkedLastTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean isCheckedLastAclTransactionTime()
|
||||||
|
{
|
||||||
|
return checkedLastAclTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCheckedLastAclTransactionTime(boolean checkedLastAclTransactionTime)
|
||||||
|
{
|
||||||
|
this.checkedLastAclTransactionTime = checkedLastAclTransactionTime;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -366,12 +366,11 @@ public class IndexHealthReport
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param txid
|
* @param dbId
|
||||||
*/
|
*/
|
||||||
public void setDuplicatedUnindexedInIndex(long txid)
|
public void setDuplicatedUnindexedInIndex(long dbId)
|
||||||
{
|
{
|
||||||
duplicatedUnindexedInIndex.set(txid);
|
duplicatedUnindexedInIndex.set(dbId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -383,11 +382,11 @@ public class IndexHealthReport
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param txid
|
* @param dbId
|
||||||
*/
|
*/
|
||||||
public void setDuplicatedErrorInIndex(long txid)
|
public void setDuplicatedErrorInIndex(long dbId)
|
||||||
{
|
{
|
||||||
duplicatedErrorInIndex.set(txid);
|
duplicatedErrorInIndex.set(dbId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -57,8 +57,8 @@ public class SOLRAPIClientFactoryTest
|
|||||||
when(props.getProperty("alfresco.port.ssl", "8443")).thenReturn("8443");
|
when(props.getProperty("alfresco.port.ssl", "8443")).thenReturn("8443");
|
||||||
when(props.getProperty("alfresco.maxTotalConnections", "40")).thenReturn("40");
|
when(props.getProperty("alfresco.maxTotalConnections", "40")).thenReturn("40");
|
||||||
when(props.getProperty("alfresco.maxHostConnections", "40")).thenReturn("40");
|
when(props.getProperty("alfresco.maxHostConnections", "40")).thenReturn("40");
|
||||||
when(props.getProperty("alfresco.socketTimeout", "0")).thenReturn("0");
|
when(props.getProperty("alfresco.socketTimeout", "60000")).thenReturn("0");
|
||||||
when(props.getProperty("alfresco.secureComms", "https")).thenReturn("none");
|
when(props.getProperty("alfresco.secureComms", "none")).thenReturn("none");
|
||||||
when(props.getProperty("alfresco.encryption.ssl.keystore.location",
|
when(props.getProperty("alfresco.encryption.ssl.keystore.location",
|
||||||
"ssl.repo.client.keystore")).thenReturn("ssl.repo.client.keystore");
|
"ssl.repo.client.keystore")).thenReturn("ssl.repo.client.keystore");
|
||||||
when(props.getProperty("alfresco.encryption.ssl.truststore.location",
|
when(props.getProperty("alfresco.encryption.ssl.truststore.location",
|
||||||
|
Reference in New Issue
Block a user