Author: yonik
Date: Tue Sep 29 15:41:49 2009
New Revision: 819990

URL: http://svn.apache.org/viewvc?rev=819990&view=rev
Log:
make the replication test harder by ensuring that the slave generation is 
higher than the master

Modified:
    
lucene/solr/trunk/src/test/org/apache/solr/handler/TestReplicationHandler.java

Modified: 
lucene/solr/trunk/src/test/org/apache/solr/handler/TestReplicationHandler.java
URL: 
http://svn.apache.org/viewvc/lucene/solr/trunk/src/test/org/apache/solr/handler/TestReplicationHandler.java?rev=819990&r1=819989&r2=819990&view=diff
==============================================================================
--- 
lucene/solr/trunk/src/test/org/apache/solr/handler/TestReplicationHandler.java 
(original)
+++ 
lucene/solr/trunk/src/test/org/apache/solr/handler/TestReplicationHandler.java 
Tue Sep 29 15:41:49 2009
@@ -395,9 +395,9 @@
   }
 
   public void testReplicateAfterWrite2Slave() throws Exception {
-
-    //add 500 docs to master
-    for (int i = 0; i < 500; i++) {
+    //add 50 docs to master
+    int nDocs = 50;
+    for (int i = 0; i < nDocs; i++) {
       index(masterClient, "id", i, "name", "name = " + i);
     }
 
@@ -414,8 +414,19 @@
 
     NamedList masterQueryRsp = query("*:*", masterClient);
     SolrDocumentList masterQueryResult = (SolrDocumentList) 
masterQueryRsp.get("response");
-    assertEquals(500, masterQueryResult.getNumFound());
+    assertEquals(nDocs, masterQueryResult.getNumFound());
 
+    // Make sure that both the index version and index generation on the slave 
is
+    // higher than that of the master, just to make the test harder.
+    Thread.sleep(100);
+    index(slaveClient, "id", 551, "name", "name = " + 551);
+    slaveClient.commit(true, true);
+    index(slaveClient, "id", 552, "name", "name = " + 552);
+    slaveClient.commit(true, true);
+    index(slaveClient, "id", 553, "name", "name = " + 553);
+    slaveClient.commit(true, true);
+    index(slaveClient, "id", 554, "name", "name = " + 554);
+    slaveClient.commit(true, true);
     index(slaveClient, "id", 555, "name", "name = " + 555);
     slaveClient.commit(true, true);
 


Reply via email to