--no commit message

--no commit message

storage-service/main.js

@@ -43,6 +43,9 @@ SS.prototype.amqp_start = function()
   this.amqp_server.set_remote_function(function(req,callback){
 
     self.db.request(req,function(err,res){
+      if(err){
+        console.log(err);
+      }
       //console.log(res);
       callback(err,res);
     });

test/jobs/example.json

@@ -3,7 +3,7 @@
   "active" : true,
   "trigger" : {
     "type": "cron",
-    "cmd": "*/10 * * * * *"
+    "cmd": "29,59 * * * * *"
   },
   "data_in" : {
     "type": "example"

test/playjob.js

@@ -77,7 +77,10 @@ function run_job(cfg)
     "job" : ctxJob
   }
 
-  track('***** JOB RUNNING *****\n[TRANSACTION ID]\t: ' + transaction.id + '\n',TRACKING>0);
+
+  track('***** JOB RUNNING *****',TRACKING>0);
+  track('[START TIME]\t\t: ' + (new Date(Date.now())).toUTCString(),TRACKING>0);
+  track('[TRANSACTION ID]\t: ' + transaction.id + '\n',TRACKING>0);
 
   async.waterfall([
     function(callback){
@@ -150,10 +153,11 @@ function run_job(cfg)
     }
   ],
   function(err,resp){
+    track('\n[FINISH TIME]\t\t: ' + (new Date(Date.now())).toUTCString(),TRACKING>0);
     if(err){
-      track('\n***** JOB UNSUCCESSFULLY DONE *****\n\n',TRACKING>0);
+      track('***** JOB UNSUCCESSFULLY DONE *****\n\n',TRACKING>0);
     }else{
-      track('\n***** JOB SUCCESSFULLY DONE *****\n\n',TRACKING>0);
+      track('***** JOB SUCCESSFULLY DONE *****\n\n',TRACKING>0);
     }
   });
 
@@ -243,6 +247,7 @@ function perform_do(context,request,cb)
 
 function track(str,is_print)
 {
+
   if(is_print){
     console.log(str);
   }

test/test.js

@@ -62,15 +62,20 @@ var database = Db.create({'repos_dir':'D:/testfile'});
 // database.request(req,function(err,res){
 //   console.log(res);
 // });
-var dateFormat = require('dateformat');
-function getCurrentTime()
-{
-    var curDate = new Date();
-    var unix = Math.floor(curDate/1000) * 1000;
-    var sqlDate = dateFormat(unix, "yyyy-mm-dd H:MM:ss");
-    //var unix = Math.round(curDate/1000) * 1000;
+var cluster = require('cluster');
+var http = require('http');
+var numCPUs = 4;
 
-    return {date:curDate,sql:sqlDate,ts:unix}
-}
+if (cluster.isMaster) {
+    for (var i = 0; i < numCPUs; i++) {
+        cluster.fork();
+    }
+} else {
+  console.log('process ' + process.pid + ' says hello!');
+
+    http.createServer(function(req, res) {
 
-console.log(getCurrentTime());
+        res.writeHead(200);
+        res.end('process ' + process.pid + ' says hello!');
+    }).listen(8000);
+}