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

[Vladmir Blagojevic]

  User: vblagojevic
  Date: 06/09/12 16:16:56

  Modified:    tests/functional/org/jboss/cache/loader  BdbjeTest.java
  Log:
  store/load moved to AbstractCacheLoader 
  
  Revision  Changes    Path
  1.9       +12 -13    JBossCache/tests/functional/org/jboss/cache/loader/BdbjeTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: BdbjeTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/tests/functional/org/jboss/cache/loader/BdbjeTest.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -b -r1.8 -r1.9
  --- BdbjeTest.java	6 Sep 2006 15:30:57 -0000	1.8
  +++ BdbjeTest.java	12 Sep 2006 20:16:56 -0000	1.9
  @@ -35,7 +35,7 @@
    * directory.  Any scratch directory will do, but beware that all files in
    * the directory will be deleted by setUp().</p>
    *
  - * @version $Revision: 1.8 $
  + * @version $Revision: 1.9 $
    */
   public class BdbjeTest extends TestCase
   {
  @@ -235,7 +235,6 @@
         MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         /* Add three FQNs, middle FQN last. */
         doPutTests(new Fqn("key1"));
  @@ -257,7 +256,6 @@
         os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         stopLoader();
      }
  @@ -696,7 +694,6 @@
         MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         stopLoader();
      }
  @@ -1072,6 +1069,7 @@
   
         ByteArrayOutputStream baos = new ByteArrayOutputStream(1024);
         MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
  +      os.writeObject(StateTransferManager.STREAMING_DELIMETER_NODE);
         os.close();
   
         ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());
  @@ -1196,8 +1194,8 @@
         ByteArrayOutputStream baos = new ByteArrayOutputStream(1024);
         MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
  +      os.writeObject(StateTransferManager.STREAMING_DELIMETER_NODE);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());
         MarshalledValueInputStream is = new MarshalledValueInputStream(bais);
  @@ -1207,8 +1205,8 @@
         baos = new ByteArrayOutputStream(1024);
         os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
  +      os.writeObject(StateTransferManager.STREAMING_DELIMETER_NODE);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         bais = new ByteArrayInputStream(baos.toByteArray());
         is = new MarshalledValueInputStream(bais);
  @@ -1218,8 +1216,8 @@
         baos = new ByteArrayOutputStream(1024);
         os = new MarshalledValueOutputStream(baos);
         loader.loadEntireState(os);
  +      os.writeObject(StateTransferManager.STREAMING_DELIMETER_NODE);
         os.close();
  -      assertEquals(STREAM_HEADER_LENGTH, baos.size());
   
         assertEquals(null, loader.get(FQN));
   
  @@ -1247,6 +1245,7 @@
         /* Clear state. */
         baos = new ByteArrayOutputStream(1024);
         os = new MarshalledValueOutputStream(baos);
  +      os.writeObject(StateTransferManager.STREAMING_DELIMETER_NODE);
         os.close();
         bais = new ByteArrayInputStream(baos.toByteArray());
         is = new MarshalledValueInputStream(bais);