mirror of https://github.com/apache/lucene.git
Patches autocommit max docs test to be less time-sensitive
git-svn-id: https://svn.apache.org/repos/asf/lucene/solr/trunk@503169 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
dcbcfd7e8f
commit
a77b94cfe4
|
@ -68,7 +68,7 @@ public class AutoCommitTest extends AbstractSolrTestCase {
|
||||||
DirectUpdateHandler2 updater = (DirectUpdateHandler2)SolrCore.getSolrCore().getUpdateHandler();
|
DirectUpdateHandler2 updater = (DirectUpdateHandler2)SolrCore.getSolrCore().getUpdateHandler();
|
||||||
DirectUpdateHandler2.CommitTracker tracker = updater.tracker;
|
DirectUpdateHandler2.CommitTracker tracker = updater.tracker;
|
||||||
tracker.timeUpperBound = -1;
|
tracker.timeUpperBound = -1;
|
||||||
tracker.docsUpperBound = 5;
|
tracker.docsUpperBound = 14;
|
||||||
|
|
||||||
XmlUpdateRequestHandler handler = new XmlUpdateRequestHandler();
|
XmlUpdateRequestHandler handler = new XmlUpdateRequestHandler();
|
||||||
handler.init( null );
|
handler.init( null );
|
||||||
|
@ -79,7 +79,7 @@ public class AutoCommitTest extends AbstractSolrTestCase {
|
||||||
// Add a single document
|
// Add a single document
|
||||||
SolrQueryResponse rsp = new SolrQueryResponse();
|
SolrQueryResponse rsp = new SolrQueryResponse();
|
||||||
SolrQueryRequestBase req = new SolrQueryRequestBase( core, params ) {};
|
SolrQueryRequestBase req = new SolrQueryRequestBase( core, params ) {};
|
||||||
for( int i=0; i<15; i++ ) {
|
for( int i=0; i<14; i++ ) {
|
||||||
req.setContentStreams( toContentStreams(
|
req.setContentStreams( toContentStreams(
|
||||||
adoc("id", "A"+i, "subject", "info" ), null ) );
|
adoc("id", "A"+i, "subject", "info" ), null ) );
|
||||||
handler.handleRequest( req, rsp );
|
handler.handleRequest( req, rsp );
|
||||||
|
@ -88,6 +88,9 @@ public class AutoCommitTest extends AbstractSolrTestCase {
|
||||||
assertQ("shouldn't find any", req("id:A1") ,"//result[@numFound=0]" );
|
assertQ("shouldn't find any", req("id:A1") ,"//result[@numFound=0]" );
|
||||||
assertEquals( 0, tracker.autoCommitCount );
|
assertEquals( 0, tracker.autoCommitCount );
|
||||||
|
|
||||||
|
req.setContentStreams( toContentStreams(
|
||||||
|
adoc("id", "A14", "subject", "info" ), null ) );
|
||||||
|
handler.handleRequest( req, rsp );
|
||||||
// Wait longer then the autocommit time
|
// Wait longer then the autocommit time
|
||||||
Thread.sleep( 500 );
|
Thread.sleep( 500 );
|
||||||
|
|
||||||
|
@ -96,7 +99,7 @@ public class AutoCommitTest extends AbstractSolrTestCase {
|
||||||
assertEquals( 1, tracker.autoCommitCount );
|
assertEquals( 1, tracker.autoCommitCount );
|
||||||
|
|
||||||
// Now add some more
|
// Now add some more
|
||||||
for( int i=0; i<15; i++ ) {
|
for( int i=0; i<14; i++ ) {
|
||||||
req.setContentStreams( toContentStreams(
|
req.setContentStreams( toContentStreams(
|
||||||
adoc("id", "B"+i, "subject", "info" ), null ) );
|
adoc("id", "B"+i, "subject", "info" ), null ) );
|
||||||
handler.handleRequest( req, rsp );
|
handler.handleRequest( req, rsp );
|
||||||
|
@ -105,7 +108,11 @@ public class AutoCommitTest extends AbstractSolrTestCase {
|
||||||
assertQ("shouldn't find any", req("id:B1") ,"//result[@numFound=0]" );
|
assertQ("shouldn't find any", req("id:B1") ,"//result[@numFound=0]" );
|
||||||
assertEquals( 1, tracker.autoCommitCount );
|
assertEquals( 1, tracker.autoCommitCount );
|
||||||
|
|
||||||
|
req.setContentStreams( toContentStreams(
|
||||||
|
adoc("id", "B14", "subject", "info" ), null ) );
|
||||||
|
handler.handleRequest( req, rsp );
|
||||||
Thread.sleep( 500 );
|
Thread.sleep( 500 );
|
||||||
|
|
||||||
assertQ("should find one", req("id:B1") ,"//result[@numFound=1]" );
|
assertQ("should find one", req("id:B1") ,"//result[@numFound=1]" );
|
||||||
assertEquals( 2, tracker.autoCommitCount );
|
assertEquals( 2, tracker.autoCommitCount );
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue