Add stats server.

1 files changed, 29 insertions, 0 deletions

diff --git a/statserver/src/main/java/com/orbekk/stats/Server.java b/statserver/src/main/java/com/orbekk/stats/Server.java
new file mode 100644
index 0000000..4f5ff32
--- /dev/null
+++ b/statserver/src/main/java/com/orbekk/stats/Server.java
@@ -0,0 +1,29 @@
+package com.orbekk.stats;
+
+import com.orbekk.protobuf.SimpleProtobufServer;
+
+public class Server {
+    final Experiment1Impl exp1 = new Experiment1Impl();
+    
+    public static void main(String[] args) {
+        new Server().run();
+    }
+    
+    public void run() {
+        addShutdownHook();
+        SimpleProtobufServer server = SimpleProtobufServer.create(
+                Common.PORT);
+        server.registerService(exp1);
+        System.out.println("Waiting for samples...");
+        server.start();
+    }
+    
+    public void addShutdownHook() {
+        class ShutdownTask implements Runnable {
+            @Override public void run() {
+                exp1.writeSamples("experiment1.data");
+            }
+        }
+        Runtime.getRuntime().addShutdownHook(new Thread(new ShutdownTask()));
+    }
+}