BinaryXmlIOComparison.java

  1. package gov.usgs.earthquake.product.io;

  3. import gov.usgs.earthquake.product.Product;
  4. import gov.usgs.util.StreamUtils;

  6. import java.io.ByteArrayOutputStream;
  7. import java.io.File;
  8. import java.util.Date;

  10. /**
  11.  * Compare io times of XML and Binary product formats.
  12.  *
  13.  * All conversion is done in memory to try to balance the tests. All writes use
  14.  * a BinaryProductSource to keep the playing field level.
  15.  */
  16. public class BinaryXmlIOComparison {

  18.     /**
  19.      * Serializes product by streaming it to a handler
  20.      * @param source a productSource
  21.      * @param handler a productHandler
  22.      * @return Time it took to stream source to handler
  23.      * @throws Exception if error occurs
  24.      */
  25.     public static long timeSerializeProduct(final ProductSource source,
  26.             final ProductHandler handler) throws Exception {
  27.         Date start = new Date();
  28.         source.streamTo(handler);
  29.         Date end = new Date();
  30.         return end.getTime() - start.getTime();
  31.     }

  33.     /**
  34.      * Testing for class
  35.      * @param args CLI args
  36.      * @throws Exception if error occurs
  37.      */
  38.     public static void main(final String[] args) throws Exception {
  39.         int numRuns = 10;
  40.         testProductIO(
  41.                 ObjectProductHandler.getProduct(new BinaryProductSource(
  42.                         StreamUtils.getInputStream(new File(
  43.                                 "etc/test_products/se082311a/us_dyfi_se082311a_1314562782198.bin")))),
  44.                 numRuns);
  45.         testProductIO(
  46.                 ObjectProductHandler.getProduct(new BinaryProductSource(
  47.                         StreamUtils.getInputStream(new File(
  48.                                 "etc/test_products/usa00040xz/us_shakemap_usa00040xz_1287260900624.bin")))),
  49.                 numRuns);
  50.         testProductIO(
  51.                 ObjectProductHandler.getProduct(new BinaryProductSource(
  52.                         StreamUtils.getInputStream(new File(
  53.                                 "etc/test_products/usa00040xz/us_losspager_usa00040xz_1287260989064.bin")))),
  54.                 numRuns);
  55.     }

  57.     /**
  58.      * Tests product IO
  59.      * @param product Produc
  60.      * @param numRuns int
  61.      * @throws Exception if error occurs
  62.      */
  63.     public static void testProductIO(final Product product, int numRuns)
  64.             throws Exception {
  65.         System.err.println(product.getId().toString());
  66.         testXmlReads(product, numRuns);
  67.         testXmlWrites(product, numRuns);
  68.         testBinaryReads(product, numRuns);
  69.         testBinaryWrites(product, numRuns);
  70.         System.err.println();
  71.     }

  73.     /**
  74.      * Tests XML reading
  75.      * @param product a product
  76.      * @param numReads int
  77.      * @throws Exception if error occurs
  78.      */
  79.     public static void testXmlReads(final Product product, int numReads)
  80.             throws Exception {
  81.         // read product into memory
  82.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  83.         new ObjectProductSource(product).streamTo(new XmlProductHandler(baos));
  84.         byte[] bytes = baos.toByteArray();

  86.         long time = 0L;

  88.         for (int i = 0; i < numReads; i++) {
  89.             Date start = new Date();

  91.             // parse from memory
  92.             ObjectProductHandler.getProduct(new XmlProductSource(StreamUtils
  93.                     .getInputStream(bytes)));

  95.             Date end = new Date();
  96.             time += end.getTime() - start.getTime();
  97.         }

  99.         System.err.println("xml\tlength=" + bytes.length + ",\tnumReads="
  100.                 + numReads + ",\tread average=" + ((double) time / numReads));
  101.     }

  103.     /**
  104.      * Tests binary reading
  105.      * @param product a product
  106.      * @param numReads int
  107.      * @throws Exception if error occurs
  108.      */
  109.     public static void testBinaryReads(final Product product, int numReads)
  110.             throws Exception {
  111.         // read product into memory
  112.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  113.         new ObjectProductSource(product)
  114.                 .streamTo(new BinaryProductHandler(baos));
  115.         byte[] bytes = baos.toByteArray();

  117.         long time = 0L;

  119.         for (int i = 0; i < numReads; i++) {
  120.             Date start = new Date();

  122.             // parse from memory
  123.             ObjectProductHandler.getProduct(new BinaryProductSource(StreamUtils
  124.                     .getInputStream(bytes)));

  126.             Date end = new Date();
  127.             time += end.getTime() - start.getTime();
  128.         }

  130.         System.err.println("binary\tlength=" + bytes.length + ",\tnumReads="
  131.                 + numReads + ",\tread average=" + ((double) time / numReads));
  132.     }

  134.     /**
  135.      * Tests binary writes
  136.      * @param product a product
  137.      * @param numWrites int
  138.      * @throws Exception if error occurs
  139.      */
  140.     public static void testBinaryWrites(final Product product, int numWrites)
  141.             throws Exception {
  142.         // read product into memory
  143.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  144.         new ObjectProductSource(product)
  145.                 .streamTo(new BinaryProductHandler(baos));
  146.         byte[] bytes = baos.toByteArray();

  148.         long time = 0L;

  150.         for (int i = 0; i < numWrites; i++) {
  151.             baos.reset();
  152.             Date start = new Date();

  154.             // parse from memory
  155.             new BinaryProductSource(StreamUtils.getInputStream(bytes))
  156.                     .streamTo(new BinaryProductHandler(baos));

  158.             Date end = new Date();
  159.             time += end.getTime() - start.getTime();
  160.         }

  162.         System.err.println("binary\tlength=" + baos.toByteArray().length
  163.                 + ",\tnumWrites=" + numWrites + ",\twrite average="
  164.                 + ((double) time / numWrites));
  165.     }

  167.     /**
  168.      * tests xml writes
  169.      * @param product a product
  170.      * @param numWrites int
  171.      * @throws Exception if error occurs
  172.      */
  173.     public static void testXmlWrites(final Product product, int numWrites)
  174.             throws Exception {
  175.         // read product into memory
  176.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  177.         new ObjectProductSource(product)
  178.                 .streamTo(new BinaryProductHandler(baos));
  179.         byte[] bytes = baos.toByteArray();

  181.         long time = 0L;

  183.         for (int i = 0; i < numWrites; i++) {
  184.             baos.reset();
  185.             Date start = new Date();

  187.             // parse from memory
  188.             new BinaryProductSource(StreamUtils.getInputStream(bytes))
  189.                     .streamTo(new XmlProductHandler(baos));

  191.             Date end = new Date();
  192.             time += end.getTime() - start.getTime();
  193.         }

  195.         System.err.println("xml\tlength=" + baos.toByteArray().length
  196.                 + ",\tnumWrites=" + numWrites + ",\twrite average="
  197.                 + ((double) time / numWrites));
  198.     }

  200. }
Created with JaCoCo 0.8.8.202204050719