archive-gh-me/log4js-node
1
0
Fork 0
mirror of https://github.com/log4js-node/log4js-node.git synced 2025-12-08 19:26:01 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #762 from florianreinhart/patch-1

Browse Source 
Fix duplicate log messages in TCP server (fixes #761)
This commit is contained in:
Gareth Jones 2018-07-21 07:50:06 +10:00 committed by GitHub
commit 2acfce3abc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
lib/appenders/tcp-server.js
View File

@ -5,22 +5,6 @@ const LoggingEvent = require('../LoggingEvent');
const DELIMITER = '__LOG4JS__';
let dataSoFar = '';
const send = (data) => {
if (data) {
dataSoFar += data;
if (dataSoFar.indexOf(DELIMITER)) {
const events = dataSoFar.split(DELIMITER);
if (!dataSoFar.endsWith(DELIMITER)) {
dataSoFar = events.pop();
}
events.filter(e => e.length).forEach((e) => {
clustering.send(LoggingEvent.deserialise(e));
});
}
}
};
exports.configure = (config) => {
debug('configure called with ', config);
// dummy shutdown if we're not master
@ -28,6 +12,24 @@ exports.configure = (config) => {
clustering.onlyOnMaster(() => {
const server = net.createServer((socket) => {
let dataSoFar = '';
const send = (data) => {
if (data) {
dataSoFar += data;
if (dataSoFar.indexOf(DELIMITER)) {
const events = dataSoFar.split(DELIMITER);
if (!dataSoFar.endsWith(DELIMITER)) {
dataSoFar = events.pop();
} else {
dataSoFar = '';
}
events.filter(e => e.length).forEach((e) => {
clustering.send(LoggingEvent.deserialise(e));
});
}
}
};
socket.setEncoding('utf8');
socket.on('data', send);
socket.on('end', send);