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 2012/07/23 01:42:56 UTC
svn commit: r1364462 - in /lucene/dev/branches/branch_4x: ./ solr/
solr/core/ solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java
Author: markrmiller
Date: Sun Jul 22 23:42:56 2012
New Revision: 1364462
URL: http://svn.apache.org/viewvc?rev=1364462&view=rev
Log:
take out del(*:*) for now and add a couple more asserts
Modified:
lucene/dev/branches/branch_4x/ (props changed)
lucene/dev/branches/branch_4x/solr/ (props changed)
lucene/dev/branches/branch_4x/solr/core/ (props changed)
lucene/dev/branches/branch_4x/solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java
Modified: lucene/dev/branches/branch_4x/solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_4x/solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java?rev=1364462&r1=1364461&r2=1364462&view=diff
==============================================================================
--- lucene/dev/branches/branch_4x/solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java (original)
+++ lucene/dev/branches/branch_4x/solr/core/src/test/org/apache/solr/cloud/SyncSliceTest.java Sun Jul 22 23:42:56 2012
@@ -23,6 +23,7 @@ import java.util.List;
import java.util.Set;
import org.apache.lucene.util.LuceneTestCase.Slow;
+import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrRequest;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
@@ -85,7 +86,8 @@ public class SyncSliceTest extends FullS
waitForThingsToLevelOut();
- del("*:*");
+ // something wrong with this?
+ //del("*:*");
List<String> skipServers = new ArrayList<String>();
@@ -124,6 +126,9 @@ public class SyncSliceTest extends FullS
checkShardConsistency(false, true);
+ long cloudClientDocs = cloudClient.query(new SolrQuery("*:*")).getResults().getNumFound();
+ assertEquals(4, cloudClientDocs);
+
skipServers = new ArrayList<String>();
skipServers.add(shardToJetty.get("shard1").get(random().nextInt(shardCount)).url + "/");
@@ -138,6 +143,9 @@ public class SyncSliceTest extends FullS
waitForThingsToLevelOut();
checkShardConsistency(false, true);
+
+ cloudClientDocs = cloudClient.query(new SolrQuery("*:*")).getResults().getNumFound();
+ assertEquals(5, cloudClientDocs);
}
private void waitForThingsToLevelOut() throws Exception {