echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

* Logging: Track duplicates across flush interval (ticket #1110)

Browse Source
This commit is contained in:
zzz
2013-11-07 12:23:37 +00:00
parent f1e77499e2
commit ca866d48e6
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
core/java/src/net/i2p/util/LogWriter.java
View File

@ -37,6 +37,7 @@ class LogWriter implements Runnable {
private volatile boolean _write;
private static final int MAX_DISKFULL_MESSAGES = 8;
private int _diskFullMessageCount;
private LogRecord _last;
public LogWriter(LogManager manager) {
_manager = manager;
@ -73,25 +74,26 @@ class LogWriter implements Runnable {
Queue<LogRecord> records = _manager.getQueue();
if (records == null) return;
if (!records.isEmpty()) {
LogRecord last = null;
if (_last != null && _last.getDate() < _manager.getContext().clock().now() - 30*60*1000)
_last = null;
LogRecord rec;
int dupCount = 0;
while ((rec = records.poll()) != null) {
if (_manager.shouldDropDuplicates() && rec.equals(last)) {
if (_manager.shouldDropDuplicates() && rec.equals(_last)) {
dupCount++;
} else {
if (dupCount > 0) {
writeRecord(dupMessage(dupCount, last, false));
_manager.getBuffer().add(dupMessage(dupCount, last, true));
writeRecord(dupMessage(dupCount, _last, false));
_manager.getBuffer().add(dupMessage(dupCount, _last, true));
dupCount = 0;
}
writeRecord(rec);
}
last = rec;
_last = rec;
}
if (dupCount > 0) {
writeRecord(dupMessage(dupCount, last, false));
_manager.getBuffer().add(dupMessage(dupCount, last, true));
writeRecord(dupMessage(dupCount, _last, false));
_manager.getBuffer().add(dupMessage(dupCount, _last, true));
}
try {
if (_currentOut != null)