tddl.rar_Different_TDDL

/* * JBoss, Home of Professional Open Source. * Copyright 2006, Red Hat Middleware LLC, and individual contributors * as indicated by the @author tags. See the copyright.txt file in the * distribution for a full listing of individual contributors. * * This is free software; you can redistribute it and/or modify it * under the terms of the GNU Lesser General Public License as * published by the Free Software Foundation; either version 2.1 of * the License, or (at your option) any later version. * * This software is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this software; if not, write to the Free * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ package com.taobao.datasource.tm; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; import java.util.Map; import java.util.Set; import javax.resource.spi.work.Work; import javax.resource.spi.work.WorkCompletedException; import javax.resource.spi.work.WorkException; import javax.transaction.HeuristicMixedException; import javax.transaction.HeuristicRollbackException; import javax.transaction.RollbackException; import javax.transaction.Status; import javax.transaction.Synchronization; import javax.transaction.SystemException; import javax.transaction.Transaction; import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; import org.jboss.logging.Logger; import org.jboss.util.timeout.Timeout; import org.jboss.util.timeout.TimeoutFactory; import org.jboss.util.timeout.TimeoutTarget; import com.taobao.datasource.tm.integrity.TransactionIntegrity; /** * Our <code>Transaction</code> implementation. * * @see TxManager * * @author <a href="mailto:rickard.oberg@telkel.com">Rickard Öberg</a> * @author <a href="mailto:marc.fleury@telkel.com">Marc Fleury</a> * @author <a href="mailto:osh@sparre.dk">Ole Husgaard</a> * @author <a href="mailto:toby.allsopp@peace.com">Toby Allsopp</a> * @author <a href="mailto:jason@planet57.com">Jason Dillon</a> * @author <a href="mailto:d_jencks@users.sourceforge.net">David Jencks</a> * @author <a href="mailto:bill@jboss.org">Bill Burke</a> * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a> * @author <a href="mailto:dimitris@jboss.org">Dimitris Andreadis</a> * @version $Revision: 57208 $ */ public class TransactionImpl implements Transaction, TimeoutTarget { // Constants ----------------------------------------------------- /** * Code meaning "no heuristics seen", * must not be XAException.XA_HEURxxx */ private static final int HEUR_NONE = XAException.XA_RETRY; // Resource states private final static int RS_NEW = 0; // not yet enlisted private final static int RS_ENLISTED = 1; // enlisted private final static int RS_SUSPENDED = 2; // suspended private final static int RS_ENDED = 3; // not associated private final static int RS_VOTE_READONLY = 4; // voted read-only private final static int RS_VOTE_OK = 5; // voted ok private final static int RS_FORGOT = 6; // RM has forgotten // Attributes ---------------------------------------------------- /** Class logger, we don't want a new logger with every transaction. */ private static Logger log = Logger.getLogger(TransactionImpl.class); /** True if trace messages should be logged. */ private boolean trace = log.isTraceEnabled(); /** The ID of this transaction. */ private XidImpl xid; /** The global id */ private GlobalId gid; private HashSet threads = new HashSet(1); private Map transactionLocalMap = Collections.synchronizedMap(new HashMap()); private Throwable cause; /** * The synchronizations to call back. */ private Synchronization[] sync = new Synchronization[3]; /** * Size of allocated synchronization array. */ private int syncAllocSize = 3; /** * Count of synchronizations for this transaction. */ private int syncCount = 0; /** * A list of the XAResources that have participated in this transaction. */ private ArrayList resources = new ArrayList(3); /** * The XAResource used in the last resource gambit */ private Resource lastResource; /** * Flags that it is too late to enlist new resources. */ private boolean resourcesEnded = false; /** * Last branch id used. */ private long lastBranchId = 0; /** * Status of this transaction. */ private int status; /** * The heuristics status of this transaction. */ private int heuristicCode = HEUR_NONE; /** * The time when this transaction was started. */ private long start; /** * The timeout handle for this transaction. */ private Timeout timeout; /** * Timeout in millisecs */ private long timeoutPeriod; /** * Mutex for thread-safety. This should only be changed in the * <code>lock()</code> and <code>unlock()</code> methods. */ private Thread locked = null; /** * The lock depth */ private int lockDepth = 0; /** Any current work associated with the transaction */ private Work work; /** * Flags that we are done with this transaction and that it can be reused. */ private boolean done = false; // Static -------------------------------------------------------- /** * Factory for Xid instances of specified class. * This is set from the <code>TransactionManagerService</code> * MBean. */ static XidFactoryMBean xidFactory; // static TransactionManagerService txManagerService; /** The timeout factory */ static TimeoutFactory timeoutFactory = TimeoutFactory.getSingleton(); /** * This static code is only present for testing purposes so a * tm can be usable without a lot of setup. */ static void defaultXidFactory() { if (xidFactory == null) xidFactory = new XidFactory(); } // Constructors -------------------------------------------------- TransactionImpl(long timeout) { xid = xidFactory.newXid(); gid = xid.getTrulyGlobalId(); status = Status.STATUS_ACTIVE; start = System.currentTimeMillis(); this.timeout = timeoutFactory.createTimeout(start+timeout, this); this.timeoutPeriod = timeout; if (trace) log.trace("Created new instance for tx=" + toString()); } TransactionImpl(GlobalId gid, long timeout) { this.gid = gid; xid = xidFactory.newXid(); status = Status.STATUS_ACTIVE; start = System.currentTimeMillis(); this.timeout = timeoutFactory.createTimeout(start+timeout, this); this.timeoutPeriod = timeout; if (trace) log.trace("Created new instance for tx=" + toString()); } // Implements TimeoutTarget -------------------------------------- /** * Called when our timeout expires. */ public void timedOut(Timeout timeout) { lock(); try { log.warn("Transaction " + toString() + " timed out." + " status=" + getStringStatus(status)); if (this.timeout == null) return; // Don't race with timeout cancellation. this.timeout = null; switch (status) { case Status.STATUS_ROLLEDBACK: case Status.STATUS_COMMITTED: case Status.STATUS_NO_TRANSACTION: return; // Transaction done. case Status.STATUS_ROLLING_BACK: re