diff options
author | jestin | 2012-08-23 19:39:32 +0000 |
---|---|---|
committer | jestin | 2012-08-23 19:39:32 +0000 |
commit | e3b0fb9534d783d62245be8d7777f35d34e6d59d (patch) | |
tree | 1216b70c18c478eb1e132c749b4ce4c09ae1b786 /src/ProxyClient.java | |
parent | e854a58a81ec90e419a4b3effa5a83caac05df90 (diff) | |
download | ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.zip ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.gz ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.bz2 ivy-java-e3b0fb9534d783d62245be8d7777f35d34e6d59d.tar.xz |
Diffstat (limited to 'src/ProxyClient.java')
-rw-r--r-- | src/ProxyClient.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/ProxyClient.java b/src/ProxyClient.java index 92f2c75..e6e8606 100644 --- a/src/ProxyClient.java +++ b/src/ProxyClient.java @@ -176,7 +176,7 @@ class ProxyClient extends Ivy { * protocol and forward everything to the proxies. * TODO: remember everything in case a new proxy client comes ? */ - protected IvyClient createIvyClient(Socket s,int port, boolean domachin) throws IOException { + protected boolean createIvyClient(Socket s,int port, boolean domachin) throws IOException { IvyClient i; // TODO si c'est un puppet, je ne dois pas creer de Ghost // voir meme me deconnecter du biniou ? @@ -185,8 +185,8 @@ class ProxyClient extends Ivy { // this new Ivy agent is in fact one of my puppets ... System.out.println("not Ghosting this (probable) Puppet Ivy agent"); i= new IvyClient(this,s,port,domachin); - i.start(); - return i; + p.bus.getPool().execute(i); + return true; } } String key = getWBUId(); @@ -196,7 +196,7 @@ class ProxyClient extends Ivy { while ((ghostId=id.get(key))==null) { Thread.sleep(200); } Ghost g = new Ghost(this,s,port,domachin,ghostId,this); ghosts.put(ghostId,g); - return g; + return true; } catch (InterruptedException ie) { ie.printStackTrace(); } System.out.println("error waiting"); throw new RuntimeException(); |