[jboss-cvs] JBossCache/src/org/jboss/cache ...

[Manik Surtani]

  User: msurtani
  Date: 06/11/24 07:00:45

  Modified:    src/org/jboss/cache   Tag: Branch_JBossCache_1_3_0
                        TransactionEntry.java TransactionTable.java
  Log:
  Ported Brian's fix from Branch JBossCache_1_3_0_SP3_JBCACHE-873 (see JBCACHE-873) which fixes JBCACHE-871
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.3.2.1   +32 -2     JBossCache/src/org/jboss/cache/TransactionEntry.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: TransactionEntry.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/TransactionEntry.java,v
  retrieving revision 1.3
  retrieving revision 1.3.2.1
  diff -u -b -r1.3 -r1.3.2.1
  --- TransactionEntry.java	10 Jan 2006 14:38:44 -0000	1.3
  +++ TransactionEntry.java	24 Nov 2006 12:00:45 -0000	1.3.2.1
  @@ -7,8 +7,8 @@
   package org.jboss.cache;
   
   
  -import org.jboss.cache.lock.IdentityLock;
   import org.jboss.cache.config.Option;
  +import org.jboss.cache.lock.IdentityLock;
   import org.jgroups.blocks.MethodCall;
   
   import javax.transaction.Transaction;
  @@ -16,6 +16,7 @@
   import java.util.Iterator;
   import java.util.LinkedList;
   import java.util.List;
  +import java.util.ArrayList;
   
   
   /**
  @@ -32,7 +33,7 @@
    * </ul>
    *
    * @author <a href="mailto:bela at jboss.org">Bela Ban</a> Apr 14, 2003
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.3.2.1 $
    */
   public class TransactionEntry {
   
  @@ -61,6 +62,12 @@
       */
      protected List locks=new LinkedList();
   
  +   /**
  +    * List<Fqn> of nodes that have been removed by the transaction
  +    */
  +   protected List removedNodes = new LinkedList();
  +
  +
   
   
   
  @@ -81,6 +88,29 @@
         undo_list.add(m);
      }
   
  +   /**
  +    * Adds the node that has been removed.
  +    *
  +    * @param fqn
  +    */
  +   public void addRemovedNode(Fqn fqn) {
  +      removedNodes.add(fqn);
  +   }
  +
  +   /**
  +    * Gets the list of removed nodes.
  +    *
  +    * @return
  +    */
  +   public List getRemovedNodes()
  +   {
  +      return new ArrayList(removedNodes);
  +   }
  +
  +   /**
  +    * Returns the undo operations in use.
  +    * Note:  This list may be concurrently modified.
  +    */
      public List getUndoOperations() {
         return undo_list;
      }
  
  
  
  1.5.2.1   +18 -1     JBossCache/src/org/jboss/cache/TransactionTable.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: TransactionTable.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/TransactionTable.java,v
  retrieving revision 1.5
  retrieving revision 1.5.2.1
  diff -u -b -r1.5 -r1.5.2.1
  --- TransactionTable.java	12 Jan 2006 04:25:47 -0000	1.5
  +++ TransactionTable.java	24 Nov 2006 12:00:45 -0000	1.5.2.1
  @@ -26,7 +26,7 @@
    * (GlobalTransaction). Also keys modifications and undo-operations) under a given TX
    *
    * @author <a href="mailto:bela at jboss.org">Bela Ban</a> Apr 14, 2003
  - * @version $Revision: 1.5 $
  + * @version $Revision: 1.5.2.1 $
    */
   public class TransactionTable {
   
  @@ -150,6 +150,23 @@
         entry.addLocks(locks);
      }
   
  +   /**
  +    * Adds a node that has been removed to the global transaction
  +    */
  +   public void addRemovedNode(GlobalTransaction gtx, Fqn fqn)
  +   {
  +      TransactionEntry entry=get(gtx);
  +      if(entry == null) {
  +         log.error("transaction entry not found for (gtx=" + gtx + ")");
  +         return;
  +      }
  +      entry.addRemovedNode(fqn);
  +
  +   }
  +
  +   /**
  +    * Returns summary debug information.
  +    */
      public String toString() {
         StringBuffer sb=new StringBuffer();
         sb.append(tx_map.size()).append(" mappings, ");