Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
b69cd851
S
SkyWalking
项目概览
apache
/
SkyWalking
上一次同步 1 年多
通知
302
Star
21345
Fork
6091
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
SkyWalking
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
b69cd851
编写于
2月 21, 2017
作者:
wu-sheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix compile issues
上级
96f6c5fa
变更
15
隐藏空白更改
内联
并排
Showing
15 changed file
with
41 addition
and
51 deletion
+41
-51
skywalking-commons/skywalking-trace/src/test/java/com/a/eye/skywalking/trace/SpanTestCase.java
...rc/test/java/com/a/eye/skywalking/trace/SpanTestCase.java
+2
-32
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/EasyLogger.java
...ain/java/com/a/eye/skywalking/api/logging/EasyLogger.java
+2
-2
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/SyncFileWriter.java
...java/com/a/eye/skywalking/api/logging/SyncFileWriter.java
+2
-2
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/WriterFactory.java
.../java/com/a/eye/skywalking/api/logging/WriterFactory.java
+1
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/EnhanceException.java
...e/skywalking/api/plugin/interceptor/EnhanceException.java
+1
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/assist/NoCocurrencyAceessObject.java
...i/plugin/interceptor/assist/NoCocurrencyAceessObject.java
+1
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassEnhancePluginDefine.java
.../plugin/interceptor/enhance/ClassEnhancePluginDefine.java
+6
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassInstanceMethodsEnhancePluginDefine.java
...ptor/enhance/ClassInstanceMethodsEnhancePluginDefine.java
+0
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassStaticMethodsEnhancePluginDefine.java
...ceptor/enhance/ClassStaticMethodsEnhancePluginDefine.java
+1
-1
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/queue/TraceSegmentProcessQueue.java
.../a/eye/skywalking/api/queue/TraceSegmentProcessQueue.java
+3
-3
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/util/TraceIdGenerator.java
.../java/com/a/eye/skywalking/api/util/TraceIdGenerator.java
+1
-1
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestAroundInterceptor.java
...om/a/eye/skywalking/api/plugin/TestAroundInterceptor.java
+1
-2
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestInterceptorDefine.java
...om/a/eye/skywalking/api/plugin/TestInterceptorDefine.java
+0
-2
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestStaticAroundInterceptor.java
...ye/skywalking/api/plugin/TestStaticAroundInterceptor.java
+1
-1
skywalking-sniffer/skywalking-sniffer-mock/src/test/java/com/a/eye/skywalking/sniffer/mock/MockTracerContextListenerTestCase.java
...lking/sniffer/mock/MockTracerContextListenerTestCase.java
+19
-0
未找到文件。
skywalking-commons/skywalking-trace/src/test/java/com/a/eye/skywalking/trace/SpanTestCase.java
浏览文件 @
b69cd851
...
...
@@ -39,7 +39,7 @@ public class SpanTestCase {
Span
span1
=
new
Span
(
0
,
"serviceA"
);
Tags
.
SPAN_LAYER
.
asHttp
(
span1
);
Tags
.
COMPONENT
.
set
(
span1
,
"Spring"
);
Tags
.
PEER_HOST
.
set
(
span1
,
ipToInt
(
"127.0.0.1"
)
);
Tags
.
PEER_HOST
.
set
(
span1
,
"127.0.0.1"
);
Tags
.
ERROR
.
set
(
span1
,
true
);
Tags
.
STATUS_CODE
.
set
(
span1
,
302
);
Tags
.
URL
.
set
(
span1
,
"http://127.0.0.1/serviceA"
);
...
...
@@ -49,40 +49,10 @@ public class SpanTestCase {
Map
<
String
,
Object
>
tags
=
span1
.
getTags
();
Assert
.
assertEquals
(
8
,
tags
.
size
());
Assert
.
assertTrue
(
Tags
.
SPAN_LAYER
.
isHttp
(
span1
));
Assert
.
assertEquals
(
"127.0.0.1"
,
intToIp
(
Tags
.
PEER_HOST
.
get
(
span1
)
));
Assert
.
assertEquals
(
"127.0.0.1"
,
Tags
.
PEER_HOST
.
get
(
span1
));
Assert
.
assertTrue
(
Tags
.
ERROR
.
get
(
span1
));
}
private
int
ipToInt
(
String
ipAddress
)
{
int
result
=
0
;
String
[]
ipAddressInArray
=
ipAddress
.
split
(
"\\."
);
for
(
int
i
=
3
;
i
>=
0
;
i
--)
{
int
ip
=
Integer
.
parseInt
(
ipAddressInArray
[
3
-
i
]);
//left shifting 24,16,8,0 and bitwise OR
//1. 192 << 24
//1. 168 << 16
//1. 1 << 8
//1. 2 << 0
result
|=
ip
<<
(
i
*
8
);
}
return
result
;
}
private
static
String
intToIp
(
int
longIp
)
{
StringBuffer
sb
=
new
StringBuffer
(
""
);
sb
.
append
(
String
.
valueOf
((
longIp
>>>
24
)));
sb
.
append
(
"."
);
sb
.
append
(
String
.
valueOf
((
longIp
&
0x00FFFFFF
)
>>>
16
));
sb
.
append
(
"."
);
sb
.
append
(
String
.
valueOf
((
longIp
&
0x0000FFFF
)
>>>
8
));
sb
.
append
(
"."
);
sb
.
append
(
String
.
valueOf
((
longIp
&
0x000000FF
)));
return
sb
.
toString
();
}
@Test
public
void
testLogException
(){
Span
span1
=
new
Span
(
0
,
"serviceA"
);
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/EasyLogger.java
浏览文件 @
b69cd851
...
...
@@ -2,13 +2,13 @@ package com.a.eye.skywalking.api.logging;
import
com.a.eye.skywalking.api.logging.api.ILog
;
import
com.a.eye.skywalking.util.LoggingUtil
;
import
com.a.eye.skywalking.api.util.LoggingUtil
;
import
java.net.URLEncoder
;
import
java.text.SimpleDateFormat
;
import
java.util.Date
;
import
static
com
.
a
.
eye
.
skywalking
.
logging
.
LogLevel
.*;
import
static
com
.
a
.
eye
.
skywalking
.
api
.
logging
.
LogLevel
.*;
/**
* Created by xin on 16-6-23.
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/SyncFileWriter.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.logging
;
import
com.a.eye.skywalking.conf.Config
;
import
com.a.eye.skywalking.util.LoggingUtil
;
import
com.a.eye.skywalking.api.conf.Config
;
import
com.a.eye.skywalking.api.util.LoggingUtil
;
import
java.io.File
;
import
java.io.FileNotFoundException
;
import
java.io.FileOutputStream
;
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/logging/WriterFactory.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.logging
;
import
com.a.eye.skywalking.conf.Config
;
import
com.a.eye.skywalking.
api.
conf.Config
;
public
class
WriterFactory
{
private
WriterFactory
(){
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/EnhanceException.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin.interceptor
;
import
com.a.eye.skywalking.plugin.PluginException
;
import
com.a.eye.skywalking.
api.
plugin.PluginException
;
public
class
EnhanceException
extends
PluginException
{
private
static
final
long
serialVersionUID
=
-
2234782755784217255L
;
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/assist/NoCocurrencyAceessObject.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin.interceptor.assist
;
import
com.a.eye.skywalking.api.plugin.interceptor.EnhancedClassInstanceContext
;
import
com.a.eye.skywalking.plugin.interceptor.InterceptorException
;
import
com.a.eye.skywalking.
api.
plugin.interceptor.InterceptorException
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor
;
/**
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassEnhancePluginDefine.java
浏览文件 @
b69cd851
...
...
@@ -3,7 +3,12 @@ package com.a.eye.skywalking.api.plugin.interceptor.enhance;
import
com.a.eye.skywalking.api.logging.api.ILog
;
import
com.a.eye.skywalking.api.logging.api.LogManager
;
import
com.a.eye.skywalking.api.plugin.AbstractClassEnhancePluginDefine
;
import
com.a.eye.skywalking.plugin.PluginException
;
import
com.a.eye.skywalking.api.plugin.PluginException
;
import
com.a.eye.skywalking.api.plugin.interceptor.ConstructorInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.EnhanceException
;
import
com.a.eye.skywalking.api.plugin.interceptor.EnhancedClassInstanceContext
;
import
com.a.eye.skywalking.api.plugin.interceptor.InstanceMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.StaticMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.util.StringUtil
;
import
net.bytebuddy.description.method.MethodDescription
;
import
net.bytebuddy.dynamic.DynamicType
;
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassInstanceMethodsEnhancePluginDefine.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin.interceptor.enhance
;
import
com.a.eye.skywalking.api.plugin.interceptor.StaticMethodsInterceptPoint
;
import
com.a.eye.skywalking.plugin.interceptor.StaticMethodsInterceptPoint
;
/**
* Plugins, which only need enhance class static methods.
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/plugin/interceptor/enhance/ClassStaticMethodsEnhancePluginDefine.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin.interceptor.enhance
;
import
com.a.eye.skywalking.api.plugin.interceptor.ConstructorInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.InstanceMethodsInterceptPoint
;
import
com.a.eye.skywalking.plugin.interceptor.ConstructorInterceptPoint
;
/**
* Plugins, which only need enhance class static methods.
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/queue/TraceSegmentProcessQueue.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.queue
;
import
com.a.eye.skywalking.conf.Config
;
import
com.a.eye.skywalking.
api.
conf.Config
;
import
com.a.eye.skywalking.api.context.TracerContext
;
import
com.a.eye.skywalking.context.TracerContextListener
;
import
com.a.eye.skywalking.
api.
context.TracerContextListener
;
import
com.a.eye.skywalking.health.report.HealthCollector
;
import
com.a.eye.skywalking.health.report.HeathReading
;
import
com.a.eye.skywalking.trace.TraceSegment
;
...
...
@@ -36,7 +36,7 @@ public enum TraceSegmentProcessQueue implements TracerContextListener {
RingBuffer
<
TraceSegmentHolder
>
buffer
;
TraceSegmentProcessQueue
()
{
disruptor
=
new
Disruptor
<>(
TraceSegmentHolder
.
Factory
.
INSTANCE
,
Config
.
Disruptor
.
BUFFER_SIZE
,
DaemonThreadFactory
.
INSTANCE
);
disruptor
=
new
Disruptor
<
TraceSegmentHolder
>(
TraceSegmentHolder
.
Factory
.
INSTANCE
,
Config
.
Disruptor
.
BUFFER_SIZE
,
DaemonThreadFactory
.
INSTANCE
);
buffer
=
disruptor
.
getRingBuffer
();
}
...
...
skywalking-sniffer/skywalking-api/src/main/java/com/a/eye/skywalking/api/util/TraceIdGenerator.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.util
;
import
com.a.eye.skywalking.conf.Constants
;
import
com.a.eye.skywalking.
api.
conf.Constants
;
import
java.util.UUID
;
public
final
class
TraceIdGenerator
{
...
...
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestAroundInterceptor.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin
;
import
com.a.eye.skywalking.api.plugin.interceptor.EnhancedClassInstanceContext
;
import
com.a.eye.skywalking.plugin.interceptor.enhance.ConstructorInvokeContext
;
import
com.a.eye.skywalking.plugin.interceptor.enhance.InstanceMethodInvokeContext
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.InstanceMethodInvokeContext
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.MethodInterceptResult
;
...
...
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestInterceptorDefine.java
浏览文件 @
b69cd851
...
...
@@ -4,8 +4,6 @@ import com.a.eye.skywalking.api.plugin.interceptor.ConstructorInterceptPoint;
import
com.a.eye.skywalking.api.plugin.interceptor.InstanceMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.StaticMethodsInterceptPoint
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.ClassEnhancePluginDefine
;
import
com.a.eye.skywalking.plugin.interceptor.ConstructorInterceptPoint
;
import
com.a.eye.skywalking.plugin.interceptor.StaticMethodsInterceptPoint
;
import
net.bytebuddy.description.method.MethodDescription
;
import
net.bytebuddy.matcher.ElementMatcher
;
...
...
skywalking-sniffer/skywalking-api/src/test/java/com/a/eye/skywalking/api/plugin/TestStaticAroundInterceptor.java
浏览文件 @
b69cd851
package
com.a.eye.skywalking.api.plugin
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.MethodInterceptResult
;
import
com.a.eye.skywalking.plugin.interceptor.enhance.MethodInvokeContext
;
import
com.a.eye.skywalking.
api.
plugin.interceptor.enhance.MethodInvokeContext
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.StaticMethodInvokeContext
;
import
com.a.eye.skywalking.api.plugin.interceptor.enhance.StaticMethodsAroundInterceptor
;
...
...
skywalking-sniffer/skywalking-sniffer-mock/src/test/java/com/a/eye/skywalking/sniffer/mock/MockTracerContextListenerTestCase.java
0 → 100644
浏览文件 @
b69cd851
package
com.a.eye.skywalking.sniffer.mock
;
import
com.a.eye.skywalking.sniffer.mock.context.MockTracerContextListener
;
import
com.a.eye.skywalking.sniffer.mock.trace.TraceSegmentBuilderFactory
;
import
org.junit.Assert
;
import
org.junit.Test
;
/**
* Created by wusheng on 2017/2/21.
*/
public
class
MockTracerContextListenerTestCase
{
@Test
public
void
testAfterFinished
(){
MockTracerContextListener
listener
=
new
MockTracerContextListener
();
listener
.
afterFinished
(
TraceSegmentBuilderFactory
.
INSTANCE
.
singleTomcat200Trace
());
Assert
.
assertNotNull
(
listener
.
getFinished
(
0
));
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录