Prevent EventEmitter memory leak

SirEOF · May 23, 2014 · a8f9cf6 · a8f9cf6
1 parent e1980db
commit a8f9cf6
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/lib/pool.js b/lib/pool.js
@@ -584,6 +584,7 @@ function startPoolServerTcp(callback){
             }
 
             var sendReply = function(error, result){
+                if(!socket.writable) return;
                 var sendData = JSON.stringify({
                     id: jsonData.id,
                     jsonrpc: "2.0",
@@ -593,10 +594,6 @@ function startPoolServerTcp(callback){
                 socket.write(sendData);
             };
 
-            socket.on('close', function() {
-                sendReply = function(){};
-            });
-
             handleMinerMethod(jsonData.method, jsonData.params, socket.remoteAddress, portData, sendReply, pushMessage);
         };
 
@@ -607,6 +604,7 @@ function startPoolServerTcp(callback){
             var dataBuffer = '';
 
             var pushMessage = function(method, params){
+                if(!socket.writable) return;
                 var sendData = JSON.stringify({
                     jsonrpc: "2.0",
                     method: method,