kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1.合并埋点发送端部分代码。

This commit is contained in:
wusheng 2015-12-04 20:46:29 +08:00
parent 081c3cbbf3
commit 186b01b9d6
3 changed files with 3 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/LocalBuriedPointSender.java
View File

@ -16,7 +16,7 @@ import java.util.logging.Logger;
public class LocalBuriedPointSender implements IBuriedPointSender {
private static Logger logger = Logger.getLogger(LocalBuriedPointSender.class.getName());
private static Logger logger = Logger.getLogger(IBuriedPointSender.class.getName());
public ContextData beforeSend(Identification id) {
if (!AuthDesc.isAuth())

58
skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/RPCBuriedPointSender.java
View File

@ -1,59 +1,3 @@
package com.ai.cloud.skywalking.buriedpoint;
import com.ai.cloud.skywalking.api.IBuriedPointSender;
import com.ai.cloud.skywalking.buffer.ContextBuffer;
import com.ai.cloud.skywalking.conf.AuthDesc;
import com.ai.cloud.skywalking.conf.Config;
import com.ai.cloud.skywalking.context.Context;
import com.ai.cloud.skywalking.model.ContextData;
import com.ai.cloud.skywalking.model.EmptyContextData;
import com.ai.cloud.skywalking.model.Identification;
import com.ai.cloud.skywalking.protocol.Span;
import com.ai.cloud.skywalking.util.ContextGenerator;
import java.util.logging.Level;
import java.util.logging.Logger;
public class RPCBuriedPointSender implements IBuriedPointSender {
private static Logger logger = Logger.getLogger(RPCBuriedPointReceiver.class.getName());
public ContextData beforeSend(Identification id) {
if (!AuthDesc.isAuth())
return new EmptyContextData();
Span spanData = ContextGenerator.generateSpanFromThreadLocal(id);
// 将新创建的Context存放到ThreadLocal栈中。
Context.append(spanData);
// 并将当前的Context返回回去
return new ContextData(spanData);
}
public void afterSend() {
if (!AuthDesc.isAuth())
return;
// 获取上下文的栈顶中的元素
Span spanData = Context.removeLastSpan();
if (spanData == null) {
return;
}
spanData.setCost(System.currentTimeMillis() - spanData.getStartDate());
if (Config.BuriedPoint.PRINTF) {
logger.log(Level.ALL, "viewpointId:" + spanData.getViewPointId() + "\tParentLevelId:" + spanData.
getParentLevel() + "\tLevelId:" + spanData.getLevelId());
}
if (!Config.Sender.IS_OFF) {
ContextBuffer.save(spanData);
}
}
public void handleException(Throwable e) {
Span span = Context.getLastSpan();
span.handleException(e, Config.BuriedPoint.MAX_EXCEPTION_STACK_LENGTH);
}
}
public class RPCBuriedPointSender extends LocalBuriedPointSender {}

2
skywalking-sdk-plugin/src/main/resources/plugin-span-type-notice.txt
View File

@ -1,5 +1,5 @@
#默认埋点类型对照信息
M:本地JAVA方法
J:JDBC
W:web servlet调用
W:web调用
D:dubbo/dubbox调用