Add repository and user/team lifecycle listener extension points

James Moger

2014-06-09 ca4d98678c20e4033fdaca09ecbbf0f5952e0b84

 src/main/java/com/gitblit/manager/ServicesManager.java

@@ -47,6 +47,7 @@
import com.gitblit.utils.IdGenerator;
import com.gitblit.utils.StringUtils;
import com.gitblit.utils.TimeUtils;
import com.gitblit.utils.WorkQueue;

/**
 * Services manager manages long-running services/processes that either have no
@@ -66,6 +67,10 @@

   private final IGitblit gitblit;

   private final IdGenerator idGenerator;

   private final WorkQueue workQueue;

   private FanoutService fanoutService;

   private GitDaemon gitDaemon;
@@ -75,6 +80,9 @@
   public ServicesManager(IGitblit gitblit) {
      this.settings = gitblit.getSettings();
      this.gitblit = gitblit;
      int defaultThreadPoolSize = settings.getInteger(Keys.execution.defaultThreadPoolSize, 1);
      this.idGenerator = new IdGenerator();
      this.workQueue = new WorkQueue(idGenerator, defaultThreadPoolSize);
   }

   @Override
@@ -99,13 +107,26 @@
      if (sshDaemon != null) {
         sshDaemon.stop();
      }
      workQueue.stop();
      return this;
   }

   public boolean isServingRepositories() {
      return settings.getBoolean(Keys.git.enableGitServlet, true)
            || (gitDaemon != null && gitDaemon.isRunning())
            || (sshDaemon != null && sshDaemon.isRunning());
      return isServingHTTP()
            || isServingGIT()
            || isServingSSH();
   }

   public boolean isServingHTTP() {
      return settings.getBoolean(Keys.git.enableGitServlet, true);
   }

   public boolean isServingGIT() {
      return gitDaemon != null && gitDaemon.isRunning();
   }

   public boolean isServingSSH() {
      return sshDaemon != null && sshDaemon.isRunning();
   }

   protected void configureFederation() {
@@ -158,7 +179,7 @@
      String bindInterface = settings.getString(Keys.git.sshBindInterface, "localhost");
      if (port > 0) {
         try {
            sshDaemon = new SshDaemon(gitblit, new IdGenerator());
            sshDaemon = new SshDaemon(gitblit, workQueue);
            sshDaemon.start();
         } catch (IOException e) {
            sshDaemon = null;