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

[유치수] [NOBTS] change arcus modifier : protocol code to uppercase

Browse Source 
change httpclient modifier : get protocol version.

git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@730 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Chisu Yu
2012-10-08 02:30:35 +00:00
parent 21f226d2d4
commit 76046d52da
3 changed files with 5 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/modifier/arcus/ArcusClientModifier.java
+1 -12
View File
@@ -73,17 +73,6 @@ public class ArcusClientModifier extends AbstractModifier {
*/
code.append("com.profiler.context.Trace.setTraceId(__nextTraceId);");
// code.append("System.out.println(__traceId);");
// code.append("System.out.println($1);");
// code.append("System.out.println(\"Change state \" + state + \" -> \" + newState);");
// code.append("System.out.println(handlingNode);");
// code.append("System.out.println(\"cmd=\" + ((cmd == null) ? null : new String(cmd.array())));");
// code.append("System.out.println(Thread.currentThread().getId());");
// code.append("System.out.println(Thread.currentThread().getName());");
// code.append("System.out.println(\"\");");
// code.append("System.out.println(\"\");");
// code.append("System.out.println(\"\");");
/**
* After sending command to the Arcus server. now waiting server
* response.
@@ -96,7 +85,7 @@ public class ArcusClientModifier extends AbstractModifier {
code.append(" java.net.SocketAddress socketAddress = handlingNode.getSocketAddress();");
code.append(" if (socketAddress instanceof java.net.InetSocketAddress) {");
code.append(" java.net.InetSocketAddress addr = (java.net.InetSocketAddress) handlingNode.getSocketAddress();");
code.append(" com.profiler.context.Trace.recordEndPoint(\"arcus:\" + addr.getHostName() + \":\" + addr.getPort());");
code.append(" com.profiler.context.Trace.recordEndPoint(\"ARCUS:\" + addr.getHostName() + \":\" + addr.getPort());");
code.append(" }");
code.append(" com.profiler.context.Trace.recordRpcName(\"arcus\", \"\");");
code.append(" com.profiler.context.Trace.recordAttribute(\"arcus.command\", ((cmd == null) ? \"UNKNOWN\" : new String(cmd.array())));");
src/main/java/com/profiler/modifier/connector/interceptors/ExecuteMethodInterceptor.java
+2 -6
View File
@@ -27,8 +27,6 @@ public class ExecuteMethodInterceptor implements StaticAroundInterceptor {
@Override
public void before(Object target, String className, String methodName, String parameterDescription, Object[] args) {
System.out.println("\n\n\n\nINVOKE HTTP START ----------------------------------------------------------------------------------------------------------------------------------------------------");
final HttpHost host = (HttpHost) args[0];
final HttpRequest request = (HttpRequest) args[1];
@@ -43,8 +41,8 @@ public class ExecuteMethodInterceptor implements StaticAroundInterceptor {
request.addHeader(Header.HTTP_SAMPLED.toString(), String.valueOf(nextId.isSampled()));
request.addHeader(Header.HTTP_FLAGS.toString(), String.valueOf(nextId.getFlags()));
Trace.recordRpcName("http-call", "");
Trace.recordEndPoint("http:" + host.getHostName() + ":" + host.getPort());
Trace.recordRpcName(request.getProtocolVersion().toString(), request.toString());
Trace.recordEndPoint(request.getProtocolVersion().toString() + ":" + host.getHostName() + ":" + host.getPort());
Trace.recordAttibute("http.url", request.toString());
Trace.record(Annotation.ClientSend);
} finally {
@@ -59,7 +57,5 @@ public class ExecuteMethodInterceptor implements StaticAroundInterceptor {
Trace.traceBlockBegin();
Trace.record(Annotation.ClientRecv, StopWatch.stopAndGetElapsed("ExecuteMethodInterceptor"));
Trace.traceBlockEnd();
System.out.println("\n\n\n\nINVOKE HTTP END ----------------------------------------------------------------------------------------------------------------------------------------------------");
}
}
src/main/java/com/profiler/modifier/tomcat/interceptors/StandardHostValveInvokeInterceptor.java
+2 -2
View File
@@ -43,9 +43,9 @@ public class StandardHostValveInvokeInterceptor implements StaticAroundIntercept
}
Trace.setTraceId(newTraceID);
}
Trace.recordRpcName("tomcat", requestURL);
Trace.recordEndPoint(request.getProtocol() + ":" + request.getLocalAddr() + ":" + request.getLocalPort());
Trace.recordEndPoint(request.getProtocol() + ":" + request.getLocalName() + ":" + request.getLocalPort());
Trace.recordAttibute("http.params", parameters);
Trace.record(Annotation.ServerRecv);