# HG changeset patch # User kazz # Date 1282914058 -32400 # Node ID 27874f473d4802fda820c1ca76d01fa76c1be20c # Parent 29ed7feebf2a692a1dc6e1fd3f522c2602520b0a modify update() diff -r 29ed7feebf2a -r 27874f473d48 src/fdl/TupleSpace.java --- a/src/fdl/TupleSpace.java Fri Aug 20 21:22:51 2010 +0900 +++ b/src/fdl/TupleSpace.java Fri Aug 27 22:00:58 2010 +0900 @@ -133,9 +133,9 @@ tuple = new Tuple(); tuple.setCommand(PSX.PSX_ANSWER, id, command.getInt(PSX.LINDA_SEQ_OFFSET), ByteBuffer.allocate(0)); } + PSX.send(key, tuple.getCommand(), tuple.getData()); tuple_space[id] = null; Out1(key, command, data, id); - PSX.send(key, tuple.getCommand(), tuple.getData()); } protected void Wait_Rd(SelectionKey key, ByteBuffer command, int mode) { diff -r 29ed7feebf2a -r 27874f473d48 src/fdl/test/api/inout/InOutMetaEngine.java --- a/src/fdl/test/api/inout/InOutMetaEngine.java Fri Aug 20 21:22:51 2010 +0900 +++ b/src/fdl/test/api/inout/InOutMetaEngine.java Fri Aug 27 22:00:58 2010 +0900 @@ -6,6 +6,7 @@ import fdl.MetaEngine; import fdl.MetaLinda; +import fdl.PSX; import fdl.PSXLinda; import fdl.PSXReply; @@ -39,7 +40,13 @@ if (count >= maxCount) { endTime = new Date(); Long resultTime = new Long(endTime.getTime() - startTime.getTime()); - System.out.println(resultTime); + linda.out(PSX.META_STOP, ByteBuffer.wrap("".getBytes())); + try { + linda.sync(); + } catch (IOException e) { + e.printStackTrace(); + } + System.out.println(maxCount + " " + resultTime); System.exit(0); } if (reply == null) { diff -r 29ed7feebf2a -r 27874f473d48 src/fdl/test/api/update/UpdateMetaEngine.java --- a/src/fdl/test/api/update/UpdateMetaEngine.java Fri Aug 20 21:22:51 2010 +0900 +++ b/src/fdl/test/api/update/UpdateMetaEngine.java Fri Aug 27 22:00:58 2010 +0900 @@ -6,6 +6,7 @@ import fdl.MetaEngine; import fdl.MetaLinda; +import fdl.PSX; import fdl.PSXLinda; import fdl.PSXReply; @@ -38,8 +39,14 @@ public void mainLoop(MetaLinda ml) { if (count >= maxCount) { endTime = new Date(); - Long resultTime = new Long(endTime.getTime() - startTime.getTime()); - System.out.println(resultTime); + Long resultTime = new Long(endTime.getTime() - startTime.getTime()); + linda.out(PSX.META_STOP, ByteBuffer.wrap("".getBytes())); + try { + linda.sync(); + } catch (IOException e) { + e.printStackTrace(); + } + System.out.println(maxCount + " " + resultTime); System.exit(0); } if (reply == null) {