diff --git a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java index d99e1ccec..ec7b3690a 100644 --- a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java +++ b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java @@ -50,7 +50,6 @@ public class Execute2MethodInterceptor implements SimpleAroundInterceptor, ByteC } final HttpUriRequest request = (HttpUriRequest) args[0]; - // UUID format을 그대로. final boolean sampling = trace.canSampled(); if (!sampling) { if(isDebug) { diff --git a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/ConnectInterceptor.java b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/ConnectInterceptor.java index 7682107a8..af7e311a6 100644 --- a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/ConnectInterceptor.java +++ b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/ConnectInterceptor.java @@ -36,7 +36,9 @@ public class ConnectInterceptor implements SimpleAroundInterceptor, ByteCodeMeth logger.beforeInterceptor(target, args); } - Trace trace = traceContext.currentRawTraceObject(); + // Trace trace = traceContext.currentRawTraceObject(); + // sampling 레이트를 추가로 확인하여 액션을 취하는 로직이 없으므로 그냥 currentTraceObject()를 호출한다. + Trace trace = traceContext.currentTraceObject(); if (trace == null) { logger.warn("Trace object is null"); return; diff --git a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/CreateConnectorInterceptor.java b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/CreateConnectorInterceptor.java index eff424bf6..eee81cca2 100644 --- a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/CreateConnectorInterceptor.java +++ b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/CreateConnectorInterceptor.java @@ -30,8 +30,9 @@ public class CreateConnectorInterceptor implements SimpleAroundInterceptor, Byte if (isDebug) { logger.beforeInterceptor(target, args); } - - Trace trace = traceContext.currentRawTraceObject(); + // Trace trace = traceContext.currentRawTraceObject(); + // sampling 레이트를 추가로 확인하여 액션을 취하는 로직이 없으므로 그냥 currentTraceObject()를 호출한다. + Trace trace = traceContext.currentTraceObject(); if (trace == null) { logger.warn("Trace object is null"); return; diff --git a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/InitializeConnectorInterceptor.java b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/InitializeConnectorInterceptor.java index bb72f8e44..df54cbf41 100644 --- a/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/InitializeConnectorInterceptor.java +++ b/src/main/java/com/nhn/pinpoint/profiler/modifier/connector/npc/interceptor/InitializeConnectorInterceptor.java @@ -33,9 +33,10 @@ public class InitializeConnectorInterceptor implements SimpleAroundInterceptor, logger.beforeInterceptor(target, args); } - Trace trace = traceContext.currentRawTraceObject(); + // Trace trace = traceContext.currentRawTraceObject(); + // sampling 레이트를 추가로 확인하여 액션을 취하는 로직이 없으므로 그냥 currentTraceObject()fmf g + Trace trace = traceContext.currentTraceObject(); if (trace == null) { - logger.warn("Trace object is null"); return; } diff --git a/src/main/java/com/nhn/pinpoint/profiler/sender/TcpDataSender.java b/src/main/java/com/nhn/pinpoint/profiler/sender/TcpDataSender.java index af0dc6518..d200b0f4d 100644 --- a/src/main/java/com/nhn/pinpoint/profiler/sender/TcpDataSender.java +++ b/src/main/java/com/nhn/pinpoint/profiler/sender/TcpDataSender.java @@ -200,6 +200,7 @@ public class TcpDataSender implements DataSender { } private void fireComplete() { + logger.debug("fireComplete"); fireState.compareAndSet(true, false); }