|
323
|
1 package alice.topology.manager.keeparive;
|
|
|
2
|
|
|
3 import alice.codesegment.CodeSegment;
|
|
|
4 import alice.datasegment.CommandType;
|
|
|
5 import alice.datasegment.Receiver;
|
|
|
6
|
|
|
7 public class RemoveTask extends CodeSegment {
|
|
|
8 private Receiver info1 = ids.create(CommandType.TAKE); // list
|
|
|
9 private Receiver info2 = ids.create(CommandType.TAKE); // remove task
|
|
|
10
|
|
|
11 public RemoveTask(){
|
|
|
12 info1.setKey("_WAITINGLIST");
|
|
|
13 info2.setKey("_REMOVETASK");
|
|
|
14 }
|
|
|
15
|
|
|
16 @Override
|
|
|
17 public void run() {
|
|
|
18 ListManager list = info1.asClass(ListManager.class); // explicit cast
|
|
|
19 TaskInfo task = info2.asClass(TaskInfo.class);
|
|
|
20 TaskExecuter exec = TaskExecuter.getInstance();
|
|
|
21 if (exec.compareNowTask(task)){
|
|
|
22 // case: remove task is state countdown.
|
|
|
23 exec.skip();
|
|
|
24 } else {
|
|
330
|
25 boolean removeFlag = false;
|
|
323
|
26 // case: remove task is still in the waiting queue.
|
|
|
27 for (TaskInfo t: list.getTaskList()){
|
|
|
28 if (t.getType().equals(task.getType())){
|
|
331
|
29 list.getTaskList().remove(t); // this operation should be executed by list Manager.
|
|
330
|
30 removeFlag = true;
|
|
323
|
31 break;
|
|
|
32 }
|
|
|
33 }
|
|
330
|
34 if (!removeFlag){
|
|
|
35 ods.put("_REMOVETASK", task);
|
|
|
36 }
|
|
323
|
37 }
|
|
|
38 ods.update("_WAITINGLIST", list);
|
|
|
39 }
|
|
|
40 }
|
