Mercurial > hg > Database > Alice
comparison src/main/java/alice/topology/manager/keeparive/CreateTask.java @ 345:8f71c3e6f11d
Change directory structure Maven standard
author | sugi |
---|---|
date | Wed, 16 Apr 2014 18:26:07 +0900 (2014-04-16) |
parents | |
children | aefbe41fcf12 |
comparison
equal
deleted
inserted
replaced
344:9f97ec18f8c5 | 345:8f71c3e6f11d |
---|---|
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{ | |
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 } | |
33 | |
34 } |