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

[Manik Surtani]

  User: msurtani
  Date: 07/07/13 09:27:38

  Modified:    src/org/jboss/cache/loader/bdbje  BdbjeCacheLoader.java
  Log:
  JBCACHE-1137
  
  Revision  Changes    Path
  1.31      +81 -67    JBossCache/src/org/jboss/cache/loader/bdbje/BdbjeCacheLoader.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: BdbjeCacheLoader.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/loader/bdbje/BdbjeCacheLoader.java,v
  retrieving revision 1.30
  retrieving revision 1.31
  diff -u -b -r1.30 -r1.31
  --- BdbjeCacheLoader.java	19 Jun 2007 17:46:50 -0000	1.30
  +++ BdbjeCacheLoader.java	13 Jul 2007 13:27:38 -0000	1.31
  @@ -50,7 +50,7 @@
    *
    * @author Mark Hayes May 16, 2004
    * @author Bela Ban
  - * @version $Id: BdbjeCacheLoader.java,v 1.30 2007/06/19 17:46:50 msurtani Exp $
  + * @version $Id: BdbjeCacheLoader.java,v 1.31 2007/07/13 13:27:38 msurtani Exp $
    */
   @ThreadSafe
   public class BdbjeCacheLoader extends AbstractCacheLoader
  @@ -703,7 +703,20 @@
      private void doRemove(Transaction txn, Fqn name)
              throws Exception
      {
  -
  +      // if the Fqn is Fqn.ROOT, make sure we get all the children and delete them instead.
  +      if (name.isRoot())
  +      {
  +         Set<String> children = getChildrenNames(name);
  +         if (children != null)
  +         {
  +            for (String child : children)
  +            {
  +               doRemove(txn, new Fqn(child));
  +            }
  +         }
  +      }
  +      else
  +      {
         DatabaseEntry keyEntry = makeKeyEntry(name);
         DatabaseEntry foundKey = new DatabaseEntry();
         DatabaseEntry foundData = new DatabaseEntry();
  @@ -729,6 +742,7 @@
            cursor.close();
         }
      }
  +   }
   
      /**
       * Deletes a single FQN-key-value record.