Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use isClosed method 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1341528 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Yonik Seeley 2012-05-22 15:25:47 +00:00
parent 2b3ce2d435
commit 2e2c70c6ae
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java
View File

@ -134,7 +134,7 @@ public class RecoveryStrategy extends Thread implements SafeStopThread {
ModifiableSolrParams solrParams = new ModifiableSolrParams(); ModifiableSolrParams solrParams = new ModifiableSolrParams();
solrParams.set(ReplicationHandler.MASTER_URL, leaderUrl + "replication"); solrParams.set(ReplicationHandler.MASTER_URL, leaderUrl + "replication");
if (close) retries = INTERRUPTED; if (isClosed()) retries = INTERRUPTED;
boolean success = replicationHandler.doFetch(solrParams, true); // TODO: look into making sure force=true does not download files we already have boolean success = replicationHandler.doFetch(solrParams, true); // TODO: look into making sure force=true does not download files we already have
if (!success) { if (!success) {
@ -269,7 +269,7 @@ public class RecoveryStrategy extends Thread implements SafeStopThread {
} }
} }
while (!successfulRecovery && !close && !isInterrupted()) { // don't use interruption or it will close channels though while (!successfulRecovery && !isClosed() && !isInterrupted()) { // don't use interruption or it will close channels though
try { try {
// first thing we just try to sync // first thing we just try to sync
zkController.publish(core.getCoreDescriptor(), ZkStateReader.RECOVERING); zkController.publish(core.getCoreDescriptor(), ZkStateReader.RECOVERING);