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

Author: manik.surtani(a)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)