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

[Manik Surtani]

  User: msurtani
  Date: 07/01/29 19:11:39

  Modified:    tests/functional/org/jboss/cache/loader 
                        AsyncFileCacheLoaderTest.java
  Log:
  wc
  
  Revision  Changes    Path
  1.21      +2 -37     JBossCache/tests/functional/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AsyncFileCacheLoaderTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/tests/functional/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java,v
  retrieving revision 1.20
  retrieving revision 1.21
  diff -u -b -r1.20 -r1.21
  --- AsyncFileCacheLoaderTest.java	17 Jan 2007 14:13:06 -0000	1.20
  +++ AsyncFileCacheLoaderTest.java	30 Jan 2007 00:11:39 -0000	1.21
  @@ -33,8 +33,7 @@
         cache = (CacheImpl) DefaultCacheFactory.getInstance().createCache(false);
         cache.getConfiguration().setCacheMode(Configuration.CacheMode.LOCAL);
         // cache.setCacheLoaderConfiguration(getSingleCacheLoaderConfig("", "org.jboss.cache.loader.jdbm.JdbmCacheLoader",
  -      cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("", "org.jboss.cache.loader.FileCacheLoader",
  -              props, true, false, true));
  +      cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("", "org.jboss.cache.loader.FileCacheLoader", props, true, false, true));
         cache.create();
         cache.start();
      }
  @@ -144,7 +143,7 @@
         ByteArrayOutputStream baos = new ByteArrayOutputStream(1024);
         MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
  -      os.writeObject(StateTransferManager.STREAMING_DELIMITER_NODE);
  +      cache.getMarshaller().objectToObjectStream(StateTransferManager.STREAMING_DELIMITER_NODE, os);
         //os.close();
         assertTrue(baos.size() > 0);
         loader.remove(X);
  @@ -156,38 +155,4 @@
         assertEquals("X found", true, loader.exists(X));
         loader.remove(X);
      }
  -
  -   /*public void testWritesGetWritten() throws Exception
  -   {
  -       configureCache();
  -       Fqn fqn = Fqn.fromString("/blah");
  -       CacheLoader loader = cache.getCacheLoader();
  -       loader.remove(fqn);
  -       // a bit brute-force,unfortunately ...
  -       // enqueue a crap load of writes...
  -       int numPuts = 750;
  -       long start = System.currentTimeMillis();
  -       for (int i=0; i<numPuts; i++)
  -           cache.put(fqn, "key" + i, "value" + i);
  -
  -       System.out.println("Finished " + numPuts + " in "  + (System.currentTimeMillis() - start) + "ms");
  -       // stop the cache loader
  -       // blocks till pending writes are completed
  -       start = System.currentTimeMillis();
  -       loader.stop();
  -       System.out.println("Finished stopping the loader in " + (System.currentTimeMillis() - start) + "ms");
  -       System.out.println(loader);
  -
  -       // the loader should have written everything to file now.
  -       loader.start();
  -       Map m = loader.get(fqn);
  -       for (int i=0;i<numPuts; i++)
  -       {
  -           Assert.assertEquals("value" + i, m.get("key" + i));
  -       }
  -
  -       // clean up
  -       loader.remove(fqn);
  -   }*/
  -
   }