diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-21 13:41:53 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-21 13:41:53 +0200 |
commit | c8693857ceaf837cebf63a3e2d5e73dbfbfafd26 (patch) | |
tree | a8a1c05d7c7982b2d695f5acfc1902e6638a8e5d /statserver/src/main/java/com/orbekk/stats/Server.java | |
parent | ffc59108e61d46aabba25ed337d72d6908b7c874 (diff) |
Add stats server.
Diffstat (limited to 'statserver/src/main/java/com/orbekk/stats/Server.java')
-rw-r--r-- | statserver/src/main/java/com/orbekk/stats/Server.java | 29 |
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())); + } +} |