You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by mb...@apache.org on 2007/04/17 14:59:28 UTC

svn commit: r529586 - /incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java

Author: mbaessler
Date: Tue Apr 17 05:59:27 2007
New Revision: 529586

URL: http://svn.apache.org/viewvc?view=rev&rev=529586
Log:
UIMA-351

change CAS serialization code

JIRA ticket https://issues.apache.org/jira/browse/UIMA-351

Modified:
    incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java

Modified: incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java
URL: http://svn.apache.org/viewvc/incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java?view=diff&rev=529586&r1=529585&r2=529586
==============================================================================
--- incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java (original)
+++ incubator/uima/uimaj/trunk/uimaj-core/src/main/java/org/apache/uima/analysis_engine/impl/PearAnalysisEngineWrapper.java Tue Apr 17 05:59:27 2007
@@ -287,21 +287,6 @@
     ByteArrayInputStream fis = new ByteArrayInputStream(fos.toByteArray());
     Serialization.deserializeCAS(this.cas, fis);
 
-//    try {
-//      ByteArrayOutputStream byteOut = new ByteArrayOutputStream(aCAS.size());
-//      BufferedOutputStream bufOut = new BufferedOutputStream(byteOut);
-//      CASSerializer serializer = new CASSerializer();
-//      serializer.addCAS((CASImpl) aCAS, bufOut);
-//      bufOut.flush();
-//      byte[] content = byteOut.toByteArray();
-//      bufOut.close();
-//      aCAS.reset();
-//      BufferedInputStream bufIn = new BufferedInputStream(new ByteArrayInputStream(content));
-//      Serialization.deserializeCAS(this.cas, bufIn);
-//    } catch (IOException ex) {
-//      throw new AnalysisEngineProcessException(ex);
-//    }
-
     // DEBUG INFORMATION
     // serialize1.stop();
     // processing.start();
@@ -327,20 +312,10 @@
     // ((CASImpl) aCAS).reinit(serializer);
 
     // FASTEST CAS SERIALIZATION/DESERIALIZATION
-    try {
-      ByteArrayOutputStream byteOut = new ByteArrayOutputStream(this.cas.size());
-      BufferedOutputStream bufOut = new BufferedOutputStream(byteOut);
-      CASSerializer serializer = new CASSerializer();
-      serializer.addCAS((CASImpl) this.cas, bufOut);
-      bufOut.flush();
-      byte[] content = byteOut.toByteArray();
-      bufOut.close();
-      aCAS.reset();
-      BufferedInputStream bufIn = new BufferedInputStream(new ByteArrayInputStream(content));
-      Serialization.deserializeCAS(aCAS, bufIn);
-    } catch (IOException ex) {
-      throw new AnalysisEngineProcessException(ex);
-    }
+    fos = new ByteArrayOutputStream();
+    Serialization.serializeCAS(this.cas, fos);
+    fis = new ByteArrayInputStream(fos.toByteArray());
+    Serialization.deserializeCAS(aCAS, fis);
 
     // DEBUG INFORMATION
     // serialize2.stop();