You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2021/03/09 19:05:12 UTC

[lucene-solr] 04/09: @1428 Tweak cache.

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch reference_impl_dev
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git

commit ec1ef1291d0790e2aec573197baf0ee0dda2f3b1
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Sat Mar 6 13:59:58 2021 -0600

    @1428 Tweak cache.
    
    Took 11 minutes
---
 solr/core/src/java/org/apache/solr/cloud/ZkSolrResourceLoader.java | 4 ++--
 solr/test-framework/src/java/org/apache/solr/SolrTestCase.java     | 2 ++
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/solr/core/src/java/org/apache/solr/cloud/ZkSolrResourceLoader.java b/solr/core/src/java/org/apache/solr/cloud/ZkSolrResourceLoader.java
index 9449813..dd9f337 100644
--- a/solr/core/src/java/org/apache/solr/cloud/ZkSolrResourceLoader.java
+++ b/solr/core/src/java/org/apache/solr/cloud/ZkSolrResourceLoader.java
@@ -48,7 +48,7 @@ public class ZkSolrResourceLoader extends SolrResourceLoader implements Resource
   private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
   private final SolrZkClient zkClient;
 
-  private static Map CONFIG_CACHE = new ReferenceMap(ReferenceMap.HARD, ReferenceMap.WEAK) {
+  public static Map CONFIG_CACHE = new ReferenceMap(ReferenceMap.HARD, ReferenceMap.WEAK) {
     {
       purgeBeforeRead();
       purgeBeforeWrite();
@@ -94,7 +94,7 @@ public class ZkSolrResourceLoader extends SolrResourceLoader implements Resource
         } catch (KeeperException | InterruptedException e) {
           throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, e);
         }
-        if (checkStat != null && checkStat.getVersion() <= cached.getStat().getVersion()) {
+        if (checkStat != null && checkStat.getVersion() == cached.getStat().getVersion()) {
           return new ZkSolrResourceLoader.ZkByteArrayInputStream(cached.getBytes(), cached.getStat());
         }
 
diff --git a/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java b/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
index bfb382f..6aec83c 100644
--- a/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
+++ b/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
@@ -43,6 +43,7 @@ import org.apache.lucene.util.RunListenerPrintReproduceInfo;
 import org.apache.lucene.util.TestRuleMarkFailure;
 import org.apache.solr.client.solrj.impl.Http2SolrClient;
 import org.apache.solr.client.solrj.impl.HttpClientUtil;
+import org.apache.solr.cloud.ZkSolrResourceLoader;
 import org.apache.solr.common.AlreadyClosedException;
 import org.apache.solr.common.ParWork;
 import org.apache.solr.common.ParWorkExecutor;
@@ -590,6 +591,7 @@ public class SolrTestCase extends Assert {
       Http2SolrClient.resetSslContextFactory();
       TestInjection.reset();
       JSONTestUtil.failRepeatedKeys = false;
+      ZkSolrResourceLoader.CONFIG_CACHE.clear();
       random = null;
       reusedKeys = null;
       sslConfig = null;