Skip to content

Commit

Permalink
feat(server): connections stats
Browse files Browse the repository at this point in the history
  • Loading branch information
popstas committed Dec 26, 2020
1 parent 696986d commit 7845bd8
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion src/server.js
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ db.set('stats.reboots', reboots).write();
const maxConcurrency = 2;
let scansTotal = 0;
let pagesTotal = 0;
let connections = 0;
let q;
const startedTime = Date.now();
initQueue();
Expand Down Expand Up @@ -110,6 +111,7 @@ function serverState() {
running: q.length < maxConcurrency ? q.length : maxConcurrency,
available: Math.max(0, maxConcurrency - q.length),
pending: Math.max(0, q.length - maxConcurrency),
connections: connections,
scansTotal: scansTotal,
pagesTotal: pagesTotal,
scansTotalAll: stats.scansTotal || 0,
Expand All @@ -125,6 +127,7 @@ function sendStats(socket) {

function onSocketConnection(socket) {
log("user connected to server", socket, true);
connections++;

submitQueueEvents(socket);

Expand Down Expand Up @@ -152,6 +155,7 @@ function onSocketConnection(socket) {

socket.on("disconnect", () => {
clearInterval(interval);
connections--;
console.log("user disconnected");
});
}
Expand Down Expand Up @@ -186,7 +190,7 @@ function log(msg, socket, outTime=false) {
function socketSend(socket, event, msg) {
if (socket) {
// console.log('socket: ' + event, msg);
console.log(event + socket.uid + ": ", msg);
// console.log(event + socket.uid + ": ", msg);
socket.emit(event + (socket.uid || ""), msg);
}
}
Expand Down

0 comments on commit 7845bd8

Please sign in to comment.