[jboss-cvs] JBossCache/tests/functional/org/jboss/cache/loader/deadlock ...

[Manik Surtani]

  User: msurtani
  Date: 07/06/18 18:44:26

  Modified:    tests/functional/org/jboss/cache/loader/deadlock 
                        ConcurrentCreationDeadlockTest.java
  Log:
  cache loader locking improvements
  
  Revision  Changes    Path
  1.18      +20 -20    JBossCache/tests/functional/org/jboss/cache/loader/deadlock/ConcurrentCreationDeadlockTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ConcurrentCreationDeadlockTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/tests/functional/org/jboss/cache/loader/deadlock/ConcurrentCreationDeadlockTest.java,v
  retrieving revision 1.17
  retrieving revision 1.18
  diff -u -b -r1.17 -r1.18
  --- ConcurrentCreationDeadlockTest.java	11 Jun 2007 12:58:16 -0000	1.17
  +++ ConcurrentCreationDeadlockTest.java	18 Jun 2007 22:44:26 -0000	1.18
  @@ -164,7 +164,7 @@
         {
            cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("", cacheLoaderClass, "", false, false, false));
         }
  -      cache.create();
  +      cache.getConfiguration().setLockAcquisitionTimeout(600000);
         cache.start();
      }
   
  @@ -346,7 +346,7 @@
            if (mcl_exception != null)
            {
               // terminate the test on the first failed worker
  -            fail("Due to an exception: " + mcl_exception);
  +            throw mcl_exception;
            }
            // start several worker threads to work with the same set of FQN's
            Worker[] t = new Worker[NUM_WORKERS];
  @@ -395,7 +395,7 @@
       *
       * @author Marian Nikolov
       * @author $Author: msurtani $
  -    * @version $Date: 2007/06/11 12:58:16 $
  +    * @version $Date: 2007/06/18 22:44:26 $
       */
      private class Worker extends Thread
      {
  @@ -472,7 +472,7 @@
                  }
                  // the first worker would create a new node for the FQN
                  // all the others would update the same node
  -               Fqn fqn = new Fqn(new Fqn("NODE"), i);
  +               Fqn fqn = Fqn.fromString("/NODE/" + i);
                  for (int m = 0; m < m_modificationsPerTx; m++)
                  {
                     cache.put(fqn, m, i);