diff --git a/lib/remoteShare.js b/lib/remoteShare.js index 60b5fff..0c564ae 100644 --- a/lib/remoteShare.js +++ b/lib/remoteShare.js @@ -71,16 +71,18 @@ app.post('/leafApi', function (req, res) { } }); +function storeShares(){ + if (Object.keys(shareData).length > 0){ + global.database.storeBulkShares(shareData); + shareData = []; + } + setTimeout(storeShares, 1000); +} + if (cluster.isMaster) { let numWorkers = require('os').cpus().length; console.log('Master cluster setting up ' + numWorkers + ' workers...'); - - setInterval(function(){ - if (Object.keys(shareData).length > 0){ - global.database.storeBulkShares(shareData); - shareData = []; - } - }, 1000); + storeShares(); for (let i = 0; i < numWorkers; i++) { let worker = cluster.fork();