[infinispan-commits] Infinispan SVN: r678 - trunk/core/src/test/java/org/infinispan/distribution.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-08-13 12:58:21 -0400 (Thu, 13 Aug 2009)
New Revision: 678

Modified:
   trunk/core/src/test/java/org/infinispan/distribution/DistAsyncTxFuncTest.java
Log:
More debug

Modified: trunk/core/src/test/java/org/infinispan/distribution/DistAsyncTxFuncTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/distribution/DistAsyncTxFuncTest.java	2009-08-13 15:54:04 UTC (rev 677)
+++ trunk/core/src/test/java/org/infinispan/distribution/DistAsyncTxFuncTest.java	2009-08-13 16:58:21 UTC (rev 678)
@@ -3,6 +3,7 @@
 import org.infinispan.Cache;
 import org.infinispan.commands.VisitableCommand;
 import org.infinispan.commands.write.InvalidateL1Command;
+import org.infinispan.remoting.transport.Address;
 import org.infinispan.test.ReplListener;
 import org.testng.annotations.Test;
 
@@ -10,6 +11,7 @@
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -20,6 +22,7 @@
    ReplListener r1, r2, r3, r4;
    ReplListener[] r;
    Map<Cache<?, ?>, ReplListener> listenerLookup;
+   List<Address> listenerCaches = new LinkedList<Address>();
 
    public DistAsyncTxFuncTest() {
       sync = false;
@@ -37,7 +40,10 @@
       r4 = new ReplListener(c4, true, true);
       r = new ReplListener[]{r1, r2, r3, r4};
       listenerLookup = new HashMap<Cache<?, ?>, ReplListener>();
-      for (ReplListener rl : r) listenerLookup.put(rl.getCache(), rl);
+      for (ReplListener rl : r) {
+         listenerCaches.add(addressOf(rl.getCache()));
+         listenerLookup.put(rl.getCache(), rl);
+      }
    }
 
    @Override
@@ -50,6 +56,7 @@
          for (ReplListener rl : r) rl.waitForRpc();
       } else {
          for (Cache<?, ?> c : getOwners(key)) {
+            log.info("Analysing cache " + addressOf(c) + ".  Listeners are avbl for caches " + listenerCaches);
             if (cachesOnWhichKeyShouldInvalList.remove(c)) {
                listenerLookup.get(c).expect(command, InvalidateL1Command.class);
             } else {