diff options
author | Carl Mastrangelo <notcarl@google.com> | 2017-09-29 18:20:37 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-09-29 18:20:37 -0700 |
commit | 02466744bbe238403bfe16ae5ba337436ac71b7f (patch) | |
tree | 3898c6ba2851aad3fa3cc8001fff03cd8ee6b2c7 /testing-proto | |
parent | cbcab9b4983dd490fb56168a43ec97d929657098 (diff) | |
download | grpc-grpc-java-02466744bbe238403bfe16ae5ba337436ac71b7f.tar.gz |
core: move census registration into internal
also preserve tracing bit when rebuilding a MethodDescriptor
Diffstat (limited to 'testing-proto')
-rw-r--r-- | testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java b/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java index 300c166a1..2071f6871 100644 --- a/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java +++ b/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java @@ -24,7 +24,6 @@ import static io.grpc.MethodDescriptor.MethodType.UNARY; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNotNull; -import io.grpc.InternalMethodDescriptor; import io.grpc.MethodDescriptor; import io.opencensus.trace.Tracing; import io.opencensus.trace.export.SampledSpanStore; @@ -61,8 +60,9 @@ public class SimpleServiceTest { @Test public void registerSampledMethodsForTracing() throws Exception { - // Make sure SimpleServiceGrpc class is loaded + // Make sure SimpleServiceGrpc and CensusTracingModule classes are loaded. assertNotNull(Class.forName(SimpleServiceGrpc.class.getName())); + assertNotNull(Class.forName("io.grpc.internal.CensusTracingModule")); String[] methodNames = new String[] { "grpc.testing.SimpleService/UnaryRpc", @@ -72,12 +72,20 @@ public class SimpleServiceTest { ArrayList<String> expectedSpans = new ArrayList<String>(); for (String methodName : methodNames) { - expectedSpans.add(InternalMethodDescriptor.generateTraceSpanName(false, methodName)); - expectedSpans.add(InternalMethodDescriptor.generateTraceSpanName(true, methodName)); + expectedSpans.add(generateTraceSpanName(false, methodName)); + expectedSpans.add(generateTraceSpanName(true, methodName)); } SampledSpanStore sampledStore = Tracing.getExportComponent().getSampledSpanStore(); Set<String> registeredSpans = sampledStore.getRegisteredSpanNamesForCollection(); assertThat(registeredSpans).containsAllIn(expectedSpans); } + + /** + * Copy of {@link io.grpc.internal.CensusTracingModule#generateTraceSpanName} to break dependency. + */ + private static String generateTraceSpanName(boolean isServer, String fullMethodName) { + String prefix = isServer ? "Recv" : "Sent"; + return prefix + "." + fullMethodName.replace('/', '.'); + } } |