Add "size" property for read tests (not yet sure if I like it or not)

Author: cowtowncoder

src/main/java/com/fasterxml/jackson/perf/AuxStateSize.java

@@ -0,0 +1,65 @@
+package com.fasterxml.jackson.perf;
+
+import org.openjdk.jmh.annotations.AuxCounters;
+import org.openjdk.jmh.annotations.Level;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.infra.IterationParams;
+import org.openjdk.jmh.runner.IterationType;
+
+/**
+ * Simple container for additional state: size of input/output.
+ * Notes
+ *<ul>
+ * <li>Type needs to be {@code EVENTS} so as not to be normalized to
+ * runtime or iterations.<li>
+ * <li>Ugly state-handling was the only way I could figure out how to
+ *  avoid either accumulation of size values with {@code EVENTS} or
+ *  normalization attempts with {@code OPERATIONS}.
+ *  </li>
+ *</ul>
+ */
+@AuxCounters(AuxCounters.Type.EVENTS)
+@State(Scope.Thread)
+public class AuxStateSize
+{
+    /**
+     * Actual size we will report once (and only once!) during
+     * the first run after warmup(s).
+     */
+    public int size;
+
+    /**
+     * Simple state to indicate last iteration type we saw
+     */
+    private IterationType lastType;
+
+    /**
+     * Flag that indicates that we should set size just once
+     */
+    private boolean shouldSetSize;
+
+    // Choice is actually clear: "Invocation" way too often, but
+    // "Trial" not often enough (since it is just once before Warmup).
+    @Setup(Level.Iteration)
+    public void clearSize(IterationParams iterParams) {
+        size = 0;
+        final IterationType nextType = iterParams.getType();
+
+        // Transition...
+        if (nextType != lastType) {
+            if (nextType == IterationType.MEASUREMENT) {
+                shouldSetSize = true;
+            }
+            lastType = nextType;
+        }
+    }
+
+    public void set(int size) {
+        if (shouldSetSize) {
+            shouldSetSize = false;
+            this.size = size;
+        }
+    }
+}

src/main/java/com/fasterxml/jackson/perf/ReadPerfBaseBasicJackson.java

@@ -4,6 +4,8 @@
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Mode;
 import org.openjdk.jmh.annotations.OutputTimeUnit;
 import org.openjdk.jmh.infra.Blackhole;
 
@@ -42,10 +44,15 @@ protected ReadPerfBaseBasicJackson(Class<T> type,
      */
 
     @Benchmark
+    @BenchmarkMode(Mode.Throughput)
     @OutputTimeUnit(TimeUnit.SECONDS)
     @Override
-    public void readPojoMediaItem(Blackhole bh) throws Exception {
-        bh.consume(read(MINIMAL_CONV.mediaItemAsBytes(), MEDIA_ITEM_READER));
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size)
+        throws Exception
+    {
+        final byte[] input = MINIMAL_CONV.mediaItemAsBytes();
+        size.set(input.length);
+        bh.consume(read(input, MEDIA_ITEM_READER));
     }
 
     /*

src/main/java/com/fasterxml/jackson/perf/ReadPerfTestBasic.java

@@ -4,5 +4,6 @@
 
 public interface ReadPerfTestBasic
 {
-    public void readPojoMediaItem(Blackhole bh) throws Exception;
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size)
+        throws Exception;
 }

src/main/java/com/fasterxml/jackson/perf/json/JacksonJrStdReadVanilla.java

@@ -7,6 +7,7 @@
 import org.openjdk.jmh.infra.Blackhole;
 
 import com.fasterxml.jackson.jr.ob.JSON;
+import com.fasterxml.jackson.perf.AuxStateSize;
 import com.fasterxml.jackson.perf.ReadPerfTestBasic;
 import com.fasterxml.jackson.perf.model.MediaItem;
 import com.fasterxml.jackson.perf.model.MediaItems;
@@ -34,7 +35,8 @@ public JacksonJrStdReadVanilla() { }
 
     @Benchmark
     @Override
-    public void readPojoMediaItem(Blackhole bh) throws Exception {
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size) throws Exception {
+        size.set(_mediaItemBytes.length);
         bh.consume(read(_mediaItemBytes));
     }
 

src/main/java/com/fasterxml/jackson/perf/json/JacksonJrWastefulReadVanilla.java

@@ -32,8 +32,10 @@ public JacksonJrWastefulReadVanilla() {
     }
 
     @Override
-    public void readPojoMediaItem(Blackhole bh) throws Exception {
-        bh.consume(read(MINIMAL_CONV.mediaItemAsBytes()));
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size) throws Exception {
+        final byte[] input = MINIMAL_CONV.mediaItemAsBytes();
+        size.set(input.length);
+        bh.consume(read(input));
     }
 
     protected Object read(byte[] data) throws Exception {

src/main/java/com/fasterxml/jackson/perf/json/JsonStringReadVanilla.java

@@ -58,8 +58,10 @@ protected Object read(String input, ObjectReader reader) throws IOException {
     @Benchmark
     @OutputTimeUnit(TimeUnit.SECONDS)
     @Override
-    public void readPojoMediaItem(Blackhole bh) throws Exception {
-        bh.consume(read(_converter.mediaItemAsString(), MEDIA_ITEM_READER));
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size) throws Exception {
+        final String input = _converter.mediaItemAsString();
+        size.set(input.length());
+        bh.consume(read(input, MEDIA_ITEM_READER));
     }
 
     /*

src/main/java/com/fasterxml/jackson/perf/json/JsonWastefulReadVanilla.java

@@ -10,6 +10,7 @@
 
 import com.fasterxml.jackson.core.JsonFactory;
 import com.fasterxml.jackson.databind.*;
+import com.fasterxml.jackson.perf.AuxStateSize;
 import com.fasterxml.jackson.perf.ReadPerfBaseBasicJackson;
 import com.fasterxml.jackson.perf.data.InputConverter;
 import com.fasterxml.jackson.perf.model.MediaItem;
@@ -36,8 +37,10 @@ public JsonWastefulReadVanilla() {
     }
 
     @Override
-    public void readPojoMediaItem(Blackhole bh) throws Exception {
-        bh.consume(read(MINIMAL_CONV.mediaItemAsString()));
+    public void readPojoMediaItem(Blackhole bh, AuxStateSize size) throws Exception {
+        final String input = MINIMAL_CONV.mediaItemAsString();
+        size.set(input.length());
+        bh.consume(read(input));
     }
 
     @Benchmark

src/test/java/com/fasterxml/jackson/perf/data/InputDataTest.java

@@ -7,7 +7,9 @@ public class InputDataTest extends TestCase
     public void testByteInput() throws Exception
     {
         for (InputData data : InputData.values()) {
-            assertNotNull(data.bytes());
+            final byte[] bytes = data.bytes();
+            assertNotNull(bytes);
+//            System.out.println("Format '"+data.name()+": "+bytes.length+" bytes");
         }
     }
 }