aboutsummaryrefslogtreecommitdiff
path: root/src/ProxyClient.java
diff options
context:
space:
mode:
authorjestin2012-08-23 19:39:32 +0000
committerjestin2012-08-23 19:39:32 +0000
commite3b0fb9534d783d62245be8d7777f35d34e6d59d (patch)
tree1216b70c18c478eb1e132c749b4ce4c09ae1b786 /src/ProxyClient.java
parente854a58a81ec90e419a4b3effa5a83caac05df90 (diff)
downloadivy-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.java8
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();