open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix some typos in tests

This commit is contained in:
Nikolay Martynov 2020-02-20 10:07:53 -05:00
parent cddd368fc0
commit a4071ca768
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dd-trace-ot/src/traceAgentTest/groovy/DDApiIntegrationTest.groovy
View File

@ -85,7 +85,7 @@ class DDApiIntegrationTest extends DDSpecification {
.withExposedPorts(datadog.trace.api.Config.DEFAULT_TRACE_AGENT_PORT) .withExposedPorts(datadog.trace.api.Config.DEFAULT_TRACE_AGENT_PORT)
.withStartupTimeout(Duration.ofSeconds(120)) .withStartupTimeout(Duration.ofSeconds(120))
// Apparently we need to sleep for a bit so agent's response `{"service:,env:":1}` in rate_by_service. // Apparently we need to sleep for a bit so agent's response `{"service:,env:":1}` in rate_by_service.
// This is clearly a race-condition and maybe we should av oid verifying complete response // This is clearly a race-condition and maybe we should avoid verifying complete response
.withStartupCheckStrategy(new MinimumDurationRunningStartupCheckStrategy(Duration.ofSeconds(10))) .withStartupCheckStrategy(new MinimumDurationRunningStartupCheckStrategy(Duration.ofSeconds(10)))
// .withLogConsumer { output -> // .withLogConsumer { output ->
// print output.utf8String // print output.utf8String
@ -98,7 +98,8 @@ class DDApiIntegrationTest extends DDSpecification {
File tmpDir = File.createTempDir() File tmpDir = File.createTempDir()
tmpDir.deleteOnExit() tmpDir.deleteOnExit()
socketPath = new File(tmpDir, "socket") socketPath = new File(tmpDir, "socket")
process = Runtime.getRuntime().exec("socat UNIX-LISEN:${socketPath},reuseaddr,fork TCP-CONNECT:${agentContainerHost}:${agentContainerPort}") println "!!!socat UNIX-LISEN:${socketPath},reuseaddr,fork TCP-CONNECT:${agentContainerHost}:${agentContainerPort}"
process = Runtime.getRuntime().exec("socat UNIX-LISTEN:${socketPath},reuseaddr,fork TCP-CONNECT:${agentContainerHost}:${agentContainerPort}")
} }
def cleanupSpec() { def cleanupSpec() {