|
345
|
1 package alice.topology.manager.keeparive;
|
|
|
2
|
|
|
3 import java.util.List;
|
|
|
4
|
|
|
5 import alice.codesegment.CodeSegment;
|
|
|
6 import alice.datasegment.CommandType;
|
|
|
7 import alice.datasegment.Receiver;
|
|
|
8
|
|
|
9 public class CreateTask extends CodeSegment{
|
|
419
|
10 private Receiver info = ids.create(CommandType.PEEK);
|
|
|
11
|
|
|
12 public CreateTask(){
|
|
|
13 info.setKey("_CLIST");
|
|
|
14 }
|
|
|
15
|
|
|
16 @Override
|
|
|
17 public void run(){
|
|
|
18 ods.put("_WAITINGLIST", new ListManager());
|
|
|
19 @SuppressWarnings("unchecked")
|
|
|
20 List<String> list = info.asClass(List.class);
|
|
|
21
|
|
|
22 new CheckExistTask();
|
|
|
23 TaskExecuter.getInstance().setKey();
|
|
|
24 for (String manager : list){
|
|
|
25 int i = 5;
|
|
|
26 TaskInfo task = new TaskInfo(TaskType.PING);
|
|
|
27 task.setInfo(manager, "_FORM_"+manager, i * 1000);
|
|
|
28 ods.put("_TASKINFO", task);
|
|
|
29 i +=5;
|
|
|
30 }
|
|
|
31
|
|
|
32 }
|
|
345
|
33
|
|
|
34 }
|
