Mercurial > hg > FederatedLinda

changeset 88:5d1189e9e420

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
MetaLinda.sync() fix
author one
date Thu, 11 Feb 2010 12:22:41 +0900
parents 8931a3e90c2a
children b658ff1eb90f
files src/fdl/MetaLinda.java src/fdl/test/debug/ConfigurationManagerEngine.java src/fdl/test/debug/MetaProtocolEngine.java
diffstat 3 files changed, 3 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/fdl/MetaLinda.java	Thu Feb 11 12:05:49 2010 +0900
+++ b/src/fdl/MetaLinda.java	Thu Feb 11 12:22:41 2010 +0900
@@ -106,8 +106,8 @@
 	}
 
 	public int sync(long timeout) {
+		fdl.queueExec();
 		fds.checkTuple(timeout); // fdl sync is also handled here
-		fdl.queueExec();
 		/*
 		 * r.callback() may call meta.sync() and modifies the
 		 * replies queue. Do current size of queue only. The
--- a/src/fdl/test/debug/ConfigurationManagerEngine.java	Thu Feb 11 12:05:49 2010 +0900
+++ b/src/fdl/test/debug/ConfigurationManagerEngine.java	Thu Feb 11 12:22:41 2010 +0900
@@ -93,7 +93,7 @@
 		// regist poll tuple id
 		ml.in(MANAGE, new AcceptNewNode());
 		while (running)
-			ml.sync(1);
+			ml.sync();
 	}
 	
 	private void linkNodes() {
--- a/src/fdl/test/debug/MetaProtocolEngine.java	Thu Feb 11 12:05:49 2010 +0900
+++ b/src/fdl/test/debug/MetaProtocolEngine.java	Thu Feb 11 12:22:41 2010 +0900
@@ -240,7 +240,7 @@
 	public void mainLoop() {
 		initPoller();
 		while (running) {
-			ml.sync(1);
+			ml.sync();
 		}
 	}