diff --git a/src/main/java/com/profiler/context/Span.java b/src/main/java/com/profiler/context/Span.java index 1fecc7d0d..045eaacaf 100644 --- a/src/main/java/com/profiler/context/Span.java +++ b/src/main/java/com/profiler/context/Span.java @@ -98,6 +98,7 @@ public class Span { sb.append(", ServiceName=").append(serviceName); sb.append(", EndPoint=").append(endPoint); sb.append(", Annotations=").append(annotations); + sb.append(", BinaryAnnotations=").append(binaryAnnotations); sb.append("}"); return sb.toString(); diff --git a/src/main/java/com/profiler/context/Trace.java b/src/main/java/com/profiler/context/Trace.java index d33ad32b8..6ad3908e8 100644 --- a/src/main/java/com/profiler/context/Trace.java +++ b/src/main/java/com/profiler/context/Trace.java @@ -113,6 +113,10 @@ public final class Trace { annotate(annotation.getCode(), duration); } + public static void recordAttribute(final String key, final String value) { + recordAttibute(key, (Object) value); + } + public static void recordAttibute(final String key, final Object value) { if (!tracingEnabled) return; diff --git a/src/main/java/com/profiler/modifier/arcus/ArcusClientModifier.java b/src/main/java/com/profiler/modifier/arcus/ArcusClientModifier.java index 1f2e670e9..a26943307 100644 --- a/src/main/java/com/profiler/modifier/arcus/ArcusClientModifier.java +++ b/src/main/java/com/profiler/modifier/arcus/ArcusClientModifier.java @@ -84,7 +84,8 @@ public class ArcusClientModifier extends AbstractModifier { code.append(" java.net.InetSocketAddress addr = (java.net.InetSocketAddress) handlingNode.getSocketAddress();"); code.append(" com.profiler.context.Trace.recordEndPoint(addr.getHostName(), addr.getPort());"); code.append(" }"); - code.append(" com.profiler.context.Trace.recordRpcName(\"arcus\", ((cmd == null) ? \"UNKNOWN\" : new String(cmd.array())));"); + code.append(" com.profiler.context.Trace.recordRpcName(\"arcus\", \"\");"); + code.append(" com.profiler.context.Trace.recordAttribute(\"arcus.command\", ((cmd == null) ? \"UNKNOWN\" : new String(cmd.array())));"); code.append(" System.out.println(\"CS\");"); code.append(" com.profiler.context.Trace.record(com.profiler.context.Annotation.ClientSend);"); code.append("} else if (newState == net.spy.memcached.ops.OperationState.COMPLETE) {"); diff --git a/src/main/java/com/profiler/modifier/connector/interceptors/ExecuteMethodInterceptor.java b/src/main/java/com/profiler/modifier/connector/interceptors/ExecuteMethodInterceptor.java index aeedf5f96..ea8a82e60 100644 --- a/src/main/java/com/profiler/modifier/connector/interceptors/ExecuteMethodInterceptor.java +++ b/src/main/java/com/profiler/modifier/connector/interceptors/ExecuteMethodInterceptor.java @@ -43,7 +43,7 @@ public class ExecuteMethodInterceptor implements StaticAroundInterceptor { Trace.recordRpcName("http-call", ""); Trace.recordEndPoint(host.getHostName(), host.getPort()); - Trace.recordMessage("http.uri=" + request.toString()); + Trace.recordAttibute("http.url", request.toString()); Trace.record(Annotation.ClientSend); StopWatch.start("ExecuteMethodInterceptor");