Mercurial > hg > Database > Alice
diff src/main/java/alice/topology/manager/keeparive/RemoveTask.java @ 419:aefbe41fcf12 dispose
change tab to space
author | sugi |
---|---|
date | Tue, 15 Jul 2014 16:00:22 +0900 |
parents | 8f71c3e6f11d |
children | e5d2141af6c2 |
line wrap: on
line diff
--- a/src/main/java/alice/topology/manager/keeparive/RemoveTask.java Tue Jul 15 06:15:53 2014 +0900 +++ b/src/main/java/alice/topology/manager/keeparive/RemoveTask.java Tue Jul 15 16:00:22 2014 +0900 @@ -5,29 +5,29 @@ import alice.datasegment.Receiver; public class RemoveTask extends CodeSegment { - private Receiver info1 = ids.create(CommandType.TAKE); // list - private Receiver info2 = ids.create(CommandType.TAKE); // remove task + private Receiver info1 = ids.create(CommandType.TAKE); // list + private Receiver info2 = ids.create(CommandType.TAKE); // remove task - public RemoveTask(){ - info1.setKey("_WAITINGLIST"); - info2.setKey("_REMOVETASK"); - } + public RemoveTask(){ + info1.setKey("_WAITINGLIST"); + info2.setKey("_REMOVETASK"); + } - @Override - public void run() { - ListManager list = info1.asClass(ListManager.class); // explicit cast - TaskInfo task = info2.asClass(TaskInfo.class); - TaskExecuter exec = TaskExecuter.getInstance(); - if (exec.compareNowTask(task)){ - // case: remove task is state countdown. - exec.skip(); - } else { - // case: remove task is still in the waiting queue. - boolean removeFlag = list.deleteTask(task); - if (!removeFlag){ - ods.put("_REMOVETASK", task); - } - } - ods.update("_WAITINGLIST", list); - } + @Override + public void run() { + ListManager list = info1.asClass(ListManager.class); // explicit cast + TaskInfo task = info2.asClass(TaskInfo.class); + TaskExecuter exec = TaskExecuter.getInstance(); + if (exec.compareNowTask(task)){ + // case: remove task is state countdown. + exec.skip(); + } else { + // case: remove task is still in the waiting queue. + boolean removeFlag = list.deleteTask(task); + if (!removeFlag){ + ods.put("_REMOVETASK", task); + } + } + ods.update("_WAITINGLIST", list); + } }