Mercurial > hg > Database > Alice
diff src/alice/topology/manager/keeparive/CreateSchedule.java @ 314:f1f0638861ab
ping responce receivable
author | sugi |
---|---|
date | Fri, 06 Dec 2013 11:42:51 +0900 |
parents | 6e0a3c680b82 |
children | 9e84deb9b1e0 |
line wrap: on
line diff
--- a/src/alice/topology/manager/keeparive/CreateSchedule.java Tue Dec 03 21:34:42 2013 +0900 +++ b/src/alice/topology/manager/keeparive/CreateSchedule.java Fri Dec 06 11:42:51 2013 +0900 @@ -20,10 +20,9 @@ ListManager manager = info1.asClass(ListManager.class); TaskInfo newTask = info2.asClass(TaskInfo.class); SendPing ps = SendPing.getInstance(); - TaskInfo nowTask = ps.getNowTask(); LinkedList<TaskInfo> list = manager.getTaskList(); - if (nowTask.getManagerKey().equals(newTask.getManagerKey())){ - long postponeTime = nowTask.getSleepTime() - (System.currentTimeMillis() - ps.getTime()); + if (ps.getNowTask()!=null&&ps.getNowTask().getManagerKey().equals(newTask.getManagerKey())){ + long postponeTime = ps.getNowTask().getSleepTime() - (System.currentTimeMillis() - ps.getTime()); TaskInfo nextTask = list.getFirst(); nextTask.setSleepTime(postponeTime + nextTask.getSleepTime()); manager.addTask(newTask); @@ -36,7 +35,7 @@ } manager.addTask(newTask); } - ods.update("_SCHEDLIST", manager); + ods.update("_WAITINGLIST", manager); new CheckExistTask(); } }