adding fixIndex() method

radu-gheorghe · Apr 27, 2012 · 9555759 · 9555759
1 parent cd79f03
commit 9555759
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java b/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java
@@ -114,6 +114,8 @@ public class InternalIndexShard extends AbstractIndexShardComponent implements I
 
 
     private final boolean checkIndexOnStartup;
+
+    private final boolean fixIndexOnStartup;
 
     private long checkIndexTook = 0;
 
@@ -163,6 +165,7 @@ public InternalIndexShard(ShardId shardId, @IndexSettings Settings indexSettings
         logger.debug("state: [CREATED]");
 
         this.checkIndexOnStartup = indexSettings.getAsBoolean("index.shard.check_on_startup", false);
+        this.fixIndexOnStartup = indexSettings.getAsBoolean("index.shard.check_on_startup_and_fix", false);
     }
 
     public MergeSchedulerProvider mergeScheduler() {
@@ -866,6 +869,15 @@ private void checkIndex(boolean throwException) throws IndexShardException {
                 if (logger.isDebugEnabled()) {
                     logger.debug("check index [success]\n{}", new String(os.underlyingBytes(), 0, os.size()));
                 }
+                if (fixIndexOnStartup) {
+                    if (logger.isDebugEnabled()) {
+                        logger.debug("fixing index, writing new segments file ...");
+                    }
+                    checkIndex.fixIndex(status);
+                    if (logger.isDebugEnabled()) {
+                        logger.debug("index fixed, wrote new segments file \"{}\"", status.segmentsFileName);
+                    }
+                }
             }
             checkIndexTook = System.currentTimeMillis() - time;
         } catch (Exception e) {