diff --git a/src/eu/telecom_bretagne/praxis/common/events/CommunicationFacade.java b/src/eu/telecom_bretagne/praxis/common/events/CommunicationFacade.java index 3ac76efb4421b13c0ea2324c6e80524230260944..8863630e87456fe4bc15b2e305d7134205533a25 100644 --- a/src/eu/telecom_bretagne/praxis/common/events/CommunicationFacade.java +++ b/src/eu/telecom_bretagne/praxis/common/events/CommunicationFacade.java @@ -8,6 +8,7 @@ import java.util.ArrayList; import java.util.List; import java.util.concurrent.Semaphore; +import eu.telecom_bretagne.praxis.common.Log; import eu.telecom_bretagne.praxis.common.events.Event.IncompatibleListenerException; @@ -198,7 +199,11 @@ public abstract class CommunicationFacade protected synchronized void connected() { if ( connected ) + { + Log.log.finest("Already connected"); return; + } + Log.log.finest("connected, notifying listeners"); connected = true; event_listeners_modification_semaphore.acquireUninterruptibly(); ArrayList<EventListener> event_listeners_copy; @@ -211,7 +216,10 @@ public abstract class CommunicationFacade event_listeners_modification_semaphore.release(); } for (EventListener listener: event_listeners_copy) + { + Log.log.finest("connected, notifying listener "+listener.toString()); listener.connected(); + } } @@ -222,8 +230,12 @@ public abstract class CommunicationFacade */ protected synchronized void disconnect(Exception reason) { + Log.log.finest("disconnect reason:"+(reason!=null?reason.toString():"<null>")); if ( ! connected ) + { + Log.log.finest("already disconnected, nothing to do"); return; + } connected = false; event_listeners_modification_semaphore.acquireUninterruptibly(); diff --git a/src/eu/telecom_bretagne/praxis/common/events/RMICommunicationFacade.java b/src/eu/telecom_bretagne/praxis/common/events/RMICommunicationFacade.java index 35bb9da458b08a1fb2214c0c2672cda7a9c331a2..4563dbdcc44d00ef880920ead08374c2653d0c81 100644 --- a/src/eu/telecom_bretagne/praxis/common/events/RMICommunicationFacade.java +++ b/src/eu/telecom_bretagne/praxis/common/events/RMICommunicationFacade.java @@ -191,6 +191,7 @@ public class RMICommunicationFacade } RMICommunicationFacade c = new RMICommunicationFacade(clientIP); new Server(c); + c.connected(); return CNX.buildCNX(c, Configuration.getBoolean("rmi.useSSL")); } }