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)
Show replies by date