diff --git a/src/main/java/com/profiler/modifier/arcus/interceptors/AddOpInterceptor.java b/src/main/java/com/profiler/modifier/arcus/interceptors/AddOpInterceptor.java index f3b4803b0..f394911b2 100644 --- a/src/main/java/com/profiler/modifier/arcus/interceptors/AddOpInterceptor.java +++ b/src/main/java/com/profiler/modifier/arcus/interceptors/AddOpInterceptor.java @@ -40,7 +40,5 @@ public class AddOpInterceptor implements StaticBeforeInterceptor { } setServiceCode.invoke(op, serviceCode); - - System.out.println("[HIPPO-ADD_OP_FUNC] INJECT SERVICE_CODE INTO OP=" + serviceCode); } } diff --git a/src/main/java/com/profiler/modifier/arcus/interceptors/BaseOperationTransitionStateInterceptor.java b/src/main/java/com/profiler/modifier/arcus/interceptors/BaseOperationTransitionStateInterceptor.java index 69a80f23e..7c1f6aa0f 100644 --- a/src/main/java/com/profiler/modifier/arcus/interceptors/BaseOperationTransitionStateInterceptor.java +++ b/src/main/java/com/profiler/modifier/arcus/interceptors/BaseOperationTransitionStateInterceptor.java @@ -60,13 +60,19 @@ public class BaseOperationTransitionStateInterceptor implements StaticBeforeInte asyncTrace.recordEndPoint("ARCUS:" + address.getHostName() + ":" + address.getPort()); } - String serviceName = (String) getServiceCode.invoke(target); + String serviceCode = (String) getServiceCode.invoke(target); - if (serviceName == null) { - serviceName = "UNKNOWN"; + if (serviceCode == null) { + serviceCode = "UNKNOWN"; } - asyncTrace.recordRpcName(ServiceType.ARCUS, serviceName, baseOperation.getClass().getSimpleName()); + ServiceType svcType = ServiceType.ARCUS; + + if(serviceCode.equals(ServiceType.MEMCACHED.getDesc())) { + svcType = ServiceType.MEMCACHED; + } + + asyncTrace.recordRpcName(svcType, serviceCode, baseOperation.getClass().getSimpleName()); String cmd = getCommand(baseOperation); asyncTrace.recordAttibute("arcus.command", cmd); diff --git a/src/main/java/com/profiler/modifier/arcus/interceptors/CacheManagerConstructInterceptor.java b/src/main/java/com/profiler/modifier/arcus/interceptors/CacheManagerConstructInterceptor.java index 93dc9f34c..e5428a891 100644 --- a/src/main/java/com/profiler/modifier/arcus/interceptors/CacheManagerConstructInterceptor.java +++ b/src/main/java/com/profiler/modifier/arcus/interceptors/CacheManagerConstructInterceptor.java @@ -24,8 +24,6 @@ public class CacheManagerConstructInterceptor implements StaticAfterInterceptor logger.info("after " + StringUtils.toString(target) + " " + className + "." + methodName + parameterDescription + " args:" + Arrays.toString(args) + " result:" + result); } - System.out.println("[HIPPO-CACHE_MAN_CTOR] SET SERVICE_CODE=" + args[1]); - setServiceCode.invoke(target, (String) args[1]); } } diff --git a/src/main/java/com/profiler/modifier/arcus/interceptors/SetCacheManagerInterceptor.java b/src/main/java/com/profiler/modifier/arcus/interceptors/SetCacheManagerInterceptor.java index 9f6c39b6c..2d1688f9e 100644 --- a/src/main/java/com/profiler/modifier/arcus/interceptors/SetCacheManagerInterceptor.java +++ b/src/main/java/com/profiler/modifier/arcus/interceptors/SetCacheManagerInterceptor.java @@ -32,8 +32,6 @@ public class SetCacheManagerInterceptor implements StaticBeforeInterceptor { CacheManager cm = (CacheManager) args[0]; String serviceCode = getServiceCode.invoke(cm); - System.out.println("[HIPPO-SET_CACHE_MAN_FUNC] GET SERVICE_CODE FROM CM=" + serviceCode); - setServiceCode.invoke((MemcachedClient) target, serviceCode); } }