@@ -40,15 +40,15 @@ public class SpanEventDiskReporter extends AbstractDiskReporter {
40
40
41
41
private final AtomicBoolean isEventFileInited = new AtomicBoolean (false );
42
42
43
- private final String eventLogType ;
43
+ private final String eventLogType ;
44
44
45
- private final String eventRollingPolicy ;
45
+ private final String eventRollingPolicy ;
46
46
47
- private String eventLogReserveConfig ;
47
+ private String eventLogReserveConfig ;
48
48
49
- private final SpanEncoder contextEncoder ;
49
+ private final SpanEncoder contextEncoder ;
50
50
51
- private String logNameKey ;
51
+ private String logNameKey ;
52
52
53
53
/**
54
54
* Instantiates a new Span event disk reporter.
@@ -102,7 +102,7 @@ public void digestReport(SofaTracerSpan span) {
102
102
this .initDigestFile ();
103
103
}
104
104
AsyncCommonDigestAppenderManager asyncDigestManager = SofaTracerDigestReporterAsyncManager
105
- .getSofaTracerDigestReporterAsyncManager ();
105
+ .getSofaTracerDigestReporterAsyncManager ();
106
106
if (asyncDigestManager .isAppenderAndEncoderExist (this .eventLogType )) {
107
107
//Print only when appender and encoder are present
108
108
asyncDigestManager .append (span );
@@ -162,24 +162,24 @@ private synchronized void initDigestFile() {
162
162
}
163
163
if (StringUtils .isNotBlank (logNameKey )) {
164
164
String currentDigestLogReserveConfig = SofaTracerConfiguration
165
- .getLogReserveConfig (logNameKey );
165
+ .getLogReserveConfig (logNameKey );
166
166
if (!currentDigestLogReserveConfig .equals (eventLogReserveConfig )) {
167
167
SelfLog .info ("the lognamekey : " + logNameKey
168
- + " take effect. the old logreserveconfig is " + eventLogReserveConfig
169
- + " and " + "the new logreverseconfig is "
170
- + currentDigestLogReserveConfig );
168
+ + " take effect. the old logreserveconfig is " + eventLogReserveConfig
169
+ + " and " + "the new logreverseconfig is "
170
+ + currentDigestLogReserveConfig );
171
171
eventLogReserveConfig = currentDigestLogReserveConfig ;
172
172
}
173
173
}
174
174
TraceAppender digestTraceAppender = LoadTestAwareAppender
175
- .createLoadTestAwareTimedRollingFileAppender (this .eventLogType ,
176
- this .eventRollingPolicy , this .eventLogReserveConfig );
175
+ .createLoadTestAwareTimedRollingFileAppender (this .eventLogType ,
176
+ this .eventRollingPolicy , this .eventLogReserveConfig );
177
177
//registry digest
178
178
AsyncCommonDigestAppenderManager asyncDigestManager = SofaTracerDigestReporterAsyncManager
179
- .getSofaTracerDigestReporterAsyncManager ();
179
+ .getSofaTracerDigestReporterAsyncManager ();
180
180
if (!asyncDigestManager .isAppenderAndEncoderExist (this .eventLogType )) {
181
181
asyncDigestManager .addAppender (this .eventLogType , digestTraceAppender ,
182
- this .contextEncoder );
182
+ this .contextEncoder );
183
183
}
184
184
//Already exists or created for the first time
185
185
this .isEventFileInited .set (true );
0 commit comments