SSHD: Add support for git pack commands

David Ostrovsky

2014-02-22 e3b636e7fa2a823cfe90ea75e88034a60f7e59e6

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

@@ -32,7 +32,6 @@
import com.gitblit.Constants.AccessPermission;
import com.gitblit.Constants.AccessRestrictionType;
import com.gitblit.Constants.FederationToken;
import com.gitblit.GitBlit;
import com.gitblit.IStoredSettings;
import com.gitblit.Keys;
import com.gitblit.fanout.FanoutNioService;
@@ -43,6 +42,8 @@
import com.gitblit.models.RepositoryModel;
import com.gitblit.models.UserModel;
import com.gitblit.service.FederationPullService;
import com.gitblit.transport.ssh.SshDaemon;
import com.gitblit.utils.IdGenerator;
import com.gitblit.utils.StringUtils;
import com.gitblit.utils.TimeUtils;

@@ -62,13 +63,15 @@

   private final IStoredSettings settings;

   private final GitBlit gitblit;
   private final IGitblit gitblit;

   private FanoutService fanoutService;

   private GitDaemon gitDaemon;

   public ServicesManager(GitBlit gitblit) {
   private SshDaemon sshDaemon;

   public ServicesManager(IGitblit gitblit) {
      this.settings = gitblit.getSettings();
      this.gitblit = gitblit;
   }
@@ -78,6 +81,7 @@
      configureFederation();
      configureFanout();
      configureGitDaemon();
      configureSshDaemon();

      return this;
   }
@@ -90,6 +94,9 @@
      }
      if (gitDaemon != null) {
         gitDaemon.stop();
      }
      if (sshDaemon != null) {
         sshDaemon.stop();
      }
      return this;
   }
@@ -136,6 +143,20 @@
         }
      } else {
         logger.info("Git Daemon is disabled.");
      }
   }

   protected void configureSshDaemon() {
      int port = settings.getInteger(Keys.git.sshPort, 0);
      String bindInterface = settings.getString(Keys.git.sshBindInterface, "localhost");
      if (port > 0) {
         try {
            sshDaemon = new SshDaemon(gitblit, new IdGenerator());
            sshDaemon.start();
         } catch (IOException e) {
            sshDaemon = null;
            logger.error(MessageFormat.format("Failed to start SSH daemon on {0}:{1,number,0}", bindInterface, port), e);
         }
      }
   }

@@ -209,11 +230,11 @@
   private class FederationPuller extends FederationPullService {

      public FederationPuller(FederationModel registration) {
         super(Arrays.asList(registration));
         super(gitblit, Arrays.asList(registration));
      }

      public FederationPuller(List<FederationModel> registrations) {
         super(registrations);
         super(gitblit, registrations);
      }

      @Override
@@ -226,6 +247,5 @@
               "Next pull of {0} @ {1} scheduled for {2,date,yyyy-MM-dd HH:mm}",
               registration.name, registration.url, registration.nextPull));
      }

   }
}