Blindly trying to fix the smoke tests

Author: jbachorik

internal-api/src/main/java/datadog/trace/util/PidHelper.java

@@ -5,10 +5,12 @@
 import datadog.trace.context.TraceScope;
 import de.thetaphi.forbiddenapis.SuppressForbidden;
 import java.io.BufferedReader;
+import java.io.IOException;
 import java.io.InputStreamReader;
 import java.lang.management.ManagementFactory;
 import java.util.Collections;
 import java.util.Set;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Supplier;
 import org.slf4j.Logger;
@@ -70,18 +72,29 @@ public static Set<String> getJavaPids() {
     ProcessBuilder pb = new ProcessBuilder("jps");
     try (TraceScope ignored = AgentTracer.get().muteTracing()) {
       Process p = pb.start();
+      // start draining the subcommand's pipes asynchronously to avoid flooding them
+      CompletableFuture<Set<String>> collecting =
+          CompletableFuture.supplyAsync(
+              (Supplier<Set<String>>)
+                  () -> {
+                    try (BufferedReader br =
+                        new BufferedReader(new InputStreamReader(p.getInputStream()))) {
+                      return br.lines()
+                          .filter(l -> !l.contains("jps"))
+                          .map(
+                              l -> {
+                                int idx = l.indexOf(' ');
+                                return l.substring(0, idx);
+                              })
+                          .collect(java.util.stream.Collectors.toSet());
+                    } catch (IOException e) {
+                      log.debug("Unable to list java processes via 'jps'", e);
+                      return Collections.emptySet();
+                    }
+                  });
       if (p.waitFor(500, TimeUnit.MILLISECONDS)) {
         if (p.exitValue() == 0) {
-          try (BufferedReader br = new BufferedReader(new InputStreamReader(p.getInputStream()))) {
-            return br.lines()
-                .filter(l -> !l.contains("jps"))
-                .map(
-                    l -> {
-                      int idx = l.indexOf(' ');
-                      return l.substring(0, idx);
-                    })
-                .collect(java.util.stream.Collectors.toSet());
-          }
+          return collecting.get();
         } else {
           log.debug("Execution of 'jps' failed with exit code {}", p.exitValue());
         }