Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

tests: more reorder testing in peersync 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1291843 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Yonik Seeley 2012-02-21 15:07:39 +00:00
parent 9911c1de35
commit 7e6c8fa33b
1 changed files with 25 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
solr/core/src/test/org/apache/solr/update/PeerSyncTest.java
View File

@ -122,8 +122,6 @@ public class PeerSyncTest extends BaseDistributedSearchTestCase {
assertSync(client1, numVersions, true, shardsArr[0]); assertSync(client1, numVersions, true, shardsArr[0]);
client0.commit(); client1.commit(); queryAndCompare(params("q", "*:*", "sort","_version_ desc"), client0, client1); client0.commit(); client1.commit(); queryAndCompare(params("q", "*:*", "sort","_version_ desc"), client0, client1);
// test delete and deleteByQuery // test delete and deleteByQuery
v=1000; v=1000;
add(client0, seenLeader, sdoc("id","1000","_version_",++v)); add(client0, seenLeader, sdoc("id","1000","_version_",++v));
@ -153,7 +151,31 @@ public class PeerSyncTest extends BaseDistributedSearchTestCase {
add(client, seenLeader, sdoc("id","2002","_version_",++v)); add(client, seenLeader, sdoc("id","2002","_version_",++v));
del(client, params("leader","true","_version_",Long.toString(-++v)), "2000"); del(client, params("leader","true","_version_",Long.toString(-++v)), "2000");
// assertSync(client1, numVersions, true, shardsArr[0]); assertSync(client1, numVersions, true, shardsArr[0]);
client0.commit(); client1.commit(); queryAndCompare(params("q", "*:*", "sort","_version_ desc"), client0, client1);
//
// Test that handling reorders work when applying docs retrieved from peer
//
// this should cause us to retrieve the delete (but not the following add)
// the reorder in application shouldn't affect anything
add(client0, seenLeader, sdoc("id","3000","_version_",3001));
add(client1, seenLeader, sdoc("id","3000","_version_",3001));
del(client0, params("leader","true","_version_","3000"), "3000");
// this should cause us to retrieve an add tha was previously deleted
add(client0, seenLeader, sdoc("id","3001","_version_",3003));
del(client0, params("leader","true","_version_","3001"), "3004");
del(client1, params("leader","true","_version_","3001"), "3004");
// this should cause us to retrieve an older add that was overwritten
add(client0, seenLeader, sdoc("id","3002","_version_",3004));
add(client0, seenLeader, sdoc("id","3002","_version_",3005));
add(client1, seenLeader, sdoc("id","3002","_version_",3005));
assertSync(client1, numVersions, true, shardsArr[0]);
client0.commit(); client1.commit(); queryAndCompare(params("q", "*:*", "sort","_version_ desc"), client0, client1); client0.commit(); client1.commit(); queryAndCompare(params("q", "*:*", "sort","_version_ desc"), client0, client1);
} }