Python server IO logged to standard out by default.

Set the destination of input, output, and error logs for remote servers same as Java process.

PiperOrigin-RevId: 551642169
Change-Id: Ibdb2219723bc983c3e2200f9f398f5be599ac196

common/src/main/java/com/google/tsunami/common/command/CommandExecutor.java

@@ -91,6 +91,20 @@ public Process execute(Executor executor)
     return process;
   }
 
+  /**
+   * Starts the command and asynchronously collect output and error.
+   *
+   * @return Started {@link Process} object.
+   * @throws IOException if an I/O error occurs when starting the command executing process.
+   * @throws InterruptedException if interrupted while waiting for the command's output.
+   * @throws ExecutionException if the command execution failed.
+   */
+  public Process executeAsync() throws IOException, InterruptedException, ExecutionException {
+    logger.atInfo().log("Executing the following command: '%s'", COMMAND_ARGS_JOINER.join(args));
+    process = processBuilder.inheritIO().start();
+    return process;
+  }
+
   /**
    * Starts the command without collecting output and error streams.
    *

common/src/test/java/com/google/tsunami/common/command/CommandExecutorTest.java

@@ -38,6 +38,17 @@ public void execute_always_startsProcessAndReturnsProcessInstance()
     assertThat(process.exitValue()).isEqualTo(0);
   }
 
+  @Test
+  public void executeAsync_always_startsProcessAndReturnsProcessInstance()
+      throws IOException, InterruptedException, ExecutionException {
+    CommandExecutor executor = new CommandExecutor("/bin/sh", "-c", "echo 1");
+
+    Process process = executor.executeAsync();
+    process.waitFor();
+
+    assertThat(process.exitValue()).isEqualTo(0);
+  }
+
   @Test
   public void executeWithNoStreamCollection_always_startsProcessAndReturnsProcessInstance()
       throws IOException, InterruptedException, ExecutionException {

main/src/main/java/com/google/tsunami/main/cli/server/RemoteServerLoader.java

@@ -69,7 +69,7 @@ private String getCommand(String flag, Object command) {
 
   private Optional<Process> runProcess(CommandExecutor executor) {
     try {
-      return Optional.of(executor.executeWithNoStreamCollection());
+      return Optional.of(executor.executeAsync());
     } catch (IOException | InterruptedException | ExecutionException e) {
       logger.atWarning().withCause(e).log("Could not execute language server binary.");
     }

plugin_server/py/plugin_server.py

@@ -163,4 +163,5 @@ def _configure_health_service(server):
 
 
 if __name__ == '__main__':
+  flags.set_default(logging.ALSOLOGTOSTDERR, True)
   app.run(main)