Skip to content

Commit 65a82f5

Browse files
committed
suggestions and compare resource name
1 parent ed9c9d8 commit 65a82f5

2 files changed

Lines changed: 21 additions & 4 deletions

File tree

dd-trace-ot/src/test/java/datadog/opentracing/DDTracerTest.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
import datadog.trace.common.writer.ListWriter;
1010
import datadog.trace.common.writer.Writer;
1111
import datadog.trace.context.TraceScope;
12-
import datadog.trace.core.DDSpan;
1312
import datadog.trace.test.util.DDJavaSpecification;
1413
import io.opentracing.Scope;
1514
import java.util.HashMap;
@@ -86,10 +85,9 @@ void shouldProduceBlackholeScopes() throws Exception {
8685
assertEquals(1, writer.size());
8786
assertEquals(2, writer.firstTrace().size());
8887
assertEquals(
89-
Long.toString(((DDSpan) span.getDelegate()).context().getSpanId()),
90-
span.context().toSpanId());
88+
Long.toString(writer.firstTrace().get(0).context().getSpanId()), span.context().toSpanId());
9189
assertEquals(
92-
Long.toString(((DDSpan) ((OTSpan) visibleSpan).getDelegate()).context().getSpanId()),
90+
Long.toString(writer.firstTrace().get(1).context().getSpanId()),
9391
visibleSpan.context().toSpanId());
9492

9593
tracer.close();

dd-trace-ot/src/test/java/datadog/opentracing/OpenTracingAPITest.java

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,8 +211,10 @@ void nestedSpans() throws Exception {
211211
DDSpan childSpan = trace.get(1);
212212
assertEquals("someService", parentSpan.getServiceName());
213213
assertEquals("someOperation", parentSpan.getOperationName().toString());
214+
assertEquals("someOperation", parentSpan.getResourceName().toString());
214215
assertEquals("someService", childSpan.getServiceName());
215216
assertEquals("someOperation2", childSpan.getOperationName().toString());
217+
assertEquals("someOperation2", childSpan.getResourceName().toString());
216218
assertEquals(parentSpan.getSpanId(), childSpan.getParentId());
217219
}
218220

@@ -248,6 +250,7 @@ void spanWithAsyncPropagation() throws Exception {
248250
DDSpan span = trace.get(0);
249251
assertEquals("someService", span.getServiceName());
250252
assertEquals("someOperation", span.getOperationName().toString());
253+
assertEquals("someOperation", span.getResourceName().toString());
251254
}
252255

253256
@Test
@@ -281,6 +284,14 @@ void spanInheritsAsyncPropagation() throws Exception {
281284
assertEquals(1, writer.size());
282285
List<DDSpan> trace = writer.get(0);
283286
assertEquals(2, trace.size());
287+
DDSpan outerSpan = trace.get(0);
288+
DDSpan innerSpan = trace.get(1);
289+
assertEquals("someService", outerSpan.getServiceName());
290+
assertEquals("someOperation", outerSpan.getOperationName().toString());
291+
assertEquals("someOperation", outerSpan.getResourceName().toString());
292+
assertEquals("otherService", innerSpan.getServiceName());
293+
assertEquals("otherOperation", innerSpan.getOperationName().toString());
294+
assertEquals("otherOperation", innerSpan.getResourceName().toString());
284295
}
285296

286297
@Test
@@ -308,6 +319,7 @@ void spanContextIdsEqualTracerIds() throws Exception {
308319
DDSpan span = trace.get(0);
309320
assertEquals("someService", span.getServiceName());
310321
assertEquals("someOperation", span.getOperationName().toString());
322+
assertEquals("someOperation", span.getResourceName().toString());
311323
}
312324

313325
@Test
@@ -331,6 +343,8 @@ void closingScopeWhenNotOnTop() throws Exception {
331343
// then: 2 * scopeListener.afterScopeClosed(), 1 * traceInterceptor.onTraceComplete(...)
332344
verify(scopeListener, times(2)).afterScopeClosed();
333345
verify(traceInterceptor).onTraceComplete(any());
346+
assertEquals(1, writer.size());
347+
assertEquals(2, writer.get(0).size());
334348
verifyNoMoreInteractions(scopeListener, traceInterceptor);
335349
clearInvocations(scopeListener, traceInterceptor);
336350

@@ -374,6 +388,8 @@ void closingScopeWhenNotOnTopInStrictMode() throws Exception {
374388
// 1 * scopeListener.afterScopeActivated() (scope restoration after strict mode exception)
375389
verify(scopeListener).afterScopeClosed();
376390
verify(traceInterceptor).onTraceComplete(any());
391+
assertEquals(1, writer.size());
392+
assertEquals(2, writer.get(0).size());
377393
verify(scopeListener).afterScopeActivated();
378394
verifyNoMoreInteractions(scopeListener, traceInterceptor);
379395
clearInvocations(scopeListener, traceInterceptor);
@@ -422,8 +438,10 @@ void injectAndExtractContext() throws Exception {
422438
DDSpan serverSpanDD = sortedTraces.get(1).get(0);
423439
assertEquals("someClientService", clientSpan.getServiceName());
424440
assertEquals("clientOperation", clientSpan.getOperationName().toString());
441+
assertEquals("clientOperation", clientSpan.getResourceName().toString());
425442
assertEquals("someService", serverSpanDD.getServiceName());
426443
assertEquals("serverOperation", serverSpanDD.getOperationName().toString());
444+
assertEquals("serverOperation", serverSpanDD.getResourceName().toString());
427445
assertEquals(clientSpan.context().getSpanId(), serverSpanDD.getParentId());
428446
}
429447

@@ -456,5 +474,6 @@ void tolerateNullSpanActivation() throws Exception {
456474
DDSpan span = trace.get(0);
457475
assertEquals("someService", span.getServiceName());
458476
assertEquals("someOperation", span.getOperationName().toString());
477+
assertEquals("someOperation", span.getResourceName().toString());
459478
}
460479
}

0 commit comments

Comments
 (0)