diff --git a/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java b/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java index 04518759f..aa2b4e2b5 100644 --- a/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java +++ b/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/Execute2MethodInterceptor.java @@ -50,7 +50,7 @@ public class Execute2MethodInterceptor implements StaticAroundInterceptor, ByteC final boolean sampling = trace.canSampled(); if (!sampling) { if(isDebug) { - logger.debug("set Samplingflag= "); + logger.debug("set Sampling flag=false"); } request.addHeader(Header.HTTP_SAMPLED.toString(), SamplingFlagUtils.SAMPLING_RATE_FALSE); return; diff --git a/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/ExecuteMethodInterceptor.java b/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/ExecuteMethodInterceptor.java index c8ef93c2e..8da526aea 100644 --- a/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/ExecuteMethodInterceptor.java +++ b/src/main/java/com/profiler/modifier/connector/httpclient4/interceptor/ExecuteMethodInterceptor.java @@ -50,6 +50,9 @@ public class ExecuteMethodInterceptor implements StaticAroundInterceptor, ByteCo final HttpRequest request = (HttpRequest) args[1]; final boolean sampling = trace.canSampled(); if (!sampling) { + if(isDebug) { + logger.debug("set Sampling flag=false"); + } request.addHeader(Header.HTTP_SAMPLED.toString(), SamplingFlagUtils.SAMPLING_RATE_FALSE); return; } diff --git a/src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementCreateInterceptor.java b/src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementCreateInterceptor.java index 5bd5d2c41..a7d1a2db6 100644 --- a/src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementCreateInterceptor.java +++ b/src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementCreateInterceptor.java @@ -64,6 +64,12 @@ public class PreparedStatementCreateInterceptor implements StaticAroundIntercept logger.debug("internal jdbc scope. skip trace"); return; } + boolean success = InterceptorUtils.isSuccess(result); + if(success) { + // preparedStatement의 생성이 성공하였을 경우만 PreparedStatement에 databaseInfo를 세팅해야 한다. + DatabaseInfo databaseInfo = (DatabaseInfo) getUrl.invoke(target); + this.setUrl.invoke(result, databaseInfo); + } Trace trace = traceContext.currentTraceObject(); if (trace == null) { @@ -73,14 +79,7 @@ public class PreparedStatementCreateInterceptor implements StaticAroundIntercept String sql = (String) args[0]; // 성공하였을 때만 PreparedSteatement에 Parsing Result를 넣어야 한다. ParsingResult parsingResult = trace.recordSqlInfo(sql); - - boolean success = InterceptorUtils.isSuccess(result); if (success) { - - // preparedStatement의 생성이 성공하였을 경우만 PreparedStatement에 databaseInfo를 세팅해야 한다. - DatabaseInfo databaseInfo = (DatabaseInfo) getUrl.invoke(target); - this.setUrl.invoke(result, databaseInfo); - if (parsingResult != null) { this.setSql.invoke(result, parsingResult); } diff --git a/src/main/java/com/profiler/modifier/tomcat/interceptors/StandardHostValveInvokeInterceptor.java b/src/main/java/com/profiler/modifier/tomcat/interceptors/StandardHostValveInvokeInterceptor.java index ea17353cc..e1f083fd0 100644 --- a/src/main/java/com/profiler/modifier/tomcat/interceptors/StandardHostValveInvokeInterceptor.java +++ b/src/main/java/com/profiler/modifier/tomcat/interceptors/StandardHostValveInvokeInterceptor.java @@ -72,9 +72,10 @@ public class StandardHostValveInvokeInterceptor implements StaticAroundIntercept trace = traceContext.newTraceObject(); if (!trace.canSampled()){ logger.debug("TraceID not exist. camSampled is false. skip trace. requestUrl:{}, remoteAddr:{}", new Object[] {requestURL, remoteAddr }); + return; } else { if (isDebug) { - logger.debug("TraceID not exist. start new trace. requestUrl:{}, remoteAddr:{}", new Object[] { requestURL, remoteAddr }); + logger.debug("TraceID not exist. start new trace. traceId:{} requestUrl:{}, remoteAddr:{}", new Object[] { traceId, requestURL, remoteAddr }); } } }