Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
武汉红喜
whatsmars
提交
5d321688
W
whatsmars
项目概览
武汉红喜
/
whatsmars
通知
3
Star
0
Fork
1
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
W
whatsmars
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
5d321688
编写于
8月 05, 2019
作者:
武汉红喜
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
@Override
上级
1c281102
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
52 addition
and
0 deletion
+52
-0
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Appender.java
...a/org/hongxi/whatsmars/common/logging/inner/Appender.java
+8
-0
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Level.java
...java/org/hongxi/whatsmars/common/logging/inner/Level.java
+2
-0
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Logger.java
...ava/org/hongxi/whatsmars/common/logging/inner/Logger.java
+18
-0
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/LoggingBuilder.java
...hongxi/whatsmars/common/logging/inner/LoggingBuilder.java
+24
-0
未找到文件。
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Appender.java
浏览文件 @
5d321688
...
...
@@ -44,6 +44,7 @@ public abstract class Appender {
abstract
protected
void
append
(
LoggingEvent
event
);
@Override
public
void
finalize
()
{
try
{
super
.
finalize
();
...
...
@@ -125,6 +126,7 @@ public abstract class Appender {
protected
Vector
<
Appender
>
appenderList
;
@Override
public
void
addAppender
(
Appender
newAppender
)
{
if
(
newAppender
==
null
)
{
return
;
...
...
@@ -152,6 +154,7 @@ public abstract class Appender {
return
size
;
}
@Override
public
Enumeration
getAllAppenders
()
{
if
(
appenderList
==
null
)
{
return
null
;
...
...
@@ -160,6 +163,7 @@ public abstract class Appender {
}
}
@Override
public
Appender
getAppender
(
String
name
)
{
if
(
appenderList
==
null
||
name
==
null
)
{
return
null
;
...
...
@@ -176,6 +180,7 @@ public abstract class Appender {
return
null
;
}
@Override
public
boolean
isAttached
(
Appender
appender
)
{
if
(
appenderList
==
null
||
appender
==
null
)
{
return
false
;
...
...
@@ -192,6 +197,7 @@ public abstract class Appender {
return
false
;
}
@Override
public
void
removeAllAppenders
()
{
if
(
appenderList
!=
null
)
{
int
len
=
appenderList
.
size
();
...
...
@@ -204,6 +210,7 @@ public abstract class Appender {
}
}
@Override
public
void
removeAppender
(
Appender
appender
)
{
if
(
appender
==
null
||
appenderList
==
null
)
{
return
;
...
...
@@ -211,6 +218,7 @@ public abstract class Appender {
appenderList
.
removeElement
(
appender
);
}
@Override
public
void
removeAppender
(
String
name
)
{
if
(
name
==
null
||
appenderList
==
null
)
{
return
;
...
...
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Level.java
浏览文件 @
5d321688
...
...
@@ -124,6 +124,7 @@ public class Level implements Serializable {
}
@Override
public
boolean
equals
(
Object
o
)
{
if
(
o
instanceof
Level
)
{
Level
r
=
(
Level
)
o
;
...
...
@@ -145,6 +146,7 @@ public class Level implements Serializable {
return
level
>=
r
.
level
;
}
@Override
final
public
String
toString
()
{
return
levelStr
;
}
...
...
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/Logger.java
浏览文件 @
5d321688
...
...
@@ -58,6 +58,7 @@ public class Logger implements Appender.AppenderPipeline {
return
getRepository
().
getRootLogger
();
}
@Override
synchronized
public
void
addAppender
(
Appender
newAppender
)
{
if
(
appenderPipeline
==
null
)
{
appenderPipeline
=
new
Appender
.
AppenderPipelineImpl
();
...
...
@@ -141,6 +142,7 @@ public class Logger implements Appender.AppenderPipeline {
}
@Override
synchronized
public
Enumeration
getAllAppenders
()
{
if
(
appenderPipeline
==
null
)
{
return
null
;
...
...
@@ -149,6 +151,7 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
synchronized
public
Appender
getAppender
(
String
name
)
{
if
(
appenderPipeline
==
null
||
name
==
null
)
{
return
null
;
...
...
@@ -193,10 +196,12 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
public
boolean
isAttached
(
Appender
appender
)
{
return
appender
!=
null
&&
appenderPipeline
!=
null
&&
appenderPipeline
.
isAttached
(
appender
);
}
@Override
synchronized
public
void
removeAllAppenders
()
{
if
(
appenderPipeline
!=
null
)
{
appenderPipeline
.
removeAllAppenders
();
...
...
@@ -204,6 +209,7 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
synchronized
public
void
removeAppender
(
Appender
appender
)
{
if
(
appender
==
null
||
appenderPipeline
==
null
)
{
return
;
...
...
@@ -211,6 +217,7 @@ public class Logger implements Appender.AppenderPipeline {
appenderPipeline
.
removeAppender
(
appender
);
}
@Override
synchronized
public
void
removeAppender
(
String
name
)
{
if
(
name
==
null
||
appenderPipeline
==
null
)
{
return
;
...
...
@@ -289,6 +296,7 @@ public class Logger implements Appender.AppenderPipeline {
setLogLevel
(
Level
.
ALL
);
}
@Override
public
void
emitNoAppenderWarning
(
Logger
cat
)
{
if
(!
this
.
emittedNoAppenderWarning
)
{
SysLogger
.
warn
(
"No appenders could be found for logger ("
+
cat
.
getName
()
+
")."
);
...
...
@@ -297,6 +305,7 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
public
Logger
exists
(
String
name
)
{
Object
o
=
ht
.
get
(
new
CategoryKey
(
name
));
if
(
o
instanceof
Logger
)
{
...
...
@@ -306,6 +315,7 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
public
void
setLogLevel
(
Level
l
)
{
if
(
l
!=
null
)
{
logLevelInt
=
l
.
level
;
...
...
@@ -313,11 +323,13 @@ public class Logger implements Appender.AppenderPipeline {
}
}
@Override
public
Level
getLogLevel
()
{
return
logLevel
;
}
@Override
public
Logger
getLogger
(
String
name
)
{
CategoryKey
key
=
new
CategoryKey
(
name
);
Logger
logger
;
...
...
@@ -347,6 +359,7 @@ public class Logger implements Appender.AppenderPipeline {
return
new
Logger
(
name
);
}
@Override
public
Enumeration
getCurrentLoggers
()
{
Vector
<
Logger
>
loggers
=
new
Vector
<
Logger
>(
ht
.
size
());
...
...
@@ -362,15 +375,18 @@ public class Logger implements Appender.AppenderPipeline {
}
@Override
public
Logger
getRootLogger
()
{
return
root
;
}
@Override
public
boolean
isDisabled
(
int
level
)
{
return
logLevelInt
>
level
;
}
@Override
public
void
shutdown
()
{
Logger
root
=
getRootLogger
();
root
.
closeNestedAppenders
();
...
...
@@ -437,10 +453,12 @@ public class Logger implements Appender.AppenderPipeline {
hashCache
=
name
.
hashCode
();
}
@Override
final
public
int
hashCode
()
{
return
hashCache
;
}
@Override
final
public
boolean
equals
(
Object
o
)
{
if
(
this
==
o
)
{
return
true
;
...
...
whatsmars-rpc/whatsmars-logging/src/main/java/org/hongxi/whatsmars/common/logging/inner/LoggingBuilder.java
浏览文件 @
5d321688
...
...
@@ -148,12 +148,14 @@ public class LoggingBuilder {
dispatcher
.
start
();
}
@Override
public
void
addAppender
(
final
Appender
newAppender
)
{
synchronized
(
appenderPipeline
)
{
appenderPipeline
.
addAppender
(
newAppender
);
}
}
@Override
public
void
append
(
final
LoggingEvent
event
)
{
if
((
dispatcher
==
null
)
||
!
dispatcher
.
isAlive
()
||
(
bufferSize
<=
0
))
{
synchronized
(
appenderPipeline
)
{
...
...
@@ -208,6 +210,7 @@ public class LoggingBuilder {
}
}
@Override
public
void
close
()
{
synchronized
(
buffer
)
{
...
...
@@ -237,36 +240,42 @@ public class LoggingBuilder {
}
}
@Override
public
Enumeration
getAllAppenders
()
{
synchronized
(
appenderPipeline
)
{
return
appenderPipeline
.
getAllAppenders
();
}
}
@Override
public
Appender
getAppender
(
final
String
name
)
{
synchronized
(
appenderPipeline
)
{
return
appenderPipeline
.
getAppender
(
name
);
}
}
@Override
public
boolean
isAttached
(
final
Appender
appender
)
{
synchronized
(
appenderPipeline
)
{
return
appenderPipeline
.
isAttached
(
appender
);
}
}
@Override
public
void
removeAllAppenders
()
{
synchronized
(
appenderPipeline
)
{
appenderPipeline
.
removeAllAppenders
();
}
}
@Override
public
void
removeAppender
(
final
Appender
appender
)
{
synchronized
(
appenderPipeline
)
{
appenderPipeline
.
removeAppender
(
appender
);
}
}
@Override
public
void
removeAppender
(
final
String
name
)
{
synchronized
(
appenderPipeline
)
{
appenderPipeline
.
removeAppender
(
name
);
...
...
@@ -352,6 +361,7 @@ public class LoggingBuilder {
this
.
discardMap
=
discardMap
;
}
@Override
public
void
run
()
{
boolean
isActive
=
true
;
...
...
@@ -420,6 +430,7 @@ public class LoggingBuilder {
}
}
@Override
public
void
flush
()
{
try
{
out
.
flush
();
...
...
@@ -453,10 +464,12 @@ public class LoggingBuilder {
return
immediateFlush
;
}
@Override
public
void
activateOptions
()
{
}
@Override
public
void
append
(
LoggingEvent
event
)
{
if
(!
checkEntryConditions
())
{
return
;
...
...
@@ -483,6 +496,7 @@ public class LoggingBuilder {
return
true
;
}
@Override
public
synchronized
void
close
()
{
if
(
this
.
closed
)
{
return
;
...
...
@@ -614,6 +628,7 @@ public class LoggingBuilder {
return
fileName
;
}
@Override
public
void
activateOptions
()
{
if
(
fileName
!=
null
)
{
try
{
...
...
@@ -706,6 +721,7 @@ public class LoggingBuilder {
this
.
qw
=
new
QuietWriter
(
writer
,
this
);
}
@Override
protected
void
reset
()
{
closeFile
();
this
.
fileName
=
null
;
...
...
@@ -796,6 +812,7 @@ public class LoggingBuilder {
}
}
@Override
public
synchronized
void
setFile
(
String
fileName
,
boolean
append
,
boolean
bufferedIO
,
int
bufferSize
)
throws
IOException
{
super
.
setFile
(
fileName
,
append
,
this
.
bufferedIO
,
this
.
bufferSize
);
...
...
@@ -813,10 +830,12 @@ public class LoggingBuilder {
this
.
maxFileSize
=
maxFileSize
;
}
@Override
protected
void
setQWForFiles
(
Writer
writer
)
{
this
.
qw
=
new
CountingQuietWriter
(
writer
,
this
);
}
@Override
protected
void
subAppend
(
LoggingEvent
event
)
{
super
.
subAppend
(
event
);
if
(
fileName
!=
null
&&
qw
!=
null
)
{
...
...
@@ -835,6 +854,7 @@ public class LoggingBuilder {
super
(
writer
,
appender
);
}
@Override
public
void
write
(
String
string
)
{
try
{
out
.
write
(
string
);
...
...
@@ -894,6 +914,7 @@ public class LoggingBuilder {
return
datePattern
;
}
@Override
public
void
activateOptions
()
{
super
.
activateOptions
();
if
(
datePattern
!=
null
&&
fileName
!=
null
)
{
...
...
@@ -990,6 +1011,7 @@ public class LoggingBuilder {
scheduledFilename
=
datedFilename
;
}
@Override
protected
void
subAppend
(
LoggingEvent
event
)
{
long
n
=
System
.
currentTimeMillis
();
if
(
n
>=
nextCheck
)
{
...
...
@@ -1114,6 +1136,7 @@ public class LoggingBuilder {
SysLogger
.
warn
(
"Using previously set target, System.out by default."
);
}
@Override
public
void
activateOptions
()
{
if
(
target
.
equals
(
SYSTEM_ERR
))
{
setWriter
(
createWriter
(
System
.
err
));
...
...
@@ -1123,6 +1146,7 @@ public class LoggingBuilder {
super
.
activateOptions
();
}
@Override
protected
final
void
closeWriter
()
{
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录