You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by yo...@apache.org on 2012/02/22 23:28:06 UTC
svn commit: r1292553 -
/lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java
Author: yonik
Date: Wed Feb 22 22:28:06 2012
New Revision: 1292553
URL: http://svn.apache.org/viewvc?rev=1292553&view=rev
Log:
tests: make sure dropped buffered docs don't interfere with new additions
Modified:
lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java
Modified: lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java?rev=1292553&r1=1292552&r2=1292553&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java (original)
+++ lucene/dev/trunk/solr/core/src/test/org/apache/solr/search/TestRecovery.java Wed Feb 22 22:28:06 2012
@@ -409,6 +409,35 @@ public class TestRecovery extends SolrTe
,"=={'versions':[206,205,201,200,105,104]}"
);
+ ulog.bufferUpdates();
+ assertEquals(UpdateLog.State.BUFFERING, ulog.getState());
+ updateJ(jsonAdd(sdoc("id","C301", "_version_","998")), params(SEEN_LEADER,SEEN_LEADER_VAL));
+ updateJ(jsonAdd(sdoc("id","C302", "_version_","999")), params(SEEN_LEADER,SEEN_LEADER_VAL));
+ assertTrue(ulog.dropBufferedUpdates());
+
+ // make sure we can overwrite with a lower version
+ // TODO: is this functionality needed?
+ updateJ(jsonAdd(sdoc("id","C301", "_version_","301")), params(SEEN_LEADER,SEEN_LEADER_VAL));
+ updateJ(jsonAdd(sdoc("id","C302", "_version_","302")), params(SEEN_LEADER,SEEN_LEADER_VAL));
+
+ assertU(commit());
+
+ assertJQ(req("qt","/get", "getVersions","2")
+ ,"=={'versions':[302,301]}"
+ );
+
+ assertJQ(req("q", "*:*", "sort","_version_ desc", "fl","id,_version_", "rows","2")
+ , "/response/docs==["
+ + "{'id':'C302','_version_':302}"
+ + ",{'id':'C301','_version_':301}"
+ +"]"
+ );
+
+
+ updateJ(jsonAdd(sdoc("id","C2", "_version_","302")), params(SEEN_LEADER,SEEN_LEADER_VAL));
+
+
+
assertEquals(UpdateLog.State.ACTIVE, ulog.getState()); // leave each test method in a good state
} finally {