From 2e2c70c6aead63f3d7cfabdb2a0b0450f9d32557 Mon Sep 17 00:00:00 2001 From: Yonik Seeley Date: Tue, 22 May 2012 15:25:47 +0000 Subject: [PATCH] use isClosed method git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1341528 13f79535-47bb-0310-9956-ffa450edef68 --- .../core/src/java/org/apache/solr/cloud/RecoveryStrategy.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java b/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java index e3d7eff3d51..6cca4cf3f91 100644 --- a/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java +++ b/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java @@ -134,7 +134,7 @@ public class RecoveryStrategy extends Thread implements SafeStopThread { ModifiableSolrParams solrParams = new ModifiableSolrParams(); 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 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 { // first thing we just try to sync zkController.publish(core.getCoreDescriptor(), ZkStateReader.RECOVERING);