Method start

java/com/google/gerrit/sshd/SshCommand.java:64–119

(ChannelSession channel, Environment env)

  protected PrintWriter stderr;

  @Override
  public void start(ChannelSession channel, Environment env) throws IOException {
    String sessionId = HexFormat.fromInt(getSession().getSessionId());
    startThread(
        () -> {
          try (PerThreadCache ignored = PerThreadCache.create();
              DynamicOptions pluginOptions = new DynamicOptions(injector, dynamicBeans)) {
            parseCommandLine(pluginOptions);
            stdout = toPrintWriter(out);
            stderr = toPrintWriter(err);
            try (TraceContext traceContext = enableTracing();
                PerformanceLogContext performanceLogContext =
                    new PerformanceLogContext(config, performanceLoggers)) {
              traceContext.addTag("SSH_SESSION", sessionId);
              RequestInfo requestInfo =
                  RequestInfo.builder(RequestInfo.RequestType.SSH, getName(), user, traceContext)
                      .build();
              Throwable error = null;
              try (RequestStateContext requestStateContext =
                  RequestStateContext.open()
                      .setPerformanceSummaryProvider(performanceLogContext)
                      .addRequestStateProvider(
                          deadlineCheckerFactory.create(requestInfo, deadline))) {
                requestListeners.runEach(l -> l.onRequest(requestInfo));
                SshCommand.this.run();
              } catch (InvalidDeadlineException e) {
                error = e;
                stderr.println(e.getMessage());
              } catch (RuntimeException e) {
                error = e;
                Optional<RequestCancelledException> requestCancelledException =
                    RequestCancelledException.getFromCausalChain(e);
                if (!requestCancelledException.isPresent()) {
                  Throwables.throwIfUnchecked(e);
                }
                cancellationMetrics.countCancelledRequest(
                    requestInfo, requestCancelledException.get().getCancellationReason());
                StringBuilder msg =
                    new StringBuilder(requestCancelledException.get().formatCancellationReason());
                if (requestCancelledException.get().getCancellationMessage().isPresent()) {
                  msg.append(
                      String.format(
                          " (%s)", requestCancelledException.get().getCancellationMessage().get()));
                }
                stderr.println(msg.toString());
              } finally {
                sshMetrics.countRequest(requestInfo, error);
              }
            } finally {
              stdout.flush();
              stderr.flush();
            }
          }
        },
        AccessPath.SSH_COMMAND);
  }

  protected abstract void run() throws UnloggedFailure, Failure, Exception;