32 queue workers for dealing with shares. Primarily non-blocking. Lets see if this plays better.

lib/pool.js

@@ -103,7 +103,7 @@ function messageHandler(message) {
             break;
         case 'sendRemote':
             if (cluster.isMaster) {
-                global.database.sendQueue.push(Buffer.from(message.data, 'hex'));
+                global.database.sendQueue.push({body: Buffer.from(message.body, 'hex')});
             }
             break;
         case 'trustedShare':

lib/remote_comms.js

@@ -22,7 +22,7 @@ function Database() {
             function () {
                 callback();
             });
-    }, 128);
+    }, require('os').cpus().length*32);
 
     this.storeShare = function (blockId, shareData) {
         let wsData = global.protos.WSData.encode({
@@ -55,7 +55,7 @@ function Database() {
     };
 
     setInterval(function(queue_obj){
-        if (thread_id === '(Master) '){
+        if (global.database.thread_id === '(Master) '){
             console.log(global.database.thread_id + "Queue debug state: " + queue_obj.length() + " items in the queue " + queue_obj.running() + " items being processed");
         }
     }, 5000, this.sendQueue);