You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2018/01/08 03:07:54 UTC
lucene-solr:jira/solr-11702: SOLR-11702: Remove unused imports of
RecoveringCoreTermWatcher
Repository: lucene-solr
Updated Branches:
refs/heads/jira/solr-11702 0311218a5 -> 9fd8c4494
SOLR-11702: Remove unused imports of RecoveringCoreTermWatcher
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/9fd8c449
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/9fd8c449
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/9fd8c449
Branch: refs/heads/jira/solr-11702
Commit: 9fd8c449461177dcbd081b9abd55b04faad6c0fc
Parents: 0311218
Author: Cao Manh Dat <da...@apache.org>
Authored: Mon Jan 8 10:07:40 2018 +0700
Committer: Cao Manh Dat <da...@apache.org>
Committed: Mon Jan 8 10:07:40 2018 +0700
----------------------------------------------------------------------
.../org/apache/solr/cloud/RecoveringCoreTermWatcher.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/9fd8c449/solr/core/src/java/org/apache/solr/cloud/RecoveringCoreTermWatcher.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/cloud/RecoveringCoreTermWatcher.java b/solr/core/src/java/org/apache/solr/cloud/RecoveringCoreTermWatcher.java
index ff06b99..13737d3 100644
--- a/solr/core/src/java/org/apache/solr/cloud/RecoveringCoreTermWatcher.java
+++ b/solr/core/src/java/org/apache/solr/cloud/RecoveringCoreTermWatcher.java
@@ -18,15 +18,15 @@
package org.apache.solr.cloud;
import java.lang.invoke.MethodHandles;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
-import org.apache.solr.core.CoreDescriptor;
import org.apache.solr.core.SolrCore;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/**
+ * Start recovery of a core if its term is less than leader's term
+ */
public class RecoveringCoreTermWatcher implements ZkShardTerms.CoreTermWatcher {
private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
private final SolrCore solrCore;
@@ -34,7 +34,7 @@ public class RecoveringCoreTermWatcher implements ZkShardTerms.CoreTermWatcher {
// the idea here is with a specific term of a replica, we only do recovery one
private final AtomicLong lastTermDoRecovery;
- public RecoveringCoreTermWatcher(SolrCore solrCore) {
+ RecoveringCoreTermWatcher(SolrCore solrCore) {
this.solrCore = solrCore;
this.lastTermDoRecovery = new AtomicLong(-1);
}