depau/HackMD
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Update to prevent duplicate socket push in queue in order to lower down server loading

Browse source
This commit is contained in:
Wu Cheng-Han 2016-10-10 20:25:48 +08:00
parent d23ced1fba
commit 1cae0c5b7f
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lib/realtime.js
View file

@ -327,6 +327,15 @@ function emitRefresh(socket) {
socket.emit('refresh', out); socket.emit('refresh', out);
} }
function isDuplicatedInSocketQueue(queue, socket) {
for (var i = 0; i < queue.length; i++) {
if (queue[i] && queue[i].id == socket.id) {
return true;
}
}
return false;
}
function clearSocketQueue(queue, socket) { function clearSocketQueue(queue, socket) {
for (var i = 0; i < queue.length; i++) { for (var i = 0; i < queue.length; i++) {
if (!queue[i] || queue[i].id == socket.id) { if (!queue[i] || queue[i].id == socket.id) {
@ -655,6 +664,8 @@ function connection(socket) {
return failConnection(404, 'note id not found', socket); return failConnection(404, 'note id not found', socket);
} }
if (isDuplicatedInSocketQueue(socket, connectionSocketQueue)) return;
// store noteId in this socket session // store noteId in this socket session
socket.noteId = noteId; socket.noteId = noteId;
@ -830,6 +841,7 @@ function connection(socket) {
//when a new client disconnect //when a new client disconnect
socket.on('disconnect', function () { socket.on('disconnect', function () {
if (isDuplicatedInSocketQueue(socket, disconnectSocketQueue)) return;
disconnectSocketQueue.push(socket); disconnectSocketQueue.push(socket);
disconnect(socket); disconnect(socket);
}); });