| | |
| | | import org.slf4j.LoggerFactory; |
| | | |
| | | import com.gitblit.Keys; |
| | | import com.gitblit.utils.IdGenerator; |
| | | import com.gitblit.utils.StringUtils; |
| | | import com.gitblit.utils.WorkQueue; |
| | | import com.gitblit.utils.WorkQueue.CancelableRunnable; |
| | |
| | | /** The task, as scheduled on a worker thread. */ |
| | | private final AtomicReference<Future<?>> task; |
| | | |
| | | private final WorkQueue.Executor executor; |
| | | private WorkQueue workQueue; |
| | | |
| | | public BaseCommand() { |
| | | task = Atomics.newReference(); |
| | | IdGenerator gen = new IdGenerator(); |
| | | WorkQueue w = new WorkQueue(gen); |
| | | this.executor = w.getDefaultQueue(); |
| | | } |
| | | |
| | | @Override |
| | |
| | | @Override |
| | | public void destroy() { |
| | | log.debug("destroying " + getClass().getName()); |
| | | Future<?> future = task.getAndSet(null); |
| | | if (future != null && !future.isDone()) { |
| | | future.cancel(true); |
| | | } |
| | | session = null; |
| | | ctx = null; |
| | | } |
| | |
| | | |
| | | protected void provideStateTo(final BaseCommand cmd) { |
| | | cmd.setContext(ctx); |
| | | cmd.setWorkQueue(workQueue); |
| | | cmd.setInputStream(in); |
| | | cmd.setOutputStream(out); |
| | | cmd.setErrorStream(err); |
| | | cmd.setExitCallback(exit); |
| | | } |
| | | |
| | | public WorkQueue getWorkQueue() { |
| | | return workQueue; |
| | | } |
| | | |
| | | public void setWorkQueue(WorkQueue workQueue) { |
| | | this.workQueue = workQueue; |
| | | } |
| | | |
| | | public void setContext(SshCommandContext ctx) { |
| | |
| | | } |
| | | |
| | | /** Runnable function which can throw an exception. */ |
| | | public static interface CommandRunnable { |
| | | public void run() throws Exception; |
| | | public interface CommandRunnable { |
| | | void run() throws Exception; |
| | | } |
| | | |
| | | /** Runnable function which can retrieve a project name related to the task */ |
| | | public static interface RepositoryCommandRunnable extends CommandRunnable { |
| | | public String getRepository(); |
| | | public interface RepositoryCommandRunnable extends CommandRunnable { |
| | | String getRepository(); |
| | | } |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | private int handleError(final Throwable e) { |
| | | if ((e.getClass() == IOException.class && "Pipe closed".equals(e.getMessage())) || // |
| | | (e.getClass() == SshException.class && "Already closed".equals(e.getMessage())) || // |
| | | if ((e.getClass() == IOException.class && "Pipe closed".equals(e.getMessage())) || |
| | | (e.getClass() == SshException.class && "Already closed".equals(e.getMessage())) || |
| | | e.getClass() == InterruptedIOException.class) { |
| | | // This is sshd telling us the client just dropped off while |
| | | // we were waiting for a read or a write to complete. Either |
| | |
| | | */ |
| | | protected void startThread(final CommandRunnable thunk) { |
| | | final TaskThunk tt = new TaskThunk(thunk); |
| | | task.set(executor.submit(tt)); |
| | | task.set(workQueue.getDefaultQueue().submit(tt)); |
| | | } |
| | | |
| | | /** Thrown from {@link CommandRunnable#run()} with client message and code. */ |