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

[Manik Surtani]

  User: msurtani
  Date: 07/03/19 15:03:34

  Modified:    src/org/jboss/cache/transaction   TransactionEntry.java
                        OptimisticTransactionEntry.java
  Log:
  JBCACHE-848 - putForExternalRead()
  
  Revision  Changes    Path
  1.7       +28 -1     JBossCache/src/org/jboss/cache/transaction/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/transaction/TransactionEntry.java,v
  retrieving revision 1.6
  retrieving revision 1.7
  diff -u -b -r1.6 -r1.7
  --- TransactionEntry.java	7 Mar 2007 23:44:00 -0000	1.6
  +++ TransactionEntry.java	19 Mar 2007 19:03:34 -0000	1.7
  @@ -43,7 +43,7 @@
    * </ul>
    *
    * @author <a href="mailto:bela at jboss.org">Bela Ban</a> Apr 14, 2003
  - * @version $Revision: 1.6 $
  + * @version $Revision: 1.7 $
    */
   @ThreadSafe
   public class TransactionEntry
  @@ -57,6 +57,8 @@
      private Transaction ltx = null;
      private Option option;
   
  +   private boolean forceAsyncReplication = false;
  +
      /**
       * List<MethodCall> of modifications ({@link MethodCall}). They will be replicated on TX commit
       */
  @@ -287,6 +289,31 @@
      }
   
      /**
  +    * Gets the value of the forceAsyncReplication flag.  Used by ReplicationInterceptor and OptimisticReplicationInterceptor
  +    * when dealing with {@link org.jboss.cache.Cache#putForExternalRead(org.jboss.cache.Fqn,Object,Object)} within
  +    * a transactional context.
  +    *
  +    * @return true if the forceAsyncReplication flag is set to true.
  +    */
  +   public boolean isForceAsyncReplication()
  +   {
  +      return forceAsyncReplication;
  +   }
  +
  +   /**
  +    * Sets the value of the forceAsyncReplication flag.  Used by ReplicationInterceptor and OptimisticReplicationInterceptor
  +    * when dealing with {@link org.jboss.cache.Cache#putForExternalRead(org.jboss.cache.Fqn,Object,Object)} within
  +    * a transactional context.
  +    *
  +    * @param forceAsyncReplication value of forceAsyncReplication
  +    */
  +   public void setForceAsyncReplication(boolean forceAsyncReplication)
  +   {
  +      this.forceAsyncReplication = forceAsyncReplication;
  +   }
  +
  +
  +   /**
       * Posts all undo operations to the CacheImpl.
       */
      public void undoOperations(CacheSPI cache)
  
  
  
  1.2       +0 -1      JBossCache/src/org/jboss/cache/transaction/OptimisticTransactionEntry.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: OptimisticTransactionEntry.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/transaction/OptimisticTransactionEntry.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -b -r1.1 -r1.2
  --- OptimisticTransactionEntry.java	7 Feb 2007 22:06:44 -0000	1.1
  +++ OptimisticTransactionEntry.java	19 Mar 2007 19:03:34 -0000	1.2
  @@ -19,7 +19,6 @@
   
   public class OptimisticTransactionEntry extends TransactionEntry
   {
  -
      private TransactionWorkspace transactionWorkSpace = new TransactionWorkspaceImpl();
   
      public OptimisticTransactionEntry()