Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
梦中观雨
cat
提交
bba52f51
C
cat
项目概览
梦中观雨
/
cat
与 Fork 源项目一致
从无法访问的项目Fork
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
C
cat
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
bba52f51
编写于
4月 20, 2015
作者:
Y
youyong205
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
modify the analyzer
上级
cae69518
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
13 addition
and
10 deletion
+13
-10
cat-client/src/main/java/com/dianping/cat/message/internal/DefaultMessageManager.java
.../dianping/cat/message/internal/DefaultMessageManager.java
+1
-1
cat-client/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java
...ain/java/com/dianping/cat/message/io/TcpSocketSender.java
+4
-2
cat-consumer/src/main/java/com/dianping/cat/consumer/event/EventAnalyzer.java
...n/java/com/dianping/cat/consumer/event/EventAnalyzer.java
+8
-7
未找到文件。
cat-client/src/main/java/com/dianping/cat/message/internal/DefaultMessageManager.java
浏览文件 @
bba52f51
...
...
@@ -556,7 +556,7 @@ public class DefaultMessageManager extends ContainerHolder implements MessageMan
String
childId
=
nextMessageId
();
DefaultTransaction
source
=
(
DefaultTransaction
)
message
;
DefaultTransaction
target
=
new
DefaultTransaction
(
source
.
getType
(),
source
.
getName
(),
DefaultMessageManager
.
this
);
DefaultMessageManager
.
this
);
target
.
setTimestamp
(
source
.
getTimestamp
());
target
.
setDurationInMicros
(
source
.
getDurationInMicros
());
...
...
cat-client/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java
浏览文件 @
bba52f51
...
...
@@ -47,6 +47,8 @@ public class TcpSocketSender implements Task, MessageSender, LogEnabled {
private
MessageQueue
m_queue
=
new
DefaultMessageQueue
(
SIZE
);
private
BlockingQueue
<
MessageTree
>
m_atomicTrees
=
new
LinkedBlockingQueue
<
MessageTree
>(
SIZE
);
private
List
<
InetSocketAddress
>
m_serverAddresses
;
private
ChannelManager
m_manager
;
...
...
@@ -59,8 +61,6 @@ public class TcpSocketSender implements Task, MessageSender, LogEnabled {
private
AtomicInteger
m_attempts
=
new
AtomicInteger
();
private
BlockingQueue
<
MessageTree
>
m_atomicTrees
=
new
LinkedBlockingQueue
<
MessageTree
>(
SIZE
*
10
);
private
static
final
int
MAX_CHILD_NUMBER
=
200
;
private
boolean
checkWritable
(
ChannelFuture
future
)
{
...
...
@@ -127,6 +127,8 @@ public class TcpSocketSender implements Task, MessageSender, LogEnabled {
if
(
count
%
1000
==
0
||
count
==
1
)
{
m_logger
.
error
(
"Message queue is full in tcp socket sender! Count: "
+
count
);
}
tree
=
null
;
}
private
MessageTree
mergeTree
(
BlockingQueue
<
MessageTree
>
trees
)
{
...
...
cat-consumer/src/main/java/com/dianping/cat/consumer/event/EventAnalyzer.java
浏览文件 @
bba52f51
...
...
@@ -70,18 +70,18 @@ public class EventAnalyzer extends AbstractMessageAnalyzer<EventReport> implemen
if
(
m_serverConfigManager
.
validateDomain
(
domain
))
{
EventReport
report
=
m_reportManager
.
getHourlyReport
(
getStartTime
(),
domain
,
true
);
Message
message
=
tree
.
getMessage
();
String
ip
=
tree
.
getIpAddress
();
if
(
message
instanceof
Transaction
)
{
processTransaction
(
report
,
tree
,
(
Transaction
)
message
);
processTransaction
(
report
,
tree
,
(
Transaction
)
message
,
ip
);
}
else
if
(
message
instanceof
Event
)
{
processEvent
(
report
,
tree
,
(
Event
)
message
);
processEvent
(
report
,
tree
,
(
Event
)
message
,
ip
);
}
}
}
private
void
processEvent
(
EventReport
report
,
MessageTree
tree
,
Event
event
)
{
private
void
processEvent
(
EventReport
report
,
MessageTree
tree
,
Event
event
,
String
ip
)
{
int
count
=
1
;
String
ip
=
tree
.
getIpAddress
();
EventType
type
=
report
.
findOrCreateMachine
(
ip
).
findOrCreateType
(
event
.
getType
());
EventName
name
=
type
.
findOrCreateName
(
event
.
getName
());
String
messageId
=
tree
.
getMessageId
();
...
...
@@ -127,14 +127,14 @@ public class EventAnalyzer extends AbstractMessageAnalyzer<EventReport> implemen
}
}
private
void
processTransaction
(
EventReport
report
,
MessageTree
tree
,
Transaction
t
)
{
private
void
processTransaction
(
EventReport
report
,
MessageTree
tree
,
Transaction
t
,
String
ip
)
{
List
<
Message
>
children
=
t
.
getChildren
();
for
(
Message
child
:
children
)
{
if
(
child
instanceof
Transaction
)
{
processTransaction
(
report
,
tree
,
(
Transaction
)
child
);
processTransaction
(
report
,
tree
,
(
Transaction
)
child
,
ip
);
}
else
if
(
child
instanceof
Event
)
{
processEvent
(
report
,
tree
,
(
Event
)
child
);
processEvent
(
report
,
tree
,
(
Event
)
child
,
ip
);
}
}
}
...
...
@@ -142,4 +142,5 @@ public class EventAnalyzer extends AbstractMessageAnalyzer<EventReport> implemen
public
void
setReportManager
(
ReportManager
<
EventReport
>
reportManager
)
{
m_reportManager
=
reportManager
;
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录