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

[Manik Surtani]

  User: msurtani
  Date: 07/07/17 13:22:13

  Modified:    src/org/jboss/cache/loader/jdbm  JdbmCacheLoader.java
  Log:
  JBCACHE-1134
  
  Revision  Changes    Path
  1.29      +19 -58    JBossCache/src/org/jboss/cache/loader/jdbm/JdbmCacheLoader.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: JdbmCacheLoader.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/loader/jdbm/JdbmCacheLoader.java,v
  retrieving revision 1.28
  retrieving revision 1.29
  diff -u -b -r1.28 -r1.29
  --- JdbmCacheLoader.java	19 Jun 2007 17:46:50 -0000	1.28
  +++ JdbmCacheLoader.java	17 Jul 2007 17:22:13 -0000	1.29
  @@ -56,7 +56,7 @@
    * plans to fix this.
    *
    * @author Elias Ross
  - * @version $Id: JdbmCacheLoader.java,v 1.28 2007/06/19 17:46:50 msurtani Exp $
  + * @version $Id: JdbmCacheLoader.java,v 1.29 2007/07/17 17:22:13 msurtani Exp $
    */
   @ThreadSafe
   public class JdbmCacheLoader extends AbstractCacheLoader
  @@ -78,19 +78,17 @@
       * Note that setConfig() and setCache() are called before create().
       */
   
  +   @Override
      public void create() throws Exception
      {
         checkNotOpen();
      }
   
  -   public void destroy()
  -   {
  -   }
  -
      /**
       * Opens the environment and the database specified by the configuration
       * string.  The environment and databases are created if necessary.
       */
  +   @Override
      public void start()
              throws Exception
      {
  @@ -194,6 +192,7 @@
      /**
       * Closes the databases and environment, and nulls references to them.
       */
  +   @Override
      public void stop()
      {
         log.debug("stop");
  @@ -593,44 +592,6 @@
      }
   
      /**
  -    * Applies and commits the given modifications in one transaction.
  -    */
  -   public void prepare(Object tx, List<Modification> modifications, boolean onePhase)
  -           throws Exception
  -   {
  -      if (onePhase)
  -      {
  -         put(modifications);
  -      }
  -      else
  -      {
  -         transactions.put(tx, modifications);
  -      }
  -   }
  -
  -   /**
  -    * Commits a transaction.
  -    */
  -   public void commit(Object tx) throws Exception
  -   {
  -      List<Modification> modifications = transactions.remove(tx);
  -      if (modifications == null)
  -      {
  -         throw new IllegalStateException("transaction " + tx + " not found in transaction table");
  -      }
  -      put(modifications);
  -      commit();
  -   }
  -
  -   /**
  -    * Removes transaction in progress.
  -    */
  -   public void rollback(Object tx)
  -   {
  -      transactions.remove(tx);
  -   }
  -
  -   /**
       * Throws an exception if the environment is not open.
       */
      private void checkOpen()