1 files changed, 41 insertions, 0 deletions
diff --git a/statserver/src/main/java/com/orbekk/stats/Experiment1Impl.java b/statserver/src/main/java/com/orbekk/stats/Experiment1Impl.java
new file mode 100644
index 0000000..1ec4ff3
--- /dev/null
+++ b/statserver/src/main/java/com/orbekk/stats/Experiment1Impl.java
@@ -0,0 +1,41 @@
+package com.orbekk.stats;
+
+import java.io.FileNotFoundException;
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.List;
+
+import com.google.protobuf.RpcCallback;
+import com.google.protobuf.RpcController;
+import com.orbekk.stats.Experiments.Empty;
+import com.orbekk.stats.Experiments.Experiment1;
+import com.orbekk.stats.Experiments.SimpleTiming;
+
+public class Experiment1Impl extends Experiment1 {
+    List<SimpleTiming> samples = new ArrayList<SimpleTiming>();
+    
+    @Override
+    public synchronized void registerSample(RpcController controller, SimpleTiming request,
+            RpcCallback<Empty> done) {
+        samples.add(request);
+        done.run(Empty.getDefaultInstance());
+    }
+    
+    public void writeSamples(String filename) {
+        PrintWriter printer = null;
+        try {
+            printer = new PrintWriter(filename);
+            System.out.println("Writing results to " + filename);
+            printer.println("# Automatically generated by Experiment1Impl.java");
+            for (SimpleTiming timing : samples) {
+                printer.println(timing);
+            }
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } finally {
+            if (printer != null) {
+                printer.close();
+            }
+        }
+    }
+}