[jbosscache-commits] JBoss Cache SVN: r7659 - core/trunk/src/main/java/org/jboss/cache.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-02-06 10:36:50 -0500 (Fri, 06 Feb 2009)
New Revision: 7659

Modified:
   core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java
Log:
fixed issue: for NBST, member list was retreived *before* connecting to the channel,  which was incorrect

Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java	2009-02-06 14:42:45 UTC (rev 7658)
+++ core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java	2009-02-06 15:36:50 UTC (rev 7659)
@@ -87,7 +87,7 @@
 {
    private Channel channel;
    private final Log log = LogFactory.getLog(RPCManagerImpl.class);
-   private List<Address> members;
+   private volatile List<Address> members;
    private long replicationCount;
    private long replicationFailures;
    private boolean statisticsEnabled = false;
@@ -210,12 +210,10 @@
             }
 
 
-            List<Address> members = getMembers();
-
             long start = System.currentTimeMillis();
             if (nonBlocking)
             {
-               startNonBlockStateTransfer(members);
+               startNonBlockStateTransfer(getMembers());
             }
             else
             {
@@ -227,7 +225,7 @@
                      log.info("Cache local address is " + getLocalAddress());
                   }
 
-                  if (members.size() > 1)
+                  if (getMembers().size() > 1)
                   {
                      messageListener.waitForState();
                   }