Apache/lucene
1
0
Fork 0
mirror of https://github.com/apache/lucene.git synced 2025-02-08 02:58:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

put multiplier back but disable threads until we can track down why they leak RAM...

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1391921 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael McCandless 2012-09-29 23:15:04 +00:00
parent 42fcded2b7
commit b6c29f4a83
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lucene/test-framework/src/java/org/apache/lucene/index/BasePostingsFormatTestCase.java
View File

@ -170,8 +170,6 @@ public abstract class BasePostingsFormatTestCase extends LuceneTestCase {
int numMediumTerms = 0; int numMediumTerms = 0;
int numBigTerms = 0; int numBigTerms = 0;
int numManyPositions = 0; int numManyPositions = 0;
totalPostings = 0;
totalPayloadBytes = 0;
while (fieldUpto < numFields) { while (fieldUpto < numFields) {
String field = _TestUtil.randomSimpleString(random()); String field = _TestUtil.randomSimpleString(random());
if (fields.containsKey(field)) { if (fields.containsKey(field)) {
@ -202,17 +200,13 @@ public abstract class BasePostingsFormatTestCase extends LuceneTestCase {
if (numBigTerms == 0 || (random().nextInt(10) == 3 && numBigTerms < 2)) { if (numBigTerms == 0 || (random().nextInt(10) == 3 && numBigTerms < 2)) {
// Make at least 1 big term, then maybe (~10% // Make at least 1 big term, then maybe (~10%
// chance) make another: // chance) make another:
// TODO: put multplier back, if we can fix OOMEs: numDocs = RANDOM_MULTIPLIER * _TestUtil.nextInt(random(), 50000, 70000);
//numDocs = RANDOM_MULTIPLIER * _TestUtil.nextInt(random(), 50000, 70000);
numDocs = _TestUtil.nextInt(random(), 50000, 70000);
numBigTerms++; numBigTerms++;
term = "big_" + term; term = "big_" + term;
} else if (numMediumTerms == 0 || (random().nextInt(10) == 3 && numMediumTerms < 5)) { } else if (numMediumTerms == 0 || (random().nextInt(10) == 3 && numMediumTerms < 5)) {
// Make at least 1 medium term, then maybe (~10% // Make at least 1 medium term, then maybe (~10%
// chance) make up to 4 more: // chance) make up to 4 more:
// TODO: put multplier back, if we can fix OOMEs: numDocs = RANDOM_MULTIPLIER * _TestUtil.nextInt(random(), 3000, 6000);
//numDocs = RANDOM_MULTIPLIER * _TestUtil.nextInt(random(), 3000, 6000);
numDocs = _TestUtil.nextInt(random(), 3000, 6000);
numMediumTerms++; numMediumTerms++;
term = "medium_" + term; term = "medium_" + term;
} else if (random().nextBoolean()) { } else if (random().nextBoolean()) {
@ -260,7 +254,7 @@ public abstract class BasePostingsFormatTestCase extends LuceneTestCase {
termPostings.add(posting); termPostings.add(posting);
int freq; int freq;
if (random().nextInt(30) == 17 && numManyPositions < 10) { if (random().nextInt(30) == 17 && numManyPositions < 5) {
freq = _TestUtil.nextInt(random(), 1, 1000); freq = _TestUtil.nextInt(random(), 1, 1000);
numManyPositions++; numManyPositions++;
} else { } else {
@ -409,7 +403,7 @@ public abstract class BasePostingsFormatTestCase extends LuceneTestCase {
SegmentWriteState writeState = new SegmentWriteState(null, dir, SegmentWriteState writeState = new SegmentWriteState(null, dir,
segmentInfo, newFieldInfos, segmentInfo, newFieldInfos,
32, null, new IOContext(new FlushInfo(maxDocID, bytes))); 32, null, new IOContext(new FlushInfo(1+maxDocID, bytes)));
FieldsConsumer fieldsConsumer = codec.postingsFormat().fieldsConsumer(writeState); FieldsConsumer fieldsConsumer = codec.postingsFormat().fieldsConsumer(writeState);
for(Map.Entry<String,Map<BytesRef,List<Posting>>> fieldEnt : fields.entrySet()) { for(Map.Entry<String,Map<BytesRef,List<Posting>>> fieldEnt : fields.entrySet()) {
@ -812,7 +806,8 @@ public abstract class BasePostingsFormatTestCase extends LuceneTestCase {
final IndexOptions maxIndexOptions, final IndexOptions maxIndexOptions,
final boolean alwaysTestMax) throws Exception { final boolean alwaysTestMax) throws Exception {
if (options.contains(Option.THREADS)) { // TODO: turn threads back on!
if (false && options.contains(Option.THREADS)) {
int numThreads = _TestUtil.nextInt(random(), 2, 5); int numThreads = _TestUtil.nextInt(random(), 2, 5);
Thread[] threads = new Thread[numThreads]; Thread[] threads = new Thread[numThreads];
for(int threadUpto=0;threadUpto<numThreads;threadUpto++) { for(int threadUpto=0;threadUpto<numThreads;threadUpto++) {