Close the Lucene index writer/searcher on a repository rename or delete

James Moger

2012-03-15 e6637cd48c50aa5ebbc01e7826b835b75bd92a87

 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

@@ -780,7 +785,7 @@
      RepositoryModel model = new RepositoryModel();

      model.name = repositoryName;

      model.hasCommits = JGitUtils.hasCommits(r);

      model.lastChange = JGitUtils.getLastChange(r, null);

      model.lastChange = JGitUtils.getLastChange(r);

      model.isBare = r.isBare();

      StoredConfig config = JGitUtils.readConfig(r);

      if (config != null) {

@@ -866,6 +871,9 @@
            repository.close();

         }

      }

		
      // close any open index writer/searcher in the Lucene executor

      luceneExecutor.close(repositoryName);

   }



   /**

@@ -882,7 +890,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);

   }

@@ -1643,6 +1651,19 @@
      }

      return scripts;

   }

	
   /**

    * Search the specified repositories using the Lucene query.

    * 
    * @param query

    * @param maximumHits

    * @param repositories

    * @return

    */

   public List<SearchResult> search(String query, int maximumHits, List<String> repositories) {

      List<SearchResult> srs = luceneExecutor.search(query, maximumHits, repositories);

      return srs;

   }



   /**

    * Notify the administrators by email.

@@ -1806,9 +1827,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();

@@ -1838,14 +1873,18 @@
         WebXmlSettings webxmlSettings = new WebXmlSettings(context);



         // 0.7.0 web.properties in the deployed war folder

         File overrideFile = new File(context.getRealPath("/WEB-INF/web.properties"));

         if (overrideFile.exists()) {

            webxmlSettings.applyOverrides(overrideFile);

         String webProps = context.getRealPath("/WEB-INF/web.properties");

         if (!StringUtils.isEmpty(webProps)) {

            File overrideFile = new File(webProps);

            if (overrideFile.exists()) {

               webxmlSettings.applyOverrides(overrideFile);

            }

         }

			


         // 0.8.0 gitblit.properties file located outside the deployed war

         // folder lie, for example, on RedHat OpenShift.

         overrideFile = getFileOrFolder("gitblit.properties");

         File overrideFile = getFileOrFolder("gitblit.properties");

         if (!overrideFile.getPath().equals("gitblit.properties")) {

            webxmlSettings.applyOverrides(overrideFile);

         }

@@ -1878,5 +1917,6 @@
   public void contextDestroyed(ServletContextEvent contextEvent) {

      logger.info("Gitblit context destroyed by servlet container.");

      scheduledExecutor.shutdownNow();

      luceneExecutor.close();

   }

}