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