[jbosscache-commits] JBoss Cache SVN: r7772 - in core/trunk/src/main/java/org/jboss/cache: statetransfer and 1 other directory.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-02-24 09:20:30 -0500 (Tue, 24 Feb 2009)
New Revision: 7772

Modified:
   core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java
   core/trunk/src/main/java/org/jboss/cache/statetransfer/DefaultStateTransferManager.java
Log:
More verbose logging

Modified: core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java	2009-02-24 14:03:13 UTC (rev 7771)
+++ core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java	2009-02-24 14:20:30 UTC (rev 7772)
@@ -181,6 +181,7 @@
          log.debug("transferred state is null (may be first member in cluster)");
          return;
       }
+      if (trace) log.trace("setState() called with byte array of size " + new_state.length);
       ByteArrayInputStream bais = new ByteArrayInputStream(new_state);
       MarshalledValueInputStream in = null;
       try
@@ -287,6 +288,7 @@
          log.debug("stream is null (may be first member in cluster)");
          return;
       }
+      if (trace) log.trace("setState() called with input stream");
       MarshalledValueInputStream in = null;
       try
       {
@@ -311,12 +313,12 @@
 
    public void setState(String state_id, byte[] state)
    {
-      if (trace) log.trace("Receiving state for " + state_id);
       if (state == null)
       {
-         log.debug("partial transferred state is null");
+         log.debug("partial transferred state for id "+state_id+ " is null");
          return;
       }
+      if (trace) log.trace("Receiving state byte array of length " +state.length+" for " + state_id);
 
       MarshalledValueInputStream in = null;
       String targetRoot = state_id;
@@ -359,7 +361,7 @@
 
    public void setState(String stateId, InputStream istream)
    {
-      if (trace) log.trace("Receiving state for " + stateId);
+      if (trace) log.trace("Receiving state on stream for " + stateId);
       String targetRoot = stateId;
       MarshalledValueInputStream in = null;
       boolean hasDifferentSourceAndIntegrationRoots = stateId.indexOf(DefaultStateTransferManager.PARTIAL_STATE_DELIMITER) > 0;

Modified: core/trunk/src/main/java/org/jboss/cache/statetransfer/DefaultStateTransferManager.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/statetransfer/DefaultStateTransferManager.java	2009-02-24 14:03:13 UTC (rev 7771)
+++ core/trunk/src/main/java/org/jboss/cache/statetransfer/DefaultStateTransferManager.java	2009-02-24 14:20:30 UTC (rev 7772)
@@ -140,6 +140,7 @@
 
    public void setState(ObjectInputStream in, Fqn targetRoot) throws Exception
    {
+      if (trace) log.trace("Setting state on Fqn root " + targetRoot);
       cache.getInvocationContext().getOptionOverrides().setSkipCacheStatusCheck(true);
       NodeSPI target = cache.getNode(targetRoot);
       if (target == null)