home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-23 19:56:59 +10:00
Code Issues Packages Projects Releases Wiki Activity

[강운덕] [LUCYSUS-1744] jdbc api interceptor에서 recordRpc 삭제.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@1324 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2013-03-12 04:35:03 +00:00
parent 2ec3c54051
commit e6a26b5171
7 changed files with 1 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/interceptor/bci/InstrumentClass.java
-1
View File
@@ -1,6 +1,5 @@
package com.profiler.interceptor.bci;
import javassist.CannotCompileException;
import javassist.CtMethod;
import com.profiler.interceptor.Interceptor;
src/main/java/com/profiler/modifier/db/interceptor/DriverConnectInterceptor.java
-1
View File
@@ -74,7 +74,6 @@ public class DriverConnectInterceptor implements StaticAroundInterceptor, ByteCo
}
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementCreateInterceptor.java
-2
View File
@@ -48,7 +48,6 @@ public class PreparedStatementCreateInterceptor implements StaticAroundIntercept
DatabaseInfo databaseInfo = (DatabaseInfo) getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
@@ -88,7 +87,6 @@ public class PreparedStatementCreateInterceptor implements StaticAroundIntercept
}
trace.recordApi(descriptor);
// trace.recordApi(apiId);
trace.markAfterTime();
trace.traceBlockEnd();
src/main/java/com/profiler/modifier/db/interceptor/PreparedStatementExecuteQueryInterceptor.java
-1
View File
@@ -52,7 +52,6 @@ public class PreparedStatementExecuteQueryInterceptor implements StaticAroundInt
DatabaseInfo databaseInfo = (DatabaseInfo) getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getExecuteQueryType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteQueryInterceptor.java
-1
View File
@@ -49,7 +49,6 @@ public class StatementExecuteQueryInterceptor implements StaticAroundInterceptor
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getExecuteQueryType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
src/main/java/com/profiler/modifier/db/interceptor/StatementExecuteUpdateInterceptor.java
-1
View File
@@ -50,7 +50,6 @@ public class StatementExecuteUpdateInterceptor implements StaticAroundIntercepto
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
src/main/java/com/profiler/modifier/db/interceptor/TransactionInterceptor.java
+1 -41
View File
@@ -79,7 +79,6 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
@@ -90,31 +89,8 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
private void afterStartTransaction(Trace trace, Connection target, Object[] arg, Object result) {
try {
trace.recordApi(descriptor, arg);
// trace.recordApi(apiId, arg);
trace.recordException(result);
// Boolean autocommit = (Boolean) arg;
// boolean success = InterceptorUtils.isSuccess(result);
// if (!autocommit) {
// // transaction start;
// if (success) {
// trace.recordAttribute("Transaction", "begin");
// trace.recordApi(descriptor, null);
// } else {
// trace.recordAttribute("Transaction", "begin fail");
// Throwable th = (Throwable) result;
// trace.recordAttribute("Exception", th.getMessage());
// }
//
// } else {
// if (success) {
// trace.recordAttribute("Transaction", "autoCommit:false");
// } else {
// trace.recordAttribute("Transaction", "autoCommit:false fail");
// Throwable th = (Throwable) result;
// trace.recordAttribute("Exception", th.getMessage());
// }
//
// }
} catch (Exception e) {
if (logger.isLoggable(Level.WARNING)) {
logger.log(Level.WARNING, e.getMessage(), e);
@@ -132,12 +108,10 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
trace.recordDestinationAddress(databaseInfo.getHost());
// trace.record(Annotation.ClientSend);
}
@@ -146,25 +120,14 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
trace.recordDestinationAddress(databaseInfo.getHost());
trace.recordApi(descriptor);
// trace.recordApi(apiId);
trace.recordException(result);
// boolean success = InterceptorUtils.isSuccess(result);
// if (success) {
// trace.recordAttribute("Transaction", "commit");
// } else {
// trace.recordAttribute("Transaction", "commit fail");
// Throwable th = (Throwable) result;
// trace.recordAttribute("Exception", th.getMessage());
// }
} catch (Exception e) {
if (logger.isLoggable(Level.WARNING)) {
logger.log(Level.WARNING, e.getMessage(), e);
@@ -183,7 +146,6 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
@@ -196,14 +158,12 @@ public class TransactionInterceptor implements StaticAroundInterceptor, ByteCode
DatabaseInfo databaseInfo = (DatabaseInfo) this.getUrl.invoke(target);
trace.recordServiceType(databaseInfo.getType());
trace.recordRpcName(databaseInfo.getUrl());
trace.recordEndPoint(databaseInfo.getUrl());
trace.recordDestinationId(databaseInfo.getDatabaseId());
trace.recordDestinationAddress(databaseInfo.getHost());
trace.recordApi(descriptor);
// trace.recordApi(apiId);
trace.recordException(result);
// boolean success = InterceptorUtils.isSuccess(result);
// if (success) {