avoid calling end more than once

marcelog · Aug 26, 2014 · 28dc828 · 28dc828
1 parent e9745e4
commit 28dc828
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -2,7 +2,7 @@
   "author": "Marcelo Gornstein <marcelog@gmail.com>",
   "name": "minionpool",
   "description": "A simple task-consumer pool for nodejs",
-  "version": "0.0.9",
+  "version": "0.0.10",
   "homepage": "https://github.com/marcelog/minionpool",
   "keywords": [
     "worker", "pool", "task", "consumer"

diff --git a/src/base.js b/src/base.js
@@ -23,6 +23,7 @@ var events = require('events');
 
 function Base(options) {
   Base.super_.call(this);
+  this.endCalled = false;
   for(k in options) {
     this[k] = options[k];
   }
@@ -68,8 +69,11 @@ Base.prototype.start = function() {
 Base.prototype.end = function() {
   var self = this;
   this.endFunction(this.state, function() {
-    self.emit('ended');
-    self.debugMsg('Ended');
+    if(!self.endCalled) {
+      self.endCalled = true;
+      self.emit('ended');
+      self.debugMsg('Ended');
+    }
   });
 };
 exports.Base = Base;