Migrated source code from Simantics SVN

[simantics/platform.git] / bundles / org.simantics.databoard / testcases / org / simantics / databoard / tests / TestBinaryMemory.java

diff --git a/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestBinaryMemory.java b/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestBinaryMemory.java
new file mode 100644 (file)
index 0000000..9102523
--- /dev/null
+++ b/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestBinaryMemory.java
@@ -0,0 +1,178 @@
+/*******************************************************************************\r
+ *  Copyright (c) 2010 Association for Decentralized Information Management in\r
+ *  Industry THTH ry.\r
+ *  All rights reserved. This program and the accompanying materials\r
+ *  are made available under the terms of the Eclipse Public License v1.0\r
+ *  which accompanies this distribution, and is available at\r
+ *  http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ *  Contributors:\r
+ *      VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.databoard.tests;
+
+import java.io.FileNotFoundException;\r
+import java.io.IOException;\r
+\r
+import junit.framework.TestCase;\r
+\r
+import org.simantics.databoard.util.binary.BinaryMemory;\r
+import org.simantics.databoard.util.binary.BinaryReadable;\r
+import org.simantics.databoard.util.binary.BinaryWriteable;\r
+import org.simantics.databoard.util.binary.RandomAccessBinary;\r
+import org.simantics.databoard.util.binary.RandomAccessBinary.ByteSide;\r
+
+public class TestBinaryMemory extends TestCase {
+
+       public static final int ITERATIONS = 50;
+       RandomAccessBinary file;
+       
+       public void setUp() throws Exception {
+               file = new BinaryMemory(4096);
+       }
+       
+       public void tearDown() throws Exception {
+               file.close();
+       }
+       
+       public void testInsertRemove()
+       throws IOException
+       {
+               // Write 4 MB file
+               for (int i=0; i<1024*1024; i++)
+               {
+                       file.writeInt(i ^0x53);
+               }
+               file.flush();
+
+               int iterCount = 16;
+               long totInsertTime = 0;
+               long totRemoveTime = 0;
+               
+               for (int iter=0; iter<iterCount; iter++) {
+               // Verify content
+               // 1. half
+               file.position(0L);
+               for (int i=0; i<1024*1024; i++)
+                       assertEquals(i^0x53, file.readInt());
+               
+               // Add 256 kb at 2MB
+               System.gc();
+               long startTime = System.currentTimeMillis();
+               file.position(512*1024*4L);
+               file.insertBytes(256*1024, ByteSide.Left);
+               long elapsedTime = System.currentTimeMillis() - startTime;
+               totInsertTime += elapsedTime;
+               System.out.println("Insert 256kb in front of 2MB, time: "+elapsedTime);
+               
+               // Verify file size
+               assertEquals(4*1024*1024 + 256*1024, file.length()); 
+               
+               // Verify content
+               // 1. half
+               file.position(0);
+               for (int i=0; i<512*1024; i++)
+                       assertEquals(i^0x53, file.readInt());
+               // 2. half
+               file.position(512*1024*4+256*1024);
+               for (int i=512*1024; i<1024*1024; i++)
+                       assertEquals(i^0x53, file.readInt());
+
+               // Remove content
+               System.gc();
+               startTime = System.currentTimeMillis();
+               file.position(512*1024*4);
+               file.removeBytes(256*1024, ByteSide.Left);
+               elapsedTime = System.currentTimeMillis() - startTime;
+               totRemoveTime += elapsedTime;
+               System.out.println("remove 256kb in front of 2,25MB, time: "+elapsedTime);
+               
+               // Verify file size
+               assertEquals(4*1024*1024, file.length());
+               
+               // Verify content
+               // 1. half
+               file.position(0);
+               for (int i=0; i<1024*1024; i++)
+                       assertEquals(i^0x53, file.readInt());
+               }
+
+               System.out.println("Average insert time: " + totInsertTime / iterCount);
+               System.out.println("Average remove time: " + totRemoveTime / iterCount);
+       }
+       
+       public void testWriteRead() 
+       throws FileNotFoundException, IOException 
+       {               
+               long time4 = measureWrite(file);
+               System.out.println();
+               System.out.println("Write Time : "+time4);
+
+               file.flush();
+               file.position(0);
+               
+               time4 = measureRead(file);                              
+               System.out.println("Read Time : "+time4);
+       }
+       
+       static long measureWrite(BinaryWriteable write) 
+       throws IOException
+       {               
+               System.gc();
+               byte[] data = new byte[1024];
+               for (int i=0; i<data.length; i++)
+                       data[i] = (byte) i;
+               
+               long startTime = System.currentTimeMillis();            
+               for (int iter=0; iter<ITERATIONS; iter++)
+               {
+                       if (iter % 10==0) System.out.print(".");
+                       for (int i=0; i<256; i++)
+                               write.write((byte)i);
+                       for (int i=0; i<256; i++)
+                               write.writeDouble(i);
+                       for (int i=0; i<256; i++)
+                               write.writeFloat(i);
+                       for (int i=0; i<256; i++)
+                               write.writeInt(i);
+                       for (int i=0; i<256; i++)
+                               write.writeShort((short)i);
+                       write.write(data);                      
+               }               
+               write.flush();
+               long elapsedTime = System.currentTimeMillis() - startTime;              
+               
+               return elapsedTime;
+       }
+       
+       static long measureRead(BinaryReadable read) 
+       throws IOException
+       {               
+               System.gc();
+               byte[] data = new byte[1024];
+               
+               long startTime = System.currentTimeMillis();            
+               for (int iter=0; iter<ITERATIONS; iter++)
+               {
+                       if (iter % 10==0) System.out.print(".");
+                       for (int i=0; i<256; i++) 
+                               assertEquals((byte) i, read.readByte());
+                       for (int i=0; i<256; i++)
+                               assertEquals((double) i, read.readDouble());
+                       for (int i=0; i<256; i++)
+                               assertEquals((float) i, read.readFloat());
+                       for (int i=0; i<256; i++)
+                               assertEquals((int) i, read.readInt());
+                       for (int i=0; i<256; i++)
+                               assertEquals((short) i, read.readShort());
+                       read.readFully(data);
+                       for (int i=0; i<data.length; i++)
+                               assertEquals(data[i], (byte) i);
+               }               
+               long elapsedTime = System.currentTimeMillis() - startTime;
+               
+               return elapsedTime;
+       }
+       
+}
+