James Moger
2012-03-17 e28b2f68fc38e4976a0e8bc11af45834bbde940c
src/com/gitblit/GitBlit.java
@@ -73,6 +73,7 @@
import com.gitblit.models.FederationSet;
import com.gitblit.models.Metric;
import com.gitblit.models.RepositoryModel;
import com.gitblit.models.SearchResult;
import com.gitblit.models.ServerSettings;
import com.gitblit.models.ServerStatus;
import com.gitblit.models.SettingModel;
@@ -86,6 +87,7 @@
import com.gitblit.utils.MetricUtils;
import com.gitblit.utils.ObjectCache;
import com.gitblit.utils.StringUtils;
import com.gitblit.utils.TimeUtils;
/**
 * GitBlit is the servlet context listener singleton that acts as the core for
@@ -136,6 +138,8 @@
   private MailExecutor mailExecutor;
   
   private LuceneExecutor luceneExecutor;
   private TimeZone timezone;
   public GitBlit() {
@@ -182,6 +186,7 @@
      }
      return self().timezone;
   }
   /**
    * Returns the boolean value for the specified key. If the key does not
@@ -807,6 +812,8 @@
               "gitblit", null, "postReceiveScript")));
         model.mailingLists = new ArrayList<String>(Arrays.asList(config.getStringList(
               "gitblit", null, "mailingList")));
         model.indexedBranches = new ArrayList<String>(Arrays.asList(config.getStringList(
               "gitblit", null, "indexBranch")));
      }
      model.HEAD = JGitUtils.getHEADRef(r);
      model.availableRefs = JGitUtils.getAvailableHeadTargets(r);
@@ -866,6 +873,9 @@
            repository.close();
         }
      }
      // close any open index writer/searcher in the Lucene executor
      luceneExecutor.close(repositoryName);
   }
   /**
@@ -882,7 +892,7 @@
      if (repositoryMetricsCache.hasCurrent(model.name, model.lastChange)) {
         return new ArrayList<Metric>(repositoryMetricsCache.getObject(model.name));
      }
      List<Metric> metrics = MetricUtils.getDateMetrics(repository, null, true, null);
      List<Metric> metrics = MetricUtils.getDateMetrics(repository, null, true, null, getTimezone());
      repositoryMetricsCache.updateObject(model.name, model.lastChange, metrics);
      return new ArrayList<Metric>(metrics);
   }
@@ -947,6 +957,12 @@
         // create repository
         logger.info("create repository " + repository.name);
         r = JGitUtils.createRepository(repositoriesFolder, repository.name);
         // automatically index master branch if Lucene integration is enabled
         if (luceneExecutor.isReady()) {
            repository.indexedBranches = new ArrayList<String>();
            repository.indexedBranches.add("refs/heads/master");
         }
      } else {
         // rename repository
         if (!repositoryName.equalsIgnoreCase(repository.name)) {
@@ -1054,6 +1070,9 @@
      }
      if (!ArrayUtils.isEmpty(repository.mailingLists)) {
         config.setStringList("gitblit", null, "mailingList", repository.mailingLists);
      }
      if (!ArrayUtils.isEmpty(repository.indexedBranches)) {
         config.setStringList("gitblit", null, "indexBranch", repository.indexedBranches);
      }
      try {
         config.save();
@@ -1643,6 +1662,20 @@
      }
      return scripts;
   }
   /**
    * Search the specified repositories using the Lucene query.
    *
    * @param query
    * @param page
    * @param pageSize
    * @param repositories
    * @return
    */
   public List<SearchResult> search(String query, int page, int pageSize, List<String> repositories) {
      List<SearchResult> srs = luceneExecutor.search(query, page, pageSize, repositories);
      return srs;
   }
   /**
    * Notify the administrators by email.
@@ -1806,9 +1839,23 @@
      setUserService(loginService);
      mailExecutor = new MailExecutor(settings);
      if (mailExecutor.isReady()) {
         logger.info("Mail executor is scheduled to process the message queue every 2 minutes.");
         scheduledExecutor.scheduleAtFixedRate(mailExecutor, 1, 2, TimeUnit.MINUTES);
      } else {
         logger.warn("Mail server is not properly configured.  Mail services disabled.");
      }
      luceneExecutor = new LuceneExecutor(settings, repositoriesFolder);
      if (luceneExecutor.isReady()) {
         String idle = settings.getString(Keys.lucene.frequency, "2 mins");
         int mins = TimeUtils.convertFrequencyToMinutes(idle);
         if (mins <= 2) {
            mins = 2;
            idle = mins + " mins";
         }
         logger.info("Lucene executor is scheduled to process ref changes every " + idle);
         scheduledExecutor.scheduleAtFixedRate(luceneExecutor, 1, mins, TimeUnit.MINUTES);
      } else {
         logger.warn("Lucene integration is disabled.");
      }
      if (startFederation) {
         configureFederation();
@@ -1882,5 +1929,6 @@
   public void contextDestroyed(ServletContextEvent contextEvent) {
      logger.info("Gitblit context destroyed by servlet container.");
      scheduledExecutor.shutdownNow();
      luceneExecutor.close();
   }
}