[jboss-cvs] JBossAS SVN: r110097 - in trunk/server/src/main/java/org/jboss/ejb: plugins and 1 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue Dec 21 11:01:33 EST 2010
Author: alex.loubyansky at jboss.com
Date: 2010-12-21 11:01:33 -0500 (Tue, 21 Dec 2010)
New Revision: 110097
Modified:
trunk/server/src/main/java/org/jboss/ejb/EnterpriseContext.java
trunk/server/src/main/java/org/jboss/ejb/GlobalTxEntityMap.java
trunk/server/src/main/java/org/jboss/ejb/plugins/EntityReentranceInterceptor.java
trunk/server/src/main/java/org/jboss/ejb/plugins/StatefulSessionInstanceInterceptor.java
trunk/server/src/main/java/org/jboss/ejb/plugins/lock/QueuedPessimisticEJBLock.java
trunk/server/src/main/java/org/jboss/ejb/plugins/lock/SimpleReadWriteEJBLock.java
Log:
JBAS-6348
Modified: trunk/server/src/main/java/org/jboss/ejb/EnterpriseContext.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/EnterpriseContext.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/EnterpriseContext.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -61,6 +61,7 @@
import org.jboss.security.javaee.SecurityHelperFactory;
import org.jboss.security.javaee.SecurityRoleRef;
import org.jboss.tm.TransactionTimeoutConfiguration;
+import org.jboss.tm.TxUtils;
import org.jboss.tm.usertx.client.ServerVMClientUserTransaction;
//$Id$
@@ -463,9 +464,7 @@
// JBAS-3847, consider an asynchronous rollback due to timeout
int status = tm.getStatus();
- return status == Status.STATUS_MARKED_ROLLBACK
- || status == Status.STATUS_ROLLING_BACK
- || status == Status.STATUS_ROLLEDBACK;
+ return TxUtils.isRollback(status);
}
catch (SystemException e)
{
Modified: trunk/server/src/main/java/org/jboss/ejb/GlobalTxEntityMap.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/GlobalTxEntityMap.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/GlobalTxEntityMap.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -23,6 +23,7 @@
import org.jboss.logging.Logger;
import org.jboss.tm.TransactionLocal;
+import org.jboss.tm.TxUtils;
import javax.ejb.EJBException;
import javax.transaction.RollbackException;
@@ -352,7 +353,7 @@
{
// any one can mark the tx rollback at any time so check
// before continuing to the next store
- if(tx.getStatus() == Status.STATUS_MARKED_ROLLBACK)
+ if(TxUtils.isRollback(tx))
{
return;
}
@@ -365,7 +366,7 @@
{
// any one can mark the tx rollback at any time so check
// before continuing to the next store
- if(tx.getStatus() == Status.STATUS_MARKED_ROLLBACK)
+ if(TxUtils.isRollback(tx))
{
return;
}
Modified: trunk/server/src/main/java/org/jboss/ejb/plugins/EntityReentranceInterceptor.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/plugins/EntityReentranceInterceptor.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/plugins/EntityReentranceInterceptor.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -33,6 +33,7 @@
import org.jboss.ejb.Container;
import org.jboss.ejb.EntityEnterpriseContext;
import org.jboss.metadata.EntityMetaData;
+import org.jboss.tm.TxUtils;
import org.jboss.ejb.plugins.lock.Entrancy;
import org.jboss.ejb.plugins.lock.NonReentrantLock;
import org.jboss.ejb.plugins.cmp.jdbc.bridge.CMRInvocation;
@@ -69,11 +70,7 @@
protected boolean isTxExpired(Transaction miTx) throws Exception
{
- if (miTx != null && miTx.getStatus() == Status.STATUS_MARKED_ROLLBACK)
- {
- return true;
- }
- return false;
+ return TxUtils.isRollback(miTx);
}
public Object invoke(Invocation mi)
Modified: trunk/server/src/main/java/org/jboss/ejb/plugins/StatefulSessionInstanceInterceptor.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/plugins/StatefulSessionInstanceInterceptor.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/plugins/StatefulSessionInstanceInterceptor.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -49,6 +49,7 @@
import org.jboss.metadata.SessionMetaData;
import org.jboss.security.AuthenticationManager;
import org.jboss.security.SecurityConstants;
+import org.jboss.tm.TxUtils;
/**
* This container acquires the given instance.
@@ -175,9 +176,8 @@
// OSH: An extra check to avoid warning.
// Can go when we are sure that we no longer get
// the JTA violation warning.
- if (tx.getStatus() == Status.STATUS_MARKED_ROLLBACK)
+ if (TxUtils.isRollback(tx.getStatus()))
{
-
return;
}
Modified: trunk/server/src/main/java/org/jboss/ejb/plugins/lock/QueuedPessimisticEJBLock.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/plugins/lock/QueuedPessimisticEJBLock.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/plugins/lock/QueuedPessimisticEJBLock.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -32,6 +32,7 @@
import org.jboss.ejb.Container;
import org.jboss.ejb.EntityEnterpriseContext;
import org.jboss.monitor.LockMonitor;
+import org.jboss.tm.TxUtils;
import org.jboss.util.deadlock.DeadlockDetector;
/**
@@ -177,12 +178,7 @@
protected boolean isTxExpired(Transaction miTx) throws Exception
{
- if(miTx == null)
- return false;
- int status = miTx.getStatus();
- return status == Status.STATUS_MARKED_ROLLBACK ||
- status == Status.STATUS_ROLLEDBACK ||
- status == Status.STATUS_ROLLING_BACK;
+ return TxUtils.isRollback(miTx);
}
Modified: trunk/server/src/main/java/org/jboss/ejb/plugins/lock/SimpleReadWriteEJBLock.java
===================================================================
--- trunk/server/src/main/java/org/jboss/ejb/plugins/lock/SimpleReadWriteEJBLock.java 2010-12-21 16:00:37 UTC (rev 110096)
+++ trunk/server/src/main/java/org/jboss/ejb/plugins/lock/SimpleReadWriteEJBLock.java 2010-12-21 16:01:33 UTC (rev 110097)
@@ -26,11 +26,11 @@
import java.lang.reflect.Method;
import javax.ejb.EJBException;
-import javax.transaction.Status;
import javax.transaction.Transaction;
import javax.transaction.Synchronization;
import org.jboss.invocation.Invocation;
+import org.jboss.tm.TxUtils;
/**
*
@@ -334,7 +334,7 @@
{
try
{
- if(tx != null && tx.getStatus() == Status.STATUS_MARKED_ROLLBACK)
+ if(TxUtils.isRollback(tx))
throw new EJBException ("Transaction marked for rollback - probably a timeout.");
}
catch (Exception e)
More information about the jboss-cvs-commits
mailing list