diff options
Diffstat (limited to 'java/com/google/gerrit/lucene/LuceneChangeIndex.java')
-rw-r--r-- | java/com/google/gerrit/lucene/LuceneChangeIndex.java | 29 |
1 files changed, 24 insertions, 5 deletions
diff --git a/java/com/google/gerrit/lucene/LuceneChangeIndex.java b/java/com/google/gerrit/lucene/LuceneChangeIndex.java index 87f9396a90..a9e431ef12 100644 --- a/java/com/google/gerrit/lucene/LuceneChangeIndex.java +++ b/java/com/google/gerrit/lucene/LuceneChangeIndex.java @@ -55,6 +55,7 @@ import com.google.gerrit.reviewdb.converter.ProtoConverter; import com.google.gerrit.server.StarredChangesUtil; import com.google.gerrit.server.config.GerritServerConfig; import com.google.gerrit.server.config.SitePaths; +import com.google.gerrit.server.index.AutoFlush; import com.google.gerrit.server.index.IndexExecutor; import com.google.gerrit.server.index.IndexUtils; import com.google.gerrit.server.index.change.ChangeField; @@ -155,7 +156,8 @@ public class LuceneChangeIndex implements ChangeIndex { SitePaths sitePaths, @IndexExecutor(INTERACTIVE) ListeningExecutorService executor, ChangeData.Factory changeDataFactory, - @Assisted Schema<ChangeData> schema) + @Assisted Schema<ChangeData> schema, + AutoFlush autoFlush) throws IOException { this.executor = executor; this.changeDataFactory = changeDataFactory; @@ -170,18 +172,35 @@ public class LuceneChangeIndex implements ChangeIndex { if (LuceneIndexModule.isInMemoryTest(cfg)) { openIndex = new ChangeSubIndex( - schema, sitePaths, new RAMDirectory(), "ramOpen", openConfig, searcherFactory); + schema, + sitePaths, + new RAMDirectory(), + "ramOpen", + openConfig, + searcherFactory, + autoFlush); closedIndex = new ChangeSubIndex( - schema, sitePaths, new RAMDirectory(), "ramClosed", closedConfig, searcherFactory); + schema, + sitePaths, + new RAMDirectory(), + "ramClosed", + closedConfig, + searcherFactory, + autoFlush); } else { Path dir = LuceneVersionManager.getDir(sitePaths, CHANGES, schema); openIndex = new ChangeSubIndex( - schema, sitePaths, dir.resolve(CHANGES_OPEN), openConfig, searcherFactory); + schema, sitePaths, dir.resolve(CHANGES_OPEN), openConfig, searcherFactory, autoFlush); closedIndex = new ChangeSubIndex( - schema, sitePaths, dir.resolve(CHANGES_CLOSED), closedConfig, searcherFactory); + schema, + sitePaths, + dir.resolve(CHANGES_CLOSED), + closedConfig, + searcherFactory, + autoFlush); } } |