Mercurial > hg > Database > Alice
changeset 311:4b38039e4454
remove SendPing and add CheckExistTask
| author | sugi |
|---|---|
| date | Tue, 26 Nov 2013 17:40:00 +0900 |
| parents | f1cd920ea913 |
| children | 6e0a3c680b82 |
| files | src/alice/topology/manager/keeparive/CheckExistTask.java src/alice/topology/manager/keeparive/CreateSchedule.java src/alice/topology/manager/keeparive/SendPing.java |
| diffstat | 3 files changed, 20 insertions(+), 20 deletions(-) [+] |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/alice/topology/manager/keeparive/CheckExistTask.java Tue Nov 26 17:40:00 2013 +0900 @@ -0,0 +1,19 @@ +package alice.topology.manager.keeparive; + +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class CheckExistTask extends CodeSegment{ + private Receiver info = ids.create(CommandType.PEEK); // TaskInfo + + public CheckExistTask(){ + info.setKey("_TASKINFO"); + } + + @Override + public void run() { + new CreateSchedule(); + } + +}
--- a/src/alice/topology/manager/keeparive/CreateSchedule.java Tue Nov 26 16:46:26 2013 +0900 +++ b/src/alice/topology/manager/keeparive/CreateSchedule.java Tue Nov 26 17:40:00 2013 +0900 @@ -37,6 +37,6 @@ manager.addTask(newTask); } ods.update("_SCHEDLIST", manager); - new CreateSchedule(); + new CheckExistTask(); } }
--- a/src/alice/topology/manager/keeparive/SendPing.java Tue Nov 26 16:46:26 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,19 +0,0 @@ -package alice.topology.manager.keeparive; - -import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; -import alice.datasegment.Receiver; - -public class SendPing extends CodeSegment{ - private Receiver taskInfo = ids.create(CommandType.TAKE); - - public SendPing(){ - taskInfo.setKey("_SENDPING"); - } - - @Override - public synchronized void run(){ - - - } -}