Mercurial > hg > Database > Alice

comparison src/alice/topology/manager/keeparive/RespondPing.java @ 326:c382d6fe1ec4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
need reamainingTime add next task
author sugi
date Fri, 24 Jan 2014 02:18:09 +0900
parents 806cc010a5bd
children 35b4e24e3e02
comparison
equal deleted inserted replaced
325:54d0b947079a 326:c382d6fe1ec4
20 System.out.println(" Recieved time "+d.time); 20 System.out.println(" Recieved time "+d.time);
21 if (pingedTime - d.time > 60 * 1000){ 21 if (pingedTime - d.time > 60 * 1000){
22 // need check, this connection is alive. may be close 22 // need check, this connection is alive. may be close
23 DataSegment.get(d.from).close(); 23 DataSegment.get(d.from).close();
24 } else { 24 } else {
25 // if nowTask is close d.from's socket cancel. 25 // if nowTask close d.from's socket cancel.
26 // if not remove close task in the Queue. 26 // if not remove close task in the Queue.
27 TaskExecuter exec = TaskExecuter.getInstance(); 27 TaskExecuter exec = TaskExecuter.getInstance();
28 TaskInfo task = new TaskInfo(TaskType.CLOSE); 28 TaskInfo task = new TaskInfo(TaskType.CLOSE);
29 task.setInfo(d.from, null, 0); 29 task.setInfo(d.from, null, 0);
30 if (exec.compareNowTask(task)){ 30 if (exec.compareNowTask(task)){