commit 88a274019f4d96b69c75bde283268ef45a6bc2ab
author Dave Borowitz <dborowitz@google.com> Wed Oct 09 12:16:44 2013 -0700
committer Dave Borowitz <dborowitz@google.com> Fri Oct 11 10:47:29 2013 -0700
tree a34c727203fd2387ab56be6488ad98c0c8215162
parent bb5a30f8a59daa1735a7d13d1e420657ef0ac907

Run indexing in sameThreadExecutor when index.threads <= 0

Change-Id: I3fb5a2ec039335cd8962b4a0973fbff7de55842f

gerrit-server/src/main/java/com/google/gerrit/server/index/IndexModule.java

diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/index/IndexModule.java b/gerrit-server/src/main/java/com/google/gerrit/server/index/IndexModule.java
index 4bf7c35..2cfc93d 100644
--- a/gerrit-server/src/main/java/com/google/gerrit/server/index/IndexModule.java
+++ b/gerrit-server/src/main/java/com/google/gerrit/server/index/IndexModule.java
@@ -19,7 +19,6 @@
 import com.google.gerrit.lifecycle.LifecycleModule;
 import com.google.gerrit.server.config.GerritServerConfig;
 import com.google.gerrit.server.git.WorkQueue;
-import com.google.gerrit.server.git.WorkQueue.Executor;
 import com.google.gerrit.server.query.change.ChangeQueryRewriter;
 import com.google.inject.AbstractModule;
 import com.google.inject.Injector;
@@ -108,13 +107,11 @@
       if (threads <= 0) {
         threads = config.getInt("index", null, "threads", 0);
       }
-      Executor executor;
       if (threads <= 0) {
-        executor = workQueue.getDefaultQueue();
-      } else {
-        executor = workQueue.createQueue(threads, "index");
+        return MoreExecutors.sameThreadExecutor();
       }
-      return MoreExecutors.listeningDecorator(executor);
+      return MoreExecutors.listeningDecorator(
+          workQueue.createQueue(threads, "index"));
     }
   }
 }