From: Clebert S. <csu...@jb...> - 2006-04-24 23:49:43
|
User: csuconic Date: 06/04/24 19:49:41 Modified: tests/org/jboss/serial/contribtests/customertest FileSystemResultKeeperDao.java TestCustomer.java Log: JBSER-60 - Improvements on sizing of streamed objects Revision Changes Path 1.4 +7 -7 jboss-serialization/tests/org/jboss/serial/contribtests/customertest/FileSystemResultKeeperDao.java (In the diff below, changes in quantity of whitespace are not shown.) Index: FileSystemResultKeeperDao.java =================================================================== RCS file: /cvsroot/jboss/jboss-serialization/tests/org/jboss/serial/contribtests/customertest/FileSystemResultKeeperDao.java,v retrieving revision 1.3 retrieving revision 1.4 diff -u -b -r1.3 -r1.4 --- FileSystemResultKeeperDao.java 24 Feb 2006 21:47:20 -0000 1.3 +++ FileSystemResultKeeperDao.java 24 Apr 2006 23:49:41 -0000 1.4 @@ -30,13 +30,13 @@ /** * @author prashantp - * @version $Revision: 1.3 $ + * @version $Revision: 1.4 $ */ public class FileSystemResultKeeperDao { private static Random random = new Random(); - public File keepResult(Object result, boolean useJBS, boolean useDirect) { + public File keepResult(Object result, boolean useJBS, boolean useInDirect) { FileOutputStream fos = null; BufferedOutputStream bufStream = null; @@ -55,9 +55,9 @@ oos = new ObjectOutputStream(bufStream); } - if (useDirect) + if (useInDirect) { - ((JBossObjectOutputStream)oos).writeObjectDirect(result); + ((JBossObjectOutputStream)oos).writeObjectUsingDataContainer(result); } else { oos.writeObject(result); @@ -88,7 +88,7 @@ return File.createTempFile("serializationTest",".ser"); } - public Object getResult(File file, boolean useJBS, boolean useDirect) { + public Object getResult(File file, boolean useJBS, boolean useInDirect) { FileInputStream fis = null; BufferedInputStream bufStream = null; ObjectInputStream oos = null; @@ -104,9 +104,9 @@ } Object obj = null; - if (useDirect) + if (useInDirect) { - obj = ((JBossObjectInputStream)oos).readObjectDirect(); + obj = ((JBossObjectInputStream)oos).readObjectUsingDataContainer(); } else { obj = oos.readObject(); 1.4 +22 -1 jboss-serialization/tests/org/jboss/serial/contribtests/customertest/TestCustomer.java (In the diff below, changes in quantity of whitespace are not shown.) Index: TestCustomer.java =================================================================== RCS file: /cvsroot/jboss/jboss-serialization/tests/org/jboss/serial/contribtests/customertest/TestCustomer.java,v retrieving revision 1.3 retrieving revision 1.4 diff -u -b -r1.3 -r1.4 --- TestCustomer.java 18 Apr 2006 18:42:41 -0000 1.3 +++ TestCustomer.java 24 Apr 2006 23:49:41 -0000 1.4 @@ -27,7 +27,7 @@ import java.io.File; /** - * $Id: TestCustomer.java,v 1.3 2006/04/18 18:42:41 csuconic Exp $ + * $Id: TestCustomer.java,v 1.4 2006/04/24 23:49:41 csuconic Exp $ * * @author <a href="mailto:cle...@jb...">Clebert Suconic</a> */ @@ -54,6 +54,27 @@ System.out.println("Time to read = " + (finishTimeRead - startTimeRead)); } + public void test100JBossIndirect() throws Exception { + System.out.println(); + System.out.println("test-100-jboss-serialization-indiret"); + Object objToWrite = ModelServer.getInsuranceModelHundredCustomers(); + + FileSystemResultKeeperDao dao = new FileSystemResultKeeperDao(); + + long startTimeWrite = System.currentTimeMillis(); + File fileWritten = dao.keepResult(objToWrite, true, true); + long finishTimeWrite = System.currentTimeMillis(); + + System.out.println("Time to write = " + (finishTimeWrite - startTimeWrite)); + + + long startTimeRead = System.currentTimeMillis(); + Object objRead = dao.getResult(fileWritten, true, true); + long finishTimeRead = System.currentTimeMillis(); + + System.out.println("Time to read = " + (finishTimeRead - startTimeRead)); + } + public void test100Java() throws Exception { System.out.println(); System.out.println("test-100-JavaSerialization-1.5"); |