|
From: Peter P. <pr...@us...> - 2006-12-29 10:21:38
|
Update of /cvsroot/pyxida/Pyxida/src/edu/harvard/syrah/pyxida/nc In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv21568/src/edu/harvard/syrah/pyxida/nc Modified Files: NCManager.java Log Message: Fixed prp todos Index: NCManager.java =================================================================== RCS file: /cvsroot/pyxida/Pyxida/src/edu/harvard/syrah/pyxida/nc/NCManager.java,v retrieving revision 1.27 retrieving revision 1.28 diff -C2 -d -r1.27 -r1.28 *** NCManager.java 20 Dec 2006 17:47:06 -0000 1.27 --- NCManager.java 29 Dec 2006 10:21:35 -0000 1.28 *************** *** 259,264 **** cbDistance.call(result, new Double(0), error); ! // PRP TODO should be be barrier.remove() ? ! barrier.join(); } } --- 259,264 ---- cbDistance.call(result, new Double(0), error); ! // Remove the barrier to clear up state ! barrier.remove(); } } *************** *** 275,279 **** log.debug ("estimateRTT a="+nodeA+" b="+nodeB); ! // TODO PRP true or false? final Barrier barrier = new Barrier(true); final List<Coordinate> coordList = new ArrayList<Coordinate>(); --- 275,280 ---- log.debug ("estimateRTT a="+nodeA+" b="+nodeB); ! // Creates a new barrier, which is triggered by default, i.e. if there's no call ! // to fork, then the barrier CB will be executed immediately. final Barrier barrier = new Barrier(true); final List<Coordinate> coordList = new ArrayList<Coordinate>(); *************** *** 282,287 **** ! // TODO PRP this fn isn't found ! EventLoop.get().registerEventCB(barrier, new CB0() { protected void cb(CBResult result) { // after barrier is triggered --- 283,287 ---- ! EventLoop.get().registerTimerCB(barrier, new CB0() { protected void cb(CBResult result) { // after barrier is triggered |