Disable thread pool, extra check to not update exited jobs. Fixes #42

Author: Sjoerd Tieleman

lib/job.js

@@ -50,6 +50,7 @@ var JobUtils = {
           storage: config['database']['database'],
           host: config['database']['host'],
           port: config['database']['port'],
+          pool: false,
           logging: false
         });
       }
@@ -472,6 +473,8 @@ var Job = JobUtils.getDatabase().define('Job', {
       return obj;
     },
     progressHandler: function(data) {
+      if (this.hasExited) return;
+      
       this.lastMessage = data.toString().replace("\n",'');
 
       (isNaN(this.duration) || this.duration == 0) ? this.extractDuration(data.toString()) : this.extractProgress(data.toString());
@@ -480,7 +483,7 @@ var Job = JobUtils.getDatabase().define('Job', {
         // successfull save
       }).error(function(err) {
         // error while saving job
-      });
+      });        
     },
     extractDuration: function(text) {
       if (!this.durationBuffer) this.durationBuffer = "";
@@ -517,18 +520,21 @@ var Job = JobUtils.getDatabase().define('Job', {
       }
     },
     exitHandler: function(code, message) {
-      if (!this.hasExited) {
-        this.hasExited = true
-        this.status = (code == 0 ? 'success' : 'failed');
-        this.message = message;
+      this.hasExited = true
+      this.message = message;
 
-        if (this.status == 'success' && !isNaN(this.progress)) {
-          this.progress = 1.0;
-        }
-
-        this.save();
-        this.completeCallback();
+      if (code == 0) {
+        this.progress = 1.0;
       }
+
+      this.status = (code == 0 ? StatusCodes.SUCCESS : StatusCodes.FAILED);
+      this.save().success(function() {
+        // successfull save
+      }).error(function(err) {
+        // error while saving job
+        logger.log("Error while saving job: " + err)
+      });
+      this.completeCallback();
     }
   }
 });