[infinispan-commits] Infinispan SVN: r1107 - trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups.

[infinispan-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2009-11-06 03:56:31 -0500 (Fri, 06 Nov 2009)
New Revision: 1107

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
Log:
[ISPN-257] (Log physical address as well as the logical address) Done.

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-11-05 16:26:22 UTC (rev 1106)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/JGroupsTransport.java	2009-11-06 08:56:31 UTC (rev 1107)
@@ -45,10 +45,12 @@
 import org.infinispan.util.logging.LogFactory;
 import org.jgroups.Channel;
 import org.jgroups.ChannelException;
+import org.jgroups.Event;
 import org.jgroups.ExtendedMembershipListener;
 import org.jgroups.ExtendedMessageListener;
 import org.jgroups.JChannel;
 import org.jgroups.Message;
+import org.jgroups.PhysicalAddress;
 import org.jgroups.View;
 import org.jgroups.blocks.GroupRequest;
 import org.jgroups.blocks.RspFilter;
@@ -155,7 +157,7 @@
             throw new CacheException("Unable to start JGroups Channel", e);
          }
       }
-      log.info("Cache local address is {0}", getAddress());
+      log.info("Cache local address is {0}, physical address is {1}", getAddress(), getPhysicalAddress());
 
       // ensure that the channel has FLUSH enabled.
       // see ISPN-83 for details.
@@ -354,6 +356,10 @@
       return address;
    }
 
+   private PhysicalAddress getPhysicalAddress() {
+      return (PhysicalAddress) channel.downcall(new Event(Event.GET_PHYSICAL_ADDRESS, channel.getAddress()));
+   }
+
    // ------------------------------------------------------------------------------------------------------------------
    // outbound RPC
    // ------------------------------------------------------------------------------------------------------------------