Mercurial > hg > Members > tatsuki > Alice
view src/alice/topology/manager/keeparive/PingScheduler.java @ 308:a8255a831ade
implement ping api
author | sugi |
---|---|
date | Tue, 19 Nov 2013 17:39:44 +0900 |
parents | 72739519cc39 |
children | 797267843126 |
line wrap: on
line source
package alice.topology.manager.keeparive; import java.util.LinkedList; import alice.codesegment.CodeSegment; public class PingScheduler extends CodeSegment{ public PingSchedList plist = new PingSchedList(); private TaskInfo nowTask; private boolean interruptFlag = false; private long INTERVAL = 60 * 1000; private long time = 0; private long postponeTime = 0; public synchronized void postpone(String name){ long elapsedTime = System.currentTimeMillis() - time; postponeTime = nowTask.getSleepTime() - elapsedTime; LinkedList<TaskInfo> list = plist.getTaskList(); if (name.equals(nowTask.getManagerKey())){ TaskInfo nextTask = list.get(0); nextTask.setSleepTime(postponeTime + nextTask.getSleepTime()); nowTask.setSleepTime(INTERVAL); plist.addTask(nowTask); } else { int cnt = 0; nowTask.setSleepTime(postponeTime); list.add(cnt, nowTask); for (TaskInfo info : list){ if (name.equals(info.getManagerKey())){ if (info != list.getLast()){ TaskInfo nextInfo = list.get(cnt+1); nextInfo.setSleepTime(nextInfo.getSleepTime() + info.getSleepTime()); } list.remove(info); info.setSleepTime(INTERVAL); plist.addTask(info); break; } cnt++; } } interruptFlag = true; notify(); } @Override public synchronized void run() { LinkedList<TaskInfo> list = plist.getTaskList(); try { while(true){ nowTask = list.poll(); System.out.print("TaskName "+nowTask.getManagerKey()); System.out.println(" sleepTime "+nowTask.getSleepTime()); time = System.currentTimeMillis(); if (nowTask.getSleepTime()!=0) this.wait(nowTask.getSleepTime()); if (interruptFlag){ interruptFlag = false; } else { ods.put("_SENDPING", nowTask.getManagerKey()); } } } catch (InterruptedException e) { } } }