feat(ci): Fix JUnit test case name uniqueness

Author: PerfectSlayer

.circleci/collect_results.sh

@@ -28,9 +28,11 @@ do
   cp "$RESULT_XML_FILE" "$TEST_RESULTS_DIR/$AGGREGATED_FILE_NAME"
   # Replace Java Object hashCode by marker in testcase XML nodes to get stable test names
   sed -i '/<testcase/ s/@[0-9a-f]\{5,\}/@HASHCODE/g' "$TEST_RESULTS_DIR/$AGGREGATED_FILE_NAME"
+  # Replace random port numbers by marker in testcase XML nodes to get stable test names
+  sed -i '/<testcase/ s/localhost:[0-9]\{2,5\}/localhost:PORT/g' "$TEST_RESULTS_DIR/$AGGREGATED_FILE_NAME"
   if cmp -s "$RESULT_XML_FILE" "$TEST_RESULTS_DIR/$AGGREGATED_FILE_NAME"; then
     echo ""
   else
-    echo " (hashCode replaced)"
+    echo -n " (non-stable test names detected)"
   fi
 done <   <(find "${TEST_RESULT_DIRS[@]}" -name \*.xml -print0)

dd-trace-core/src/main/java/datadog/trace/common/writer/BinaryWriter.java

@@ -0,0 +1,94 @@
+package datadog.trace.common.writer;
+
+import datadog.trace.bootstrap.instrumentation.api.WriterConstants;
+import datadog.trace.core.DDSpan;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.List;
+
+public class BinaryWriter implements Writer {
+  private final Path output;
+  private ObjectOutputStream outputStream;
+
+  /**
+   * Creates a {@link BinaryWriter} from {@link MultiWriter} configuration.
+   *
+   * @param configuration The {@link MultiWriter} configuration.
+   * @return The created writer instance.
+   */
+  public static Writer fromArguments(String configuration) {
+    if (configuration == null) {
+      throw new IllegalArgumentException("writer configuration is null");
+    }
+    if (configuration.startsWith(WriterConstants.BINARY_WRITER_TYPE + ':')) {
+      configuration = configuration.substring(WriterConstants.BINARY_WRITER_TYPE.length() + 1);
+    }
+    if (configuration.isEmpty()) {
+      throw new IllegalArgumentException("no output configuration");
+    }
+    return new BinaryWriter(Paths.get(configuration));
+  }
+
+  public BinaryWriter(Path output) {
+    this.output = output;
+    start();
+  }
+
+  @Override
+  public void write(List<DDSpan> trace) {
+    if (this.outputStream != null) {
+      try {
+        for (DDSpan span : trace) {
+          this.outputStream.writeObject(span);
+        }
+      } catch (IOException e) {
+        throw new RuntimeException("Failed to write trace", e);
+      }
+    }
+  }
+
+  @Override
+  public void start() {
+    checkOutputFolder();
+    try {
+      this.outputStream = new ObjectOutputStream(Files.newOutputStream(this.output));
+    } catch (IOException e) {
+      throw new RuntimeException(e);
+    }
+  }
+
+  private void checkOutputFolder() {
+    if (!Files.exists(this.output.getParent())) {
+      try {
+        Files.createFile(this.output.getParent());
+      } catch (IOException e) {
+        throw new RuntimeException("Failed to create writer output directory", e);
+      }
+    }
+  }
+
+  @Override
+  public boolean flush() {
+    if (this.outputStream != null) {
+      try {
+        this.outputStream.flush();
+        return true;
+      } catch (IOException ignored) {
+      }
+    }
+    return false;
+  }
+
+  @Override
+  public void close() {
+    this.outputStream = null;
+  }
+
+  @Override
+  public void incrementDropCounts(int spanCount) {
+    // Not supported
+  }
+}