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 2017/12/14 09:35:47 UTC
lucene-solr:jira/solr-11702: SOLR-11702: Hardness
ZkShardTermsTest.testCoreTermWatcher
Repository: lucene-solr
Updated Branches:
refs/heads/jira/solr-11702 f881a62a6 -> 40c96032f
SOLR-11702: Hardness ZkShardTermsTest.testCoreTermWatcher
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/40c96032
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/40c96032
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/40c96032
Branch: refs/heads/jira/solr-11702
Commit: 40c96032f8fcdbb1e128173eb47d94ff6d1b1a43
Parents: f881a62
Author: Cao Manh Dat <da...@apache.org>
Authored: Thu Dec 14 16:35:26 2017 +0700
Committer: Cao Manh Dat <da...@apache.org>
Committed: Thu Dec 14 16:35:26 2017 +0700
----------------------------------------------------------------------
solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/40c96032/solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java b/solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java
index 32a4723..dc2084a 100644
--- a/solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java
+++ b/solr/core/src/test/org/apache/solr/cloud/ZkShardTermsTest.java
@@ -170,12 +170,13 @@ public class ZkShardTermsTest extends SolrCloudTestCase {
}
}
- public void testCoreTermWatcher() {
+ public void testCoreTermWatcher() throws InterruptedException {
String collection = "coreTermWatcher";
ZkShardTerms leaderTerms = new ZkShardTerms(collection, "shard1", cluster.getZkClient());
leaderTerms.registerTerm("leader");
ZkShardTerms replicaTerms = new ZkShardTerms(collection, "shard1", cluster.getZkClient());
replicaTerms.registerTerm("replica");
+ waitFor(2, () -> replicaTerms.getTerms().size());
AtomicInteger count = new AtomicInteger(0);
// this will get called for almost 2 times
@@ -191,10 +192,11 @@ public class ZkShardTermsTest extends SolrCloudTestCase {
replicaTerms.close();
}
- private <T> void waitFor(T expected, Supplier<T> supplier) {
+ private <T> void waitFor(T expected, Supplier<T> supplier) throws InterruptedException {
TimeOut timeOut = new TimeOut(2, TimeUnit.SECONDS);
while (!timeOut.hasTimedOut()) {
if (expected == supplier.get()) return;
+ Thread.sleep(100);
}
assertEquals(expected, supplier.get());
}