package alice.topology.manager.keeparive;

import java.util.LinkedList;
import alice.codesegment.CodeSegment;

public class PingScheduler extends CodeSegment{
	private PingSchedList plist = new PingSchedList(); 
	private long INTERVAL = 60 * 1000;

	private boolean interruptFlag = false;

	private long time = 0;
	public TaskInfo nowTask;
	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();
				time = System.currentTimeMillis();
				if (nowTask.getSleepTime()!=0)
					this.wait(nowTask.getSleepTime());
				if (interruptFlag){				
					interruptFlag = false;				
				} else {
					ods.put("_SENDPING", nowTask);
					nowTask.getSleepTime();					
				}
			}
		} catch (InterruptedException e) {
		}
	}
}