[jboss-cvs] JBossCache/src/org/jboss/cache/interceptors ...
Manik Surtani
msurtani at jboss.com
Tue Sep 12 08:52:07 EDT 2006
User: msurtani
Date: 06/09/12 08:52:07
Modified: src/org/jboss/cache/interceptors
ReplicationInterceptor.java
Log:
Added trace logging
Revision Changes Path
1.40 +6 -3 JBossCache/src/org/jboss/cache/interceptors/ReplicationInterceptor.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ReplicationInterceptor.java
===================================================================
RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/interceptors/ReplicationInterceptor.java,v
retrieving revision 1.39
retrieving revision 1.40
diff -u -b -r1.39 -r1.40
--- ReplicationInterceptor.java 29 Aug 2006 16:35:52 -0000 1.39
+++ ReplicationInterceptor.java 12 Sep 2006 12:52:07 -0000 1.40
@@ -13,7 +13,7 @@
* 'side-ways' (see docs/design/Refactoring.txt).
*
* @author Bela Ban
- * @version $Id: ReplicationInterceptor.java,v 1.39 2006/08/29 16:35:52 msurtani Exp $
+ * @version $Id: ReplicationInterceptor.java,v 1.40 2006/09/12 12:52:07 msurtani Exp $
*/
public class ReplicationInterceptor extends BaseRpcInterceptor
{
@@ -23,8 +23,11 @@
InvocationContext ctx = cache.getInvocationContext();
GlobalTransaction gtx = ctx.getGlobalTransaction();
+
boolean isLocalCommitOrRollback = gtx != null && !gtx.isRemote() && (m.getMethodId() == MethodDeclarations.commitMethod_id || m.getMethodId() == MethodDeclarations.rollbackMethod_id);
+ if (log.isTraceEnabled()) log.trace("isLocalCommitOrRollback? " + isLocalCommitOrRollback + "; gtx = " + gtx);
+
// pass up the chain if not a local commit or rollback (in which case replicate first)
Object o = isLocalCommitOrRollback ? null : super.invoke(m);
// ctx = cache.getInvocationContext();
More information about the jboss-cvs-commits
mailing list