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

LUCENE-2386: reverting previous commit due to failing Solr tests 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@932917 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Shai Erera 2010-04-11 14:41:06 +00:00
parent 9992282d53
commit e525dbd83f
40 changed files with 142 additions and 246 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lucene/CHANGES.txt
View File

@ -105,12 +105,6 @@ Changes in backwards compatibility policy
of incrementToken(), tokenStream(), and reusableTokenStream(). of incrementToken(), tokenStream(), and reusableTokenStream().
(Uwe Schindler, Robert Muir) (Uwe Schindler, Robert Muir)
* LUCENE-2386: IndexWriter no longer performs an empty commit upon new index
creation. Previously, if you passed an empty Directory and set OpenMode to
CREATE*, IndexWriter would make a first empty commit. If you need that
behavior you can call writer.commit() immediately after you create it.
(Shai Erera, Mike McCandless)
Changes in runtime behavior Changes in runtime behavior
* LUCENE-1923: Made IndexReader.toString() produce something * LUCENE-1923: Made IndexReader.toString() produce something

2
lucene/backwards/src/test/org/apache/lucene/TestSnapshotDeletionPolicy.java
View File

@ -113,7 +113,7 @@ public class TestSnapshotDeletionPolicy extends LuceneTestCase
SnapshotDeletionPolicy dp = new SnapshotDeletionPolicy(new KeepOnlyLastCommitDeletionPolicy()); SnapshotDeletionPolicy dp = new SnapshotDeletionPolicy(new KeepOnlyLastCommitDeletionPolicy());
final IndexWriter writer = new IndexWriter(dir, new StandardAnalyzer(org.apache.lucene.util.Version.LUCENE_CURRENT), dp, IndexWriter.MaxFieldLength.UNLIMITED); final IndexWriter writer = new IndexWriter(dir, new StandardAnalyzer(org.apache.lucene.util.Version.LUCENE_CURRENT), dp, IndexWriter.MaxFieldLength.UNLIMITED);
writer.commit();
// Force frequent flushes // Force frequent flushes
writer.setMaxBufferedDocs(2); writer.setMaxBufferedDocs(2);

2
lucene/backwards/src/test/org/apache/lucene/index/TestBackwardsCompatibility.java
View File

@ -553,7 +553,7 @@ public class TestBackwardsCompatibility extends LuceneTestCase
expected = new String[] {"_0.cfs", expected = new String[] {"_0.cfs",
"_0_1.del", "_0_1.del",
"_0_1.s" + contentFieldIndex, "_0_1.s" + contentFieldIndex,
"segments_2", "segments_3",
"segments.gen"}; "segments.gen"};
String[] actual = dir.listAll(); String[] actual = dir.listAll();

28
lucene/backwards/src/test/org/apache/lucene/index/TestCrash.java
View File

@ -25,24 +25,20 @@ import org.apache.lucene.store.MockRAMDirectory;
import org.apache.lucene.store.NoLockFactory; import org.apache.lucene.store.NoLockFactory;
import org.apache.lucene.document.Document; import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field; import org.apache.lucene.document.Field;
import org.apache.lucene.index.IndexWriter;
public class TestCrash extends LuceneTestCase { public class TestCrash extends LuceneTestCase {
private IndexWriter initIndex(boolean initialCommit) throws IOException { private IndexWriter initIndex() throws IOException {
return initIndex(new MockRAMDirectory(), initialCommit); return initIndex(new MockRAMDirectory());
} }
private IndexWriter initIndex(MockRAMDirectory dir, boolean initialCommit) throws IOException { private IndexWriter initIndex(MockRAMDirectory dir) throws IOException {
dir.setLockFactory(NoLockFactory.getNoLockFactory()); dir.setLockFactory(NoLockFactory.getNoLockFactory());
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.UNLIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.UNLIMITED);
//writer.setMaxBufferedDocs(2); //writer.setMaxBufferedDocs(2);
writer.setMaxBufferedDocs(10); writer.setMaxBufferedDocs(10);
((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions();
if (initialCommit) {
writer.commit();
}
Document doc = new Document(); Document doc = new Document();
doc.add(new Field("content", "aaa", Field.Store.YES, Field.Index.ANALYZED)); doc.add(new Field("content", "aaa", Field.Store.YES, Field.Index.ANALYZED));
@ -62,7 +58,7 @@ public class TestCrash extends LuceneTestCase {
} }
public void testCrashWhileIndexing() throws IOException { public void testCrashWhileIndexing() throws IOException {
IndexWriter writer = initIndex(true); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
crash(writer); crash(writer);
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
@ -70,11 +66,11 @@ public class TestCrash extends LuceneTestCase {
} }
public void testWriterAfterCrash() throws IOException { public void testWriterAfterCrash() throws IOException {
IndexWriter writer = initIndex(true); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
dir.setPreventDoubleWrite(false); dir.setPreventDoubleWrite(false);
crash(writer); crash(writer);
writer = initIndex(dir, false); writer = initIndex(dir);
writer.close(); writer.close();
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
@ -82,10 +78,10 @@ public class TestCrash extends LuceneTestCase {
} }
public void testCrashAfterReopen() throws IOException { public void testCrashAfterReopen() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(); writer.close();
writer = initIndex(dir, false); writer = initIndex(dir);
assertEquals(314, writer.maxDoc()); assertEquals(314, writer.maxDoc());
crash(writer); crash(writer);
@ -104,7 +100,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashAfterClose() throws IOException { public void testCrashAfterClose() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(); writer.close();
@ -123,7 +119,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashAfterCloseNoWait() throws IOException { public void testCrashAfterCloseNoWait() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);
@ -142,7 +138,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashReaderDeletes() throws IOException { public void testCrashReaderDeletes() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);
@ -163,7 +159,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashReaderDeletesAfterClose() throws IOException { public void testCrashReaderDeletesAfterClose() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);

24
lucene/backwards/src/test/org/apache/lucene/index/TestDeletionPolicy.java
View File

@ -290,7 +290,7 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(1, policy.numOnInit); assertEquals(2, policy.numOnInit);
// If we are not auto committing then there should // If we are not auto committing then there should
// be exactly 2 commits (one per close above): // be exactly 2 commits (one per close above):
@ -298,8 +298,8 @@ public class TestDeletionPolicy extends LuceneTestCase
// Test listCommits // Test listCommits
Collection commits = IndexReader.listCommits(dir); Collection commits = IndexReader.listCommits(dir);
// 2 from closing writer // 1 from opening writer + 2 from closing writer
assertEquals(2, commits.size()); assertEquals(3, commits.size());
Iterator it = commits.iterator(); Iterator it = commits.iterator();
// Make sure we can open a reader on each commit: // Make sure we can open a reader on each commit:
@ -357,7 +357,7 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.close(); writer.close();
Collection commits = IndexReader.listCommits(dir); Collection commits = IndexReader.listCommits(dir);
assertEquals(5, commits.size()); assertEquals(6, commits.size());
IndexCommit lastCommit = null; IndexCommit lastCommit = null;
Iterator it = commits.iterator(); Iterator it = commits.iterator();
while(it.hasNext()) { while(it.hasNext()) {
@ -374,7 +374,7 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(6, IndexReader.listCommits(dir).size()); assertEquals(7, IndexReader.listCommits(dir).size());
// Now open writer on the commit just before optimize: // Now open writer on the commit just before optimize:
writer = new IndexWriter(dir, new WhitespaceAnalyzer(), policy, IndexWriter.MaxFieldLength.LIMITED, lastCommit); writer = new IndexWriter(dir, new WhitespaceAnalyzer(), policy, IndexWriter.MaxFieldLength.LIMITED, lastCommit);
@ -395,7 +395,7 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.close(); writer.close();
// Now 8 because we made another commit // Now 8 because we made another commit
assertEquals(7, IndexReader.listCommits(dir).size()); assertEquals(8, IndexReader.listCommits(dir).size());
r = IndexReader.open(dir, true); r = IndexReader.open(dir, true);
// Not optimized because we rolled it back, and now only // Not optimized because we rolled it back, and now only
@ -465,7 +465,7 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(1, policy.numOnInit); assertEquals(2, policy.numOnInit);
// If we are not auto committing then there should // If we are not auto committing then there should
// be exactly 2 commits (one per close above): // be exactly 2 commits (one per close above):
assertEquals(2, policy.numOnCommit); assertEquals(2, policy.numOnCommit);
@ -506,7 +506,7 @@ public class TestDeletionPolicy extends LuceneTestCase
} }
assertTrue(policy.numDelete > 0); assertTrue(policy.numDelete > 0);
assertEquals(N, policy.numOnInit); assertEquals(N+1, policy.numOnInit);
assertEquals(N+1, policy.numOnCommit); assertEquals(N+1, policy.numOnCommit);
// Simplistic check: just verify only the past N segments_N's still // Simplistic check: just verify only the past N segments_N's still
@ -580,8 +580,8 @@ public class TestDeletionPolicy extends LuceneTestCase
// this is a commit // this is a commit
writer.close(); writer.close();
assertEquals(2*(N+1)+1, policy.numOnInit); assertEquals(2*(N+2), policy.numOnInit);
assertEquals(2*(N+2), policy.numOnCommit); assertEquals(2*(N+2)-1, policy.numOnCommit);
IndexSearcher searcher = new IndexSearcher(dir, false); IndexSearcher searcher = new IndexSearcher(dir, false);
ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs; ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs;
@ -678,8 +678,8 @@ public class TestDeletionPolicy extends LuceneTestCase
writer.close(); writer.close();
} }
assertEquals(3*(N+1), policy.numOnInit); assertEquals(1+3*(N+1), policy.numOnInit);
assertEquals(3*(N+1)+1, policy.numOnCommit); assertEquals(3*(N+1), policy.numOnCommit);
IndexSearcher searcher = new IndexSearcher(dir, false); IndexSearcher searcher = new IndexSearcher(dir, false);
ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs; ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs;

6
lucene/backwards/src/test/org/apache/lucene/index/TestIndexFileDeleter.java
View File

@ -136,11 +136,11 @@ public class TestIndexFileDeleter extends LuceneTestCase
copyFile(dir, "_0.cfs", "deletable"); copyFile(dir, "_0.cfs", "deletable");
// Create some old segments file: // Create some old segments file:
copyFile(dir, "segments_2", "segments"); copyFile(dir, "segments_3", "segments");
copyFile(dir, "segments_2", "segments_1"); copyFile(dir, "segments_3", "segments_2");
// Create a bogus cfs file shadowing a non-cfs segment: // Create a bogus cfs file shadowing a non-cfs segment:
copyFile(dir, "_1.cfs", "_2.cfs"); copyFile(dir, "_2.cfs", "_3.cfs");
String[] filesPre = dir.listAll(); String[] filesPre = dir.listAll();

3
lucene/backwards/src/test/org/apache/lucene/index/TestIndexReader.java
View File

@ -39,7 +39,6 @@ import org.apache.lucene.document.Field;
import org.apache.lucene.document.FieldSelector; import org.apache.lucene.document.FieldSelector;
import org.apache.lucene.document.Fieldable; import org.apache.lucene.document.Fieldable;
import org.apache.lucene.document.SetBasedFieldSelector; import org.apache.lucene.document.SetBasedFieldSelector;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexReader.FieldOption; import org.apache.lucene.index.IndexReader.FieldOption;
import org.apache.lucene.search.FieldCache; import org.apache.lucene.search.FieldCache;
import org.apache.lucene.search.IndexSearcher; import org.apache.lucene.search.IndexSearcher;
@ -475,7 +474,6 @@ public class TestIndexReader extends LuceneTestCase
// add 11 documents with term : aaa // add 11 documents with term : aaa
writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.LIMITED); writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.LIMITED);
writer.commit();
for (int i = 0; i < 11; i++) for (int i = 0; i < 11; i++)
{ {
addDoc(writer, searchTerm.text()); addDoc(writer, searchTerm.text());
@ -1767,7 +1765,6 @@ public class TestIndexReader extends LuceneTestCase
public void testPrepareCommitIsCurrent() throws Throwable { public void testPrepareCommitIsCurrent() throws Throwable {
Directory dir = new MockRAMDirectory(); Directory dir = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.UNLIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.UNLIMITED);
writer.commit();
Document doc = new Document(); Document doc = new Document();
writer.addDocument(doc); writer.addDocument(doc);
IndexReader r = IndexReader.open(dir, true); IndexReader r = IndexReader.open(dir, true);

2
lucene/backwards/src/test/org/apache/lucene/index/TestIndexReaderReopen.java
View File

@ -36,7 +36,6 @@ import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field; import org.apache.lucene.document.Field;
import org.apache.lucene.document.Field.Index; import org.apache.lucene.document.Field.Index;
import org.apache.lucene.document.Field.Store; import org.apache.lucene.document.Field.Store;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriter.MaxFieldLength; import org.apache.lucene.index.IndexWriter.MaxFieldLength;
import org.apache.lucene.search.IndexSearcher; import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.ScoreDoc; import org.apache.lucene.search.ScoreDoc;
@ -173,7 +172,6 @@ public class TestIndexReaderReopen extends LuceneTestCase {
private void doTestReopenWithCommit (Directory dir, boolean withReopen) throws IOException { private void doTestReopenWithCommit (Directory dir, boolean withReopen) throws IOException {
IndexWriter iwriter = new IndexWriter(dir, new KeywordAnalyzer(), true, MaxFieldLength.LIMITED); IndexWriter iwriter = new IndexWriter(dir, new KeywordAnalyzer(), true, MaxFieldLength.LIMITED);
iwriter.setMergeScheduler(new SerialMergeScheduler()); iwriter.setMergeScheduler(new SerialMergeScheduler());
iwriter.commit();
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
try { try {
int M = 3; int M = 3;

15
lucene/backwards/src/test/org/apache/lucene/index/TestIndexWriter.java
View File

@ -47,7 +47,6 @@ import org.apache.lucene.analysis.tokenattributes.TermAttribute;
import org.apache.lucene.analysis.tokenattributes.PositionIncrementAttribute; import org.apache.lucene.analysis.tokenattributes.PositionIncrementAttribute;
import org.apache.lucene.document.Document; import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field; import org.apache.lucene.document.Field;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.search.IndexSearcher; import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.PhraseQuery; import org.apache.lucene.search.PhraseQuery;
import org.apache.lucene.search.Query; import org.apache.lucene.search.Query;
@ -784,7 +783,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
// Make the next segments file, with last byte // Make the next segments file, with last byte
// missing, to simulate a writer that crashed while // missing, to simulate a writer that crashed while
@ -844,7 +843,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
String fileNameIn = SegmentInfos.getCurrentSegmentFileName(dir); String fileNameIn = SegmentInfos.getCurrentSegmentFileName(dir);
String fileNameOut = IndexFileNames.fileNameFromGeneration(IndexFileNames.SEGMENTS, String fileNameOut = IndexFileNames.fileNameFromGeneration(IndexFileNames.SEGMENTS,
@ -909,7 +908,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
String[] files = dir.listAll(); String[] files = dir.listAll();
for(int i=0;i<files.length;i++) { for(int i=0;i<files.length;i++) {
@ -2325,7 +2324,7 @@ public class TestIndexWriter extends LuceneTestCase {
public void testImmediateDiskFull() throws IOException { public void testImmediateDiskFull() throws IOException {
MockRAMDirectory dir = new MockRAMDirectory(); MockRAMDirectory dir = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED);
dir.setMaxSizeInBytes(Math.max(1, dir.getRecomputedActualSizeInBytes())); dir.setMaxSizeInBytes(dir.getRecomputedActualSizeInBytes());
writer.setMaxBufferedDocs(2); writer.setMaxBufferedDocs(2);
final Document doc = new Document(); final Document doc = new Document();
doc.add(new Field("field", "aaa bbb ccc ddd eee fff ggg hhh iii jjj", Field.Store.YES, Field.Index.ANALYZED, Field.TermVector.WITH_POSITIONS_OFFSETS)); doc.add(new Field("field", "aaa bbb ccc ddd eee fff ggg hhh iii jjj", Field.Store.YES, Field.Index.ANALYZED, Field.TermVector.WITH_POSITIONS_OFFSETS));
@ -2648,7 +2647,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
final String segmentsFileName = SegmentInfos.getCurrentSegmentFileName(dir); final String segmentsFileName = SegmentInfos.getCurrentSegmentFileName(dir);
IndexInput in = dir.openInput(segmentsFileName); IndexInput in = dir.openInput(segmentsFileName);
@ -2676,7 +2675,6 @@ public class TestIndexWriter extends LuceneTestCase {
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED);
writer.setMaxBufferedDocs(2); writer.setMaxBufferedDocs(2);
writer.setMergeFactor(5); writer.setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3544,7 +3542,6 @@ public class TestIndexWriter extends LuceneTestCase {
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED);
writer.setMaxBufferedDocs(2); writer.setMaxBufferedDocs(2);
writer.setMergeFactor(5); writer.setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3598,7 +3595,6 @@ public class TestIndexWriter extends LuceneTestCase {
writer.setMaxBufferedDocs(2); writer.setMaxBufferedDocs(2);
writer.setMergeFactor(5); writer.setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3683,7 +3679,6 @@ public class TestIndexWriter extends LuceneTestCase {
dir2 = new MockRAMDirectory(); dir2 = new MockRAMDirectory();
writer2 = new IndexWriter(dir2, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED); writer2 = new IndexWriter(dir2, new WhitespaceAnalyzer(), IndexWriter.MaxFieldLength.LIMITED);
writer2.commit();
cms = (ConcurrentMergeScheduler) writer2.getMergeScheduler(); cms = (ConcurrentMergeScheduler) writer2.getMergeScheduler();
readers = new IndexReader[NUM_COPY]; readers = new IndexReader[NUM_COPY];

3
lucene/backwards/src/test/org/apache/lucene/index/TestIndexWriterDelete.java
View File

@ -23,7 +23,6 @@ import java.util.Arrays;
import org.apache.lucene.analysis.WhitespaceAnalyzer; import org.apache.lucene.analysis.WhitespaceAnalyzer;
import org.apache.lucene.document.Document; import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field; import org.apache.lucene.document.Field;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.search.IndexSearcher; import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.ScoreDoc; import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TermQuery; import org.apache.lucene.search.TermQuery;
@ -765,7 +764,7 @@ public class TestIndexWriterDelete extends LuceneTestCase {
MockRAMDirectory dir = new MockRAMDirectory(); MockRAMDirectory dir = new MockRAMDirectory();
IndexWriter modifier = new IndexWriter(dir, IndexWriter modifier = new IndexWriter(dir,
new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.UNLIMITED); new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.UNLIMITED);
modifier.commit();
dir.failOn(failure.reset()); dir.failOn(failure.reset());
for (int i = 0; i < keywords.length; i++) { for (int i = 0; i < keywords.length; i++) {

2
lucene/backwards/src/test/org/apache/lucene/index/TestIndexWriterExceptions.java
View File

@ -138,7 +138,6 @@ public class TestIndexWriterExceptions extends LuceneTestCase {
((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions();
//writer.setMaxBufferedDocs(10); //writer.setMaxBufferedDocs(10);
writer.setRAMBufferSizeMB(0.1); writer.setRAMBufferSizeMB(0.1);
writer.commit();
if (DEBUG) if (DEBUG)
writer.setInfoStream(System.out); writer.setInfoStream(System.out);
@ -177,7 +176,6 @@ public class TestIndexWriterExceptions extends LuceneTestCase {
((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getMergeScheduler()).setSuppressExceptions();
//writer.setMaxBufferedDocs(10); //writer.setMaxBufferedDocs(10);
writer.setRAMBufferSizeMB(0.2); writer.setRAMBufferSizeMB(0.2);
writer.commit();
if (DEBUG) if (DEBUG)
writer.setInfoStream(System.out); writer.setInfoStream(System.out);

2
lucene/backwards/src/test/org/apache/lucene/index/TestIndexWriterReader.java
View File

@ -30,7 +30,6 @@ import org.apache.lucene.document.Field;
import org.apache.lucene.document.Field.Index; import org.apache.lucene.document.Field.Index;
import org.apache.lucene.document.Field.Store; import org.apache.lucene.document.Field.Store;
import org.apache.lucene.document.Field.TermVector; import org.apache.lucene.document.Field.TermVector;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.search.TermQuery; import org.apache.lucene.search.TermQuery;
import org.apache.lucene.search.IndexSearcher; import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query; import org.apache.lucene.search.Query;
@ -643,7 +642,6 @@ public class TestIndexWriterReader extends LuceneTestCase {
Directory dir1 = new MockRAMDirectory(); Directory dir1 = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir1, new WhitespaceAnalyzer(), IndexWriter writer = new IndexWriter(dir1, new WhitespaceAnalyzer(),
IndexWriter.MaxFieldLength.LIMITED); IndexWriter.MaxFieldLength.LIMITED);
writer.commit();
writer.setInfoStream(infoStream); writer.setInfoStream(infoStream);
// create the index // create the index

3
lucene/backwards/src/test/org/apache/lucene/index/TestStressIndexing.java
View File

@ -19,7 +19,6 @@ package org.apache.lucene.index;
import org.apache.lucene.util.*; import org.apache.lucene.util.*;
import org.apache.lucene.store.*; import org.apache.lucene.store.*;
import org.apache.lucene.document.*; import org.apache.lucene.document.*;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.analysis.*; import org.apache.lucene.analysis.*;
import org.apache.lucene.search.*; import org.apache.lucene.search.*;
import org.apache.lucene.queryParser.*; import org.apache.lucene.queryParser.*;
@ -122,7 +121,7 @@ public class TestStressIndexing extends LuceneTestCase {
*/ */
public void runStressTest(Directory directory, MergeScheduler mergeScheduler) throws Exception { public void runStressTest(Directory directory, MergeScheduler mergeScheduler) throws Exception {
IndexWriter modifier = new IndexWriter(directory, ANALYZER, true, IndexWriter.MaxFieldLength.UNLIMITED); IndexWriter modifier = new IndexWriter(directory, ANALYZER, true, IndexWriter.MaxFieldLength.UNLIMITED);
modifier.commit();
modifier.setMaxBufferedDocs(10); modifier.setMaxBufferedDocs(10);
TimedThread[] threads = new TimedThread[4]; TimedThread[] threads = new TimedThread[4];

2
lucene/backwards/src/test/org/apache/lucene/index/TestStressIndexing2.java
View File

@ -16,7 +16,6 @@ package org.apache.lucene.index;
import org.apache.lucene.store.*; import org.apache.lucene.store.*;
import org.apache.lucene.document.*; import org.apache.lucene.document.*;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.analysis.*; import org.apache.lucene.analysis.*;
import org.apache.lucene.util.LuceneTestCase; import org.apache.lucene.util.LuceneTestCase;
@ -125,7 +124,6 @@ public class TestStressIndexing2 extends LuceneTestCase {
public DocsAndWriter indexRandomIWReader(int nThreads, int iterations, int range, Directory dir) throws IOException, InterruptedException { public DocsAndWriter indexRandomIWReader(int nThreads, int iterations, int range, Directory dir) throws IOException, InterruptedException {
Map docs = new HashMap(); Map docs = new HashMap();
IndexWriter w = new MockIndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.UNLIMITED); IndexWriter w = new MockIndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.UNLIMITED);
w.commit();
w.setUseCompoundFile(false); w.setUseCompoundFile(false);
/*** /***

1
lucene/backwards/src/test/org/apache/lucene/store/TestBufferedIndexInput.java
View File

@ -241,7 +241,6 @@ public class TestBufferedIndexInput extends LuceneTestCase {
public void testSetBufferSize() throws IOException { public void testSetBufferSize() throws IOException {
File indexDir = new File(System.getProperty("tempDir"), "testSetBufferSize"); File indexDir = new File(System.getProperty("tempDir"), "testSetBufferSize");
indexDir.mkdirs(); // required for this MockFSDir since we don't commit on IW creation anymore.
MockFSDirectory dir = new MockFSDirectory(indexDir, newRandom()); MockFSDirectory dir = new MockFSDirectory(indexDir, newRandom());
try { try {
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.LIMITED); IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter.MaxFieldLength.LIMITED);

1
lucene/backwards/src/test/org/apache/lucene/store/TestLockFactory.java
View File

@ -85,7 +85,6 @@ public class TestLockFactory extends LuceneTestCase {
IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true, IndexWriter writer = new IndexWriter(dir, new WhitespaceAnalyzer(), true,
IndexWriter.MaxFieldLength.LIMITED); IndexWriter.MaxFieldLength.LIMITED);
writer.commit(); // required so the second open succeed
// Create a 2nd IndexWriter. This is normally not allowed but it should run through since we're not // Create a 2nd IndexWriter. This is normally not allowed but it should run through since we're not
// using any locks: // using any locks:

26
lucene/backwards/src/test/org/apache/lucene/store/TestWindowsMMap.java
View File

@ -64,18 +64,14 @@ public class TestWindowsMMap extends LuceneTestCase {
new File(System.getProperty("tempDir"),"testLuceneMmap").getAbsolutePath(); new File(System.getProperty("tempDir"),"testLuceneMmap").getAbsolutePath();
public void testMmapIndex() throws Exception { public void testMmapIndex() throws Exception {
// sometimes the directory is not cleaned by rmDir, because on Windows it FSDirectory storeDirectory;
// may take some time until the files are finally dereferenced. So clean the storeDirectory = new MMapDirectory(new File(storePathname), null);
// directory up front, or otherwise new IndexWriter will fail.
rmDir(new File(storePathname));
FSDirectory storeDirectory = new MMapDirectory(new File(storePathname), null);
// plan to add a set of useful stopwords, consider changing some of the // plan to add a set of useful stopwords, consider changing some of the
// interior filters. // interior filters.
StandardAnalyzer analyzer = new StandardAnalyzer(org.apache.lucene.util.Version.LUCENE_CURRENT, Collections.emptySet()); StandardAnalyzer analyzer = new StandardAnalyzer(org.apache.lucene.util.Version.LUCENE_CURRENT, Collections.emptySet());
// TODO: something about lock timeouts and leftover locks. // TODO: something about lock timeouts and leftover locks.
IndexWriter writer = new IndexWriter(storeDirectory, analyzer, true, IndexWriter.MaxFieldLength.LIMITED); IndexWriter writer = new IndexWriter(storeDirectory, analyzer, true, IndexWriter.MaxFieldLength.LIMITED);
writer.commit();
IndexSearcher searcher = new IndexSearcher(storeDirectory, true); IndexSearcher searcher = new IndexSearcher(storeDirectory, true);
for(int dx = 0; dx < 1000; dx ++) { for(int dx = 0; dx < 1000; dx ++) {
@ -87,16 +83,14 @@ public class TestWindowsMMap extends LuceneTestCase {
searcher.close(); searcher.close();
writer.close(); writer.close();
rmDir(new File(storePathname)); rmDir(new File(storePathname));
} }
private void rmDir(File dir) { private void rmDir(File dir) {
if (!dir.exists()) { File[] files = dir.listFiles();
return; for (int i = 0; i < files.length; i++) {
} files[i].delete();
for (File file : dir.listFiles()) { }
file.delete(); dir.delete();
} }
dir.delete();
}
} }

4
lucene/contrib/xml-query-parser/src/test/org/apache/lucene/xmlparser/builders/TestNumericRangeFilterBuilder.java
View File

@ -29,7 +29,6 @@ import org.apache.lucene.util.LuceneTestCase;
import org.apache.lucene.index.IndexReader; import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter; import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.index.IndexWriter.MaxFieldLength; import org.apache.lucene.index.IndexWriter.MaxFieldLength;
import org.apache.lucene.search.Filter; import org.apache.lucene.search.Filter;
import org.apache.lucene.search.NumericRangeFilter; import org.apache.lucene.search.NumericRangeFilter;
@ -63,8 +62,7 @@ public class TestNumericRangeFilterBuilder extends LuceneTestCase {
Filter filter = filterBuilder.getFilter(doc.getDocumentElement()); Filter filter = filterBuilder.getFilter(doc.getDocumentElement());
RAMDirectory ramDir = new RAMDirectory(); RAMDirectory ramDir = new RAMDirectory();
IndexWriter writer = new IndexWriter(ramDir, new IndexWriterConfig(TEST_VERSION_CURRENT, null)); IndexWriter writer = new IndexWriter(ramDir, null, MaxFieldLength.UNLIMITED);
writer.commit();
try try
{ {
IndexReader reader = IndexReader.open(ramDir, true); IndexReader reader = IndexReader.open(ramDir, true);

6
lucene/src/java/org/apache/lucene/index/DirectoryReader.java
View File

@ -1030,11 +1030,7 @@ class DirectoryReader extends IndexReader implements Cloneable {
Collection<IndexCommit> commits = new ArrayList<IndexCommit>(); Collection<IndexCommit> commits = new ArrayList<IndexCommit>();
SegmentInfos latest = new SegmentInfos(); SegmentInfos latest = new SegmentInfos();
try { latest.read(dir, codecs);
latest.read(dir, codecs);
} catch (IndexNotFoundException e) {
return Collections.emptyList();
}
final long currentGen = latest.getGeneration(); final long currentGen = latest.getGeneration();
commits.add(new ReaderCommit(latest, dir)); commits.add(new ReaderCommit(latest, dir));

20
lucene/src/java/org/apache/lucene/index/IndexFileDeleter.java
View File

@ -144,12 +144,15 @@ final class IndexFileDeleter {
long currentGen = segmentInfos.getGeneration(); long currentGen = segmentInfos.getGeneration();
indexFilenameFilter = new IndexFileNameFilter(codecs); indexFilenameFilter = new IndexFileNameFilter(codecs);
String[] files = directory.listAll();
CommitPoint currentCommitPoint = null; CommitPoint currentCommitPoint = null;
boolean seenIndexFiles = false;
for (String fileName : directory.listAll()) { for(int i=0;i<files.length;i++) {
String fileName = files[i];
if ((indexFilenameFilter.accept(null, fileName)) && !fileName.endsWith("write.lock") && !fileName.equals(IndexFileNames.SEGMENTS_GEN)) { if ((indexFilenameFilter.accept(null, fileName)) && !fileName.endsWith("write.lock") && !fileName.equals(IndexFileNames.SEGMENTS_GEN)) {
seenIndexFiles = true;
// Add this file to refCounts with initial count 0: // Add this file to refCounts with initial count 0:
getRefCount(fileName); getRefCount(fileName);
@ -192,10 +195,7 @@ final class IndexFileDeleter {
} }
} }
// If we haven't seen any Lucene files, then currentCommitPoint is expected if (currentCommitPoint == null) {
// to be null, because it means it's a fresh Directory. Therefore it cannot
// be any NFS cache issues - so just ignore.
if (currentCommitPoint == null && seenIndexFiles) {
// We did not in fact see the segments_N file // We did not in fact see the segments_N file
// corresponding to the segmentInfos that was passed // corresponding to the segmentInfos that was passed
// in. Yet, it must exist, because our caller holds // in. Yet, it must exist, because our caller holds
@ -235,15 +235,13 @@ final class IndexFileDeleter {
// Finally, give policy a chance to remove things on // Finally, give policy a chance to remove things on
// startup: // startup:
if (seenIndexFiles) { policy.onInit(commits);
policy.onInit(commits);
}
// Always protect the incoming segmentInfos since // Always protect the incoming segmentInfos since
// sometime it may not be the most recent commit // sometime it may not be the most recent commit
checkpoint(segmentInfos, false); checkpoint(segmentInfos, false);
startingCommitDeleted = currentCommitPoint == null ? false : currentCommitPoint.isDeleted(); startingCommitDeleted = currentCommitPoint.isDeleted();
deleteCommits(); deleteCommits();
} }

32
lucene/src/java/org/apache/lucene/index/IndexNotFoundException.java
View File

@ -1,32 +0,0 @@
package org.apache.lucene.index;
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import java.io.FileNotFoundException;
/**
* Signals that no index was found in the Directory. Possibly because the
* directory is empty, however can slso indicate an index corruption.
*/
public final class IndexNotFoundException extends FileNotFoundException {
public IndexNotFoundException(String msg) {
super(msg);
}
}

15
lucene/src/java/org/apache/lucene/index/IndexWriter.java
View File

@ -1115,16 +1115,25 @@ public class IndexWriter implements Closeable {
// against an index that's currently open for // against an index that's currently open for
// searching. In this case we write the next // searching. In this case we write the next
// segments_N file with no segments: // segments_N file with no segments:
boolean doCommit;
try { try {
segmentInfos.read(directory, codecs); segmentInfos.read(directory, codecs);
segmentInfos.clear(); segmentInfos.clear();
doCommit = false;
} catch (IOException e) { } catch (IOException e) {
// Likely this means it's a fresh directory // Likely this means it's a fresh directory
doCommit = true;
} }
// Record that we have a change (zero out all if (doCommit) {
// segments) pending: // Only commit if there is no segments file in
changeCount++; // this dir already.
segmentInfos.commit(directory);
} else {
// Record that we have a change (zero out all
// segments) pending:
changeCount++;
}
} else { } else {
segmentInfos.read(directory, codecs); segmentInfos.read(directory, codecs);

2
lucene/src/java/org/apache/lucene/index/SegmentInfos.java
View File

@ -649,7 +649,7 @@ public final class SegmentInfos extends Vector<SegmentInfo> {
if (gen == -1) { if (gen == -1) {
// Neither approach found a generation // Neither approach found a generation
throw new IndexNotFoundException("no segments* file found in " + directory + ": files: " + Arrays.toString(files)); throw new FileNotFoundException("no segments* file found in " + directory + ": files: " + Arrays.toString(files));
} }
} }

5
lucene/src/test/org/apache/lucene/TestSnapshotDeletionPolicy.java
View File

@ -45,8 +45,8 @@ import org.apache.lucene.util._TestUtil;
// http://lucenebook.com // http://lucenebook.com
// //
public class TestSnapshotDeletionPolicy extends LuceneTestCase { public class TestSnapshotDeletionPolicy extends LuceneTestCase
{
public static final String INDEX_PATH = "test.snapshots"; public static final String INDEX_PATH = "test.snapshots";
public void testSnapshotDeletionPolicy() throws Exception { public void testSnapshotDeletionPolicy() throws Exception {
@ -119,7 +119,6 @@ public class TestSnapshotDeletionPolicy extends LuceneTestCase {
TEST_VERSION_CURRENT, TEST_VERSION_CURRENT,
new StandardAnalyzer(TEST_VERSION_CURRENT)).setIndexDeletionPolicy(dp) new StandardAnalyzer(TEST_VERSION_CURRENT)).setIndexDeletionPolicy(dp)
.setMaxBufferedDocs(2)); .setMaxBufferedDocs(2));
writer.commit();
final Thread t = new Thread() { final Thread t = new Thread() {
@Override @Override

5
lucene/src/test/org/apache/lucene/index/TestBackwardsCompatibility.java
View File

@ -558,10 +558,11 @@ public class TestBackwardsCompatibility extends LuceneTestCase {
assertTrue("could not locate the 'content' field number in the _2.cfs segment", contentFieldIndex != -1); assertTrue("could not locate the 'content' field number in the _2.cfs segment", contentFieldIndex != -1);
// Now verify file names: // Now verify file names:
String[] expected = new String[] {"_0.cfs", String[] expected;
expected = new String[] {"_0.cfs",
"_0_1.del", "_0_1.del",
"_0_1.s" + contentFieldIndex, "_0_1.s" + contentFieldIndex,
"segments_2", "segments_3",
"segments.gen"}; "segments.gen"};
String[] actual = dir.listAll(); String[] actual = dir.listAll();

33
lucene/src/test/org/apache/lucene/index/TestCrash.java
View File

@ -28,18 +28,15 @@ import org.apache.lucene.document.Field;
public class TestCrash extends LuceneTestCase { public class TestCrash extends LuceneTestCase {
private IndexWriter initIndex(boolean initialCommit) throws IOException { private IndexWriter initIndex() throws IOException {
return initIndex(new MockRAMDirectory(), initialCommit); return initIndex(new MockRAMDirectory());
} }
private IndexWriter initIndex(MockRAMDirectory dir, boolean initialCommit) throws IOException { private IndexWriter initIndex(MockRAMDirectory dir) throws IOException {
dir.setLockFactory(NoLockFactory.getNoLockFactory()); dir.setLockFactory(NoLockFactory.getNoLockFactory());
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(10)); IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(10));
((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions();
if (initialCommit) {
writer.commit();
}
Document doc = new Document(); Document doc = new Document();
doc.add(new Field("content", "aaa", Field.Store.YES, Field.Index.ANALYZED)); doc.add(new Field("content", "aaa", Field.Store.YES, Field.Index.ANALYZED));
@ -59,10 +56,7 @@ public class TestCrash extends LuceneTestCase {
} }
public void testCrashWhileIndexing() throws IOException { public void testCrashWhileIndexing() throws IOException {
// This test relies on being able to open a reader before any commit IndexWriter writer = initIndex();
// happened, so we must create an initial commit just to allow that, but
// before any documents were added.
IndexWriter writer = initIndex(true);
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
crash(writer); crash(writer);
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
@ -70,14 +64,11 @@ public class TestCrash extends LuceneTestCase {
} }
public void testWriterAfterCrash() throws IOException { public void testWriterAfterCrash() throws IOException {
// This test relies on being able to open a reader before any commit IndexWriter writer = initIndex();
// happened, so we must create an initial commit just to allow that, but
// before any documents were added.
IndexWriter writer = initIndex(true);
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
dir.setPreventDoubleWrite(false); dir.setPreventDoubleWrite(false);
crash(writer); crash(writer);
writer = initIndex(dir, false); writer = initIndex(dir);
writer.close(); writer.close();
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
@ -85,10 +76,10 @@ public class TestCrash extends LuceneTestCase {
} }
public void testCrashAfterReopen() throws IOException { public void testCrashAfterReopen() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(); writer.close();
writer = initIndex(dir, false); writer = initIndex(dir);
assertEquals(314, writer.maxDoc()); assertEquals(314, writer.maxDoc());
crash(writer); crash(writer);
@ -107,7 +98,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashAfterClose() throws IOException { public void testCrashAfterClose() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(); writer.close();
@ -126,7 +117,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashAfterCloseNoWait() throws IOException { public void testCrashAfterCloseNoWait() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);
@ -145,7 +136,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashReaderDeletes() throws IOException { public void testCrashReaderDeletes() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);
@ -166,7 +157,7 @@ public class TestCrash extends LuceneTestCase {
public void testCrashReaderDeletesAfterClose() throws IOException { public void testCrashReaderDeletesAfterClose() throws IOException {
IndexWriter writer = initIndex(false); IndexWriter writer = initIndex();
MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory(); MockRAMDirectory dir = (MockRAMDirectory) writer.getDirectory();
writer.close(false); writer.close(false);

24
lucene/src/test/org/apache/lucene/index/TestDeletionPolicy.java
View File

@ -305,7 +305,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(1, policy.numOnInit); assertEquals(2, policy.numOnInit);
// If we are not auto committing then there should // If we are not auto committing then there should
// be exactly 2 commits (one per close above): // be exactly 2 commits (one per close above):
@ -313,8 +313,8 @@ public class TestDeletionPolicy extends LuceneTestCase {
// Test listCommits // Test listCommits
Collection<IndexCommit> commits = IndexReader.listCommits(dir); Collection<IndexCommit> commits = IndexReader.listCommits(dir);
// 2 from closing writer // 1 from opening writer + 2 from closing writer
assertEquals(2, commits.size()); assertEquals(3, commits.size());
// Make sure we can open a reader on each commit: // Make sure we can open a reader on each commit:
for (final IndexCommit commit : commits) { for (final IndexCommit commit : commits) {
@ -374,7 +374,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.close(); writer.close();
Collection<IndexCommit> commits = IndexReader.listCommits(dir); Collection<IndexCommit> commits = IndexReader.listCommits(dir);
assertEquals(5, commits.size()); assertEquals(6, commits.size());
IndexCommit lastCommit = null; IndexCommit lastCommit = null;
for (final IndexCommit commit : commits) { for (final IndexCommit commit : commits) {
if (lastCommit == null || commit.getGeneration() > lastCommit.getGeneration()) if (lastCommit == null || commit.getGeneration() > lastCommit.getGeneration())
@ -389,7 +389,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(6, IndexReader.listCommits(dir).size()); assertEquals(7, IndexReader.listCommits(dir).size());
// Now open writer on the commit just before optimize: // Now open writer on the commit just before optimize:
writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)) writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))
@ -412,7 +412,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.close(); writer.close();
// Now 8 because we made another commit // Now 8 because we made another commit
assertEquals(7, IndexReader.listCommits(dir).size()); assertEquals(8, IndexReader.listCommits(dir).size());
r = IndexReader.open(dir, true); r = IndexReader.open(dir, true);
// Not optimized because we rolled it back, and now only // Not optimized because we rolled it back, and now only
@ -491,7 +491,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.optimize(); writer.optimize();
writer.close(); writer.close();
assertEquals(1, policy.numOnInit); assertEquals(2, policy.numOnInit);
// If we are not auto committing then there should // If we are not auto committing then there should
// be exactly 2 commits (one per close above): // be exactly 2 commits (one per close above):
assertEquals(2, policy.numOnCommit); assertEquals(2, policy.numOnCommit);
@ -537,7 +537,7 @@ public class TestDeletionPolicy extends LuceneTestCase {
} }
assertTrue(policy.numDelete > 0); assertTrue(policy.numDelete > 0);
assertEquals(N, policy.numOnInit); assertEquals(N+1, policy.numOnInit);
assertEquals(N+1, policy.numOnCommit); assertEquals(N+1, policy.numOnCommit);
// Simplistic check: just verify only the past N segments_N's still // Simplistic check: just verify only the past N segments_N's still
@ -625,8 +625,8 @@ public class TestDeletionPolicy extends LuceneTestCase {
// this is a commit // this is a commit
writer.close(); writer.close();
assertEquals(2*(N+1)+1, policy.numOnInit); assertEquals(2*(N+2), policy.numOnInit);
assertEquals(2*(N+2), policy.numOnCommit); assertEquals(2*(N+2)-1, policy.numOnCommit);
IndexSearcher searcher = new IndexSearcher(dir, false); IndexSearcher searcher = new IndexSearcher(dir, false);
ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs; ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs;
@ -735,8 +735,8 @@ public class TestDeletionPolicy extends LuceneTestCase {
writer.close(); writer.close();
} }
assertEquals(3*(N+1), policy.numOnInit); assertEquals(1+3*(N+1), policy.numOnInit);
assertEquals(3*(N+1)+1, policy.numOnCommit); assertEquals(3*(N+1), policy.numOnCommit);
IndexSearcher searcher = new IndexSearcher(dir, false); IndexSearcher searcher = new IndexSearcher(dir, false);
ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs; ScoreDoc[] hits = searcher.search(query, null, 1000).scoreDocs;

6
lucene/src/test/org/apache/lucene/index/TestIndexFileDeleter.java
View File

@ -138,11 +138,11 @@ public class TestIndexFileDeleter extends LuceneTestCase {
copyFile(dir, "_0.cfs", "deletable"); copyFile(dir, "_0.cfs", "deletable");
// Create some old segments file: // Create some old segments file:
copyFile(dir, "segments_2", "segments"); copyFile(dir, "segments_3", "segments");
copyFile(dir, "segments_2", "segments_1"); copyFile(dir, "segments_3", "segments_2");
// Create a bogus cfs file shadowing a non-cfs segment: // Create a bogus cfs file shadowing a non-cfs segment:
copyFile(dir, "_1.cfs", "_2.cfs"); copyFile(dir, "_2.cfs", "_3.cfs");
String[] filesPre = dir.listAll(); String[] filesPre = dir.listAll();

8
lucene/src/test/org/apache/lucene/index/TestIndexReader.java
View File

@ -466,17 +466,18 @@ public class TestIndexReader extends LuceneTestCase
public void testLockObtainFailed() throws IOException { public void testLockObtainFailed() throws IOException {
Directory dir = new RAMDirectory(); Directory dir = new RAMDirectory();
IndexWriter writer = null;
IndexReader reader = null;
Term searchTerm = new Term("content", "aaa"); Term searchTerm = new Term("content", "aaa");
// add 11 documents with term : aaa // add 11 documents with term : aaa
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
writer.commit();
for (int i = 0; i < 11; i++) { for (int i = 0; i < 11; i++) {
addDoc(writer, searchTerm.text()); addDoc(writer, searchTerm.text());
} }
// Create reader: // Create reader:
IndexReader reader = IndexReader.open(dir, false); reader = IndexReader.open(dir, false);
// Try to make changes // Try to make changes
try { try {
@ -1748,7 +1749,6 @@ public class TestIndexReader extends LuceneTestCase
Directory dir = new MockRAMDirectory(); Directory dir = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig( IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(
TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
writer.commit();
Document doc = new Document(); Document doc = new Document();
writer.addDocument(doc); writer.addDocument(doc);
IndexReader r = IndexReader.open(dir, true); IndexReader r = IndexReader.open(dir, true);

1
lucene/src/test/org/apache/lucene/index/TestIndexReaderReopen.java
View File

@ -174,7 +174,6 @@ public class TestIndexReaderReopen extends LuceneTestCase {
IndexWriter iwriter = new IndexWriter(dir, new IndexWriterConfig( IndexWriter iwriter = new IndexWriter(dir, new IndexWriterConfig(
TEST_VERSION_CURRENT, new KeywordAnalyzer()).setOpenMode( TEST_VERSION_CURRENT, new KeywordAnalyzer()).setOpenMode(
OpenMode.CREATE).setMergeScheduler(new SerialMergeScheduler())); OpenMode.CREATE).setMergeScheduler(new SerialMergeScheduler()));
iwriter.commit();
IndexReader reader = IndexReader.open(dir, false); IndexReader reader = IndexReader.open(dir, false);
try { try {
int M = 3; int M = 3;

27
lucene/src/test/org/apache/lucene/index/TestIndexWriter.java
View File

@ -778,7 +778,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
// Make the next segments file, with last byte // Make the next segments file, with last byte
// missing, to simulate a writer that crashed while // missing, to simulate a writer that crashed while
@ -838,7 +838,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
String fileNameIn = SegmentInfos.getCurrentSegmentFileName(dir); String fileNameIn = SegmentInfos.getCurrentSegmentFileName(dir);
String fileNameOut = IndexFileNames.fileNameFromGeneration(IndexFileNames.SEGMENTS, String fileNameOut = IndexFileNames.fileNameFromGeneration(IndexFileNames.SEGMENTS,
@ -903,7 +903,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
String[] files = dir.listAll(); String[] files = dir.listAll();
for(int i=0;i<files.length;i++) { for(int i=0;i<files.length;i++) {
@ -2326,7 +2326,7 @@ public class TestIndexWriter extends LuceneTestCase {
public void testImmediateDiskFull() throws IOException { public void testImmediateDiskFull() throws IOException {
MockRAMDirectory dir = new MockRAMDirectory(); MockRAMDirectory dir = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2)); IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2));
dir.setMaxSizeInBytes(Math.max(1, dir.getRecomputedActualSizeInBytes())); dir.setMaxSizeInBytes(dir.getRecomputedActualSizeInBytes());
final Document doc = new Document(); final Document doc = new Document();
doc.add(new Field("field", "aaa bbb ccc ddd eee fff ggg hhh iii jjj", Field.Store.YES, Field.Index.ANALYZED, Field.TermVector.WITH_POSITIONS_OFFSETS)); doc.add(new Field("field", "aaa bbb ccc ddd eee fff ggg hhh iii jjj", Field.Store.YES, Field.Index.ANALYZED, Field.TermVector.WITH_POSITIONS_OFFSETS));
try { try {
@ -2644,7 +2644,7 @@ public class TestIndexWriter extends LuceneTestCase {
writer.close(); writer.close();
long gen = SegmentInfos.getCurrentSegmentGeneration(dir); long gen = SegmentInfos.getCurrentSegmentGeneration(dir);
assertTrue("segment generation should be > 0 but got " + gen, gen > 0); assertTrue("segment generation should be > 1 but got " + gen, gen > 1);
final String segmentsFileName = SegmentInfos.getCurrentSegmentFileName(dir); final String segmentsFileName = SegmentInfos.getCurrentSegmentFileName(dir);
IndexInput in = dir.openInput(segmentsFileName); IndexInput in = dir.openInput(segmentsFileName);
@ -2673,7 +2673,6 @@ public class TestIndexWriter extends LuceneTestCase {
TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)) TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))
.setMaxBufferedDocs(2)); .setMaxBufferedDocs(2));
((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5); ((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3535,7 +3534,6 @@ public class TestIndexWriter extends LuceneTestCase {
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2)); IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2));
((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5); ((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3587,7 +3585,6 @@ public class TestIndexWriter extends LuceneTestCase {
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2)); IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setMaxBufferedDocs(2));
((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5); ((LogMergePolicy) writer.getConfig().getMergePolicy()).setMergeFactor(5);
writer.commit();
for (int i = 0; i < 23; i++) for (int i = 0; i < 23; i++)
addDoc(writer); addDoc(writer);
@ -3673,7 +3670,6 @@ public class TestIndexWriter extends LuceneTestCase {
dir2 = new MockRAMDirectory(); dir2 = new MockRAMDirectory();
writer2 = new IndexWriter(dir2, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); writer2 = new IndexWriter(dir2, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
writer2.commit();
cms = (ConcurrentMergeScheduler) writer2.getConfig().getMergeScheduler(); cms = (ConcurrentMergeScheduler) writer2.getConfig().getMergeScheduler();
readers = new IndexReader[NUM_COPY]; readers = new IndexReader[NUM_COPY];
@ -4956,17 +4952,4 @@ public class TestIndexWriter extends LuceneTestCase {
w.close(); w.close();
dir.close(); dir.close();
} }
public void testNoCommits() throws Exception {
// Tests that if we don't call commit(), the directory has 0 commits. This has
// changed since LUCENE-2386, where before IW would always commit on a fresh
// new index.
Directory dir = new RAMDirectory();
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
assertEquals("expected 0 commits!", 0, IndexReader.listCommits(dir).size());
// No changes still should generate a commit, because it's a new index.
writer.close();
assertEquals("expected 1 commits!", 1, IndexReader.listCommits(dir).size());
}
} }

2
lucene/src/test/org/apache/lucene/index/TestIndexWriterDelete.java
View File

@ -749,7 +749,7 @@ public class TestIndexWriterDelete extends LuceneTestCase {
MockRAMDirectory dir = new MockRAMDirectory(); MockRAMDirectory dir = new MockRAMDirectory();
IndexWriter modifier = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); IndexWriter modifier = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
modifier.commit();
dir.failOn(failure.reset()); dir.failOn(failure.reset());
for (int i = 0; i < keywords.length; i++) { for (int i = 0; i < keywords.length; i++) {

2
lucene/src/test/org/apache/lucene/index/TestIndexWriterExceptions.java
View File

@ -134,7 +134,6 @@ public class TestIndexWriterExceptions extends LuceneTestCase {
MockIndexWriter writer = new MockIndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setRAMBufferSizeMB(0.1)); MockIndexWriter writer = new MockIndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setRAMBufferSizeMB(0.1));
((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions();
//writer.setMaxBufferedDocs(10); //writer.setMaxBufferedDocs(10);
writer.commit();
if (VERBOSE) if (VERBOSE)
writer.setInfoStream(System.out); writer.setInfoStream(System.out);
@ -172,7 +171,6 @@ public class TestIndexWriterExceptions extends LuceneTestCase {
MockIndexWriter writer = new MockIndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setRAMBufferSizeMB(0.2)); MockIndexWriter writer = new MockIndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setRAMBufferSizeMB(0.2));
((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions(); ((ConcurrentMergeScheduler) writer.getConfig().getMergeScheduler()).setSuppressExceptions();
//writer.setMaxBufferedDocs(10); //writer.setMaxBufferedDocs(10);
writer.commit();
if (VERBOSE) if (VERBOSE)
writer.setInfoStream(System.out); writer.setInfoStream(System.out);

1
lucene/src/test/org/apache/lucene/index/TestIndexWriterReader.java
View File

@ -561,7 +561,6 @@ public class TestIndexWriterReader extends LuceneTestCase {
public void testAfterCommit() throws Exception { public void testAfterCommit() throws Exception {
Directory dir1 = new MockRAMDirectory(); Directory dir1 = new MockRAMDirectory();
IndexWriter writer = new IndexWriter(dir1, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); IndexWriter writer = new IndexWriter(dir1, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
writer.commit();
writer.setInfoStream(infoStream); writer.setInfoStream(infoStream);
// create the index // create the index

5
lucene/src/test/org/apache/lucene/index/TestNoDeletionPolicy.java
View File

@ -82,7 +82,10 @@ public class TestNoDeletionPolicy extends LuceneTestCaseJ4 {
doc.add(new Field("c", "a" + i, Store.YES, Index.ANALYZED)); doc.add(new Field("c", "a" + i, Store.YES, Index.ANALYZED));
writer.addDocument(doc); writer.addDocument(doc);
writer.commit(); writer.commit();
assertEquals("wrong number of commits !", i + 1, IndexReader.listCommits(dir).size()); // the reason to expect i + 2 commits is because when IndexWriter is
// created it creates a first commit. If this ever changes, then the
// expected should be i + 1 (and this comment removed).
assertEquals("wrong number of commits !", i + 2, IndexReader.listCommits(dir).size());
} }
writer.close(); writer.close();
} }

1
lucene/src/test/org/apache/lucene/index/TestStressIndexing.java
View File

@ -122,7 +122,6 @@ public class TestStressIndexing extends MultiCodecTestCase {
TEST_VERSION_CURRENT, new SimpleAnalyzer(TEST_VERSION_CURRENT)) TEST_VERSION_CURRENT, new SimpleAnalyzer(TEST_VERSION_CURRENT))
.setOpenMode(OpenMode.CREATE).setMaxBufferedDocs(10).setMergeScheduler( .setOpenMode(OpenMode.CREATE).setMaxBufferedDocs(10).setMergeScheduler(
mergeScheduler)); mergeScheduler));
modifier.commit();
TimedThread[] threads = new TimedThread[4]; TimedThread[] threads = new TimedThread[4];
int numThread = 0; int numThread = 0;

1
lucene/src/test/org/apache/lucene/index/TestStressIndexing2.java
View File

@ -150,7 +150,6 @@ public class TestStressIndexing2 extends MultiCodecTestCase {
IndexWriter w = new MockIndexWriter(dir, new IndexWriterConfig( IndexWriter w = new MockIndexWriter(dir, new IndexWriterConfig(
TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setOpenMode(OpenMode.CREATE).setRAMBufferSizeMB( TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)).setOpenMode(OpenMode.CREATE).setRAMBufferSizeMB(
0.1).setMaxBufferedDocs(maxBufferedDocs)); 0.1).setMaxBufferedDocs(maxBufferedDocs));
w.commit();
LogMergePolicy lmp = (LogMergePolicy) w.getConfig().getMergePolicy(); LogMergePolicy lmp = (LogMergePolicy) w.getConfig().getMergePolicy();
lmp.setUseCompoundFile(false); lmp.setUseCompoundFile(false);
lmp.setUseCompoundDocStore(false); lmp.setUseCompoundDocStore(false);

1
lucene/src/test/org/apache/lucene/store/TestBufferedIndexInput.java
View File

@ -243,7 +243,6 @@ public class TestBufferedIndexInput extends LuceneTestCase {
public void testSetBufferSize() throws IOException { public void testSetBufferSize() throws IOException {
File indexDir = new File(TEMP_DIR, "testSetBufferSize"); File indexDir = new File(TEMP_DIR, "testSetBufferSize");
indexDir.mkdirs(); // required for this MockFSDir since we don't commit on IW creation anymore.
MockFSDirectory dir = new MockFSDirectory(indexDir, newRandom()); MockFSDirectory dir = new MockFSDirectory(indexDir, newRandom());
try { try {
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig( IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(

2
lucene/src/test/org/apache/lucene/store/TestLockFactory.java
View File

@ -82,7 +82,7 @@ public class TestLockFactory extends LuceneTestCase {
NoLockFactory.class.isInstance(dir.getLockFactory())); NoLockFactory.class.isInstance(dir.getLockFactory()));
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT))); IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig(TEST_VERSION_CURRENT, new WhitespaceAnalyzer(TEST_VERSION_CURRENT)));
writer.commit(); // required so the second open succeed
// Create a 2nd IndexWriter. This is normally not allowed but it should run through since we're not // Create a 2nd IndexWriter. This is normally not allowed but it should run through since we're not
// using any locks: // using any locks:
IndexWriter writer2 = null; IndexWriter writer2 = null;

31
lucene/src/test/org/apache/lucene/store/TestWindowsMMap.java
View File

@ -66,22 +66,17 @@ public class TestWindowsMMap extends LuceneTestCase {
new File(TEMP_DIR,"testLuceneMmap").getAbsolutePath(); new File(TEMP_DIR,"testLuceneMmap").getAbsolutePath();
public void testMmapIndex() throws Exception { public void testMmapIndex() throws Exception {
// sometimes the directory is not cleaned by rmDir, because on Windows it FSDirectory storeDirectory;
// may take some time until the files are finally dereferenced. So clean the storeDirectory = new MMapDirectory(new File(storePathname), null);
// directory up front, or otherwise new IndexWriter will fail.
File dirPath = new File(storePathname);
rmDir(dirPath);
MMapDirectory dir = new MMapDirectory(dirPath, null);
// plan to add a set of useful stopwords, consider changing some of the // plan to add a set of useful stopwords, consider changing some of the
// interior filters. // interior filters.
StandardAnalyzer analyzer = new StandardAnalyzer(TEST_VERSION_CURRENT, Collections.emptySet()); StandardAnalyzer analyzer = new StandardAnalyzer(TEST_VERSION_CURRENT, Collections.emptySet());
// TODO: something about lock timeouts and leftover locks. // TODO: something about lock timeouts and leftover locks.
IndexWriter writer = new IndexWriter(dir, new IndexWriterConfig( IndexWriter writer = new IndexWriter(storeDirectory, new IndexWriterConfig(
TEST_VERSION_CURRENT, analyzer) TEST_VERSION_CURRENT, analyzer)
.setOpenMode(OpenMode.CREATE)); .setOpenMode(OpenMode.CREATE));
writer.commit(); IndexSearcher searcher = new IndexSearcher(storeDirectory, true);
IndexSearcher searcher = new IndexSearcher(dir, true);
for(int dx = 0; dx < 1000; dx ++) { for(int dx = 0; dx < 1000; dx ++) {
String f = randomField(); String f = randomField();
@ -92,16 +87,14 @@ public class TestWindowsMMap extends LuceneTestCase {
searcher.close(); searcher.close();
writer.close(); writer.close();
rmDir(dirPath); rmDir(new File(storePathname));
} }
private void rmDir(File dir) { private void rmDir(File dir) {
if (!dir.exists()) { File[] files = dir.listFiles();
return; for (int i = 0; i < files.length; i++) {
} files[i].delete();
for (File file : dir.listFiles()) { }
file.delete(); dir.delete();
} }
dir.delete();
}
} }