summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/Client.java
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-15 18:47:27 +0100
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-15 18:47:27 +0100
commit6f58c3a3ce15289e559360330896cfb0cc22ae4d (patch)
treeeb227626101389495b8a7351da69c73290641505 /same/src/main/java/com/orbekk/same/Client.java
parent043dc32807afc0e82b3b89e99bc4eea254fa9062 (diff)
Move old SameService files out of the way.
Diffstat (limited to 'same/src/main/java/com/orbekk/same/Client.java')
-rw-r--r--same/src/main/java/com/orbekk/same/Client.java62
1 files changed, 0 insertions, 62 deletions
diff --git a/same/src/main/java/com/orbekk/same/Client.java b/same/src/main/java/com/orbekk/same/Client.java
deleted file mode 100644
index 11a7449..0000000
--- a/same/src/main/java/com/orbekk/same/Client.java
+++ /dev/null
@@ -1,62 +0,0 @@
-package com.orbekk.same;
-
-import com.googlecode.jsonrpc4j.JsonRpcServer;
-import com.orbekk.net.HttpUtil;
-import org.eclipse.jetty.server.Server;
-
-public class Client {
-
- public static void main(String[] args) {
- if (args.length < 4) {
- System.err.println("Arguments: port clientId thisNetworkName " +
- "remoteNetworkAddr");
- System.exit(1);
- }
- int port = Integer.parseInt(args[0]);
- String clientId = args[1];
- String networkName = args[2];
- String remoteAddr = args[3];
-
- ConnectionManagerImpl connections = new ConnectionManagerImpl();
-
- SameState sameState = new SameState(networkName, clientId,
- connections);
- sameState.start();
-
- SameServiceImpl service = new SameServiceImpl(sameState);
- JsonRpcServer jsonServer = new JsonRpcServer(service,
- SameService.class);
-
- Server server = new Server(port);
- RpcHandler rpcHandler = new RpcHandler(jsonServer, sameState);
- server.setHandler(rpcHandler);
-
- try {
- server.start();
- } catch (Exception e) {
- System.out.println("Could not start jetty server.");
- e.printStackTrace();
- }
-
- while (sameState.getUrl() == null) {
- HttpUtil.sendHttpRequest(remoteAddr + "ping?port=" + port);
- try {
- Thread.sleep(500);
- } catch (InterruptedException e) {
- // Ignore interrupt in wait loop.
- }
- }
-
- SameService remoteService = connections.getConnection(remoteAddr);
- remoteService.notifyNetwork("NoNetwork");
- remoteService.participateNetwork("FirstNetwork",
- sameState.getClientId(), sameState.getUrl());
-
- try {
- server.join();
- } catch (InterruptedException e) {
- System.out.println("Interrupt");
- }
-
- }
-}