Commit cc96c195 authored by project's avatar project

--no commit message

--no commit message
parent cfecf12f
...@@ -41,7 +41,6 @@ SchedulerService.prototype.reload = function () ...@@ -41,7 +41,6 @@ SchedulerService.prototype.reload = function ()
self.clean(); self.clean();
self.crons.update(function(err){ self.crons.update(function(err){
var cl = self.crons.list; var cl = self.crons.list;
console.log(cl);
for(var i=0;i<cl.length;i++) for(var i=0;i<cl.length;i++)
{ {
var c = cl[i]; var c = cl[i];
......
...@@ -7,7 +7,8 @@ module.exports.create = function(cfg) ...@@ -7,7 +7,8 @@ module.exports.create = function(cfg)
return new CronList(cfg); return new CronList(cfg);
} }
module.exports.mkCron = function(name,cmd,jobid,opt) module.exports.mkCron = mkCron;
function mkCron(name,cmd,jobid,opt)
{ {
var a = { var a = {
'name' : name, 'name' : name,
...@@ -63,7 +64,8 @@ CronList.prototype.update = function(cb) ...@@ -63,7 +64,8 @@ CronList.prototype.update = function(cb)
// }); // });
self.list = []; self.list = [];
self.mem.hgetall(KEYS,function (err,res){ self.mem.hgetall(KEYS,function (err,res){
if(!err && Array.isArray(res)){ if(!err && res){
var ks = Object.keys(res); var ks = Object.keys(res);
for(var i=0;i<ks.length;i++) for(var i=0;i<ks.length;i++)
{ {
...@@ -71,7 +73,7 @@ CronList.prototype.update = function(cb) ...@@ -71,7 +73,7 @@ CronList.prototype.update = function(cb)
var trigger = JSON.parse(res[k]); var trigger = JSON.parse(res[k]);
if(trigger.type == 'cron') if(trigger.type == 'cron')
{ {
var cl = self.mkCron(trigger.id,trigger.cmd,trigger.job_id); var cl = mkCron(trigger.id,trigger.cmd,trigger.job_id);
self.list.push(cl); self.list.push(cl);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment