diff --git a/ws2012/P2P/uebungen/4/src/network/Network.java b/ws2012/P2P/uebungen/4/src/Main.java similarity index 58% rename from ws2012/P2P/uebungen/4/src/network/Network.java rename to ws2012/P2P/uebungen/4/src/Main.java index bbba1c04..abffa821 100644 --- a/ws2012/P2P/uebungen/4/src/network/Network.java +++ b/ws2012/P2P/uebungen/4/src/Main.java @@ -1,5 +1,3 @@ -package network; - import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; @@ -7,9 +5,9 @@ import java.util.HashMap; import java.util.Map; import java.util.logging.LogManager; -import peer.Node; +import node.Node; -public class Network { +public class Main { public static Map nodes = new HashMap(); @@ -32,10 +30,7 @@ public class Network { e.printStackTrace(); } - // int delay = 1000; - - Node a = new Node(); - nodes.put("a", a); + nodes.put("a", new Node()); BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); String s; @@ -65,47 +60,5 @@ public class Network { System.out.println("No such node."); } } - - // try { - // Node b = a.spawn(); - // Thread.sleep(delay); - // - // Node c = a.spawn(); - // Thread.sleep(delay); - // - // Node d = a.spawn(); - // Thread.sleep(delay); - // - // // Node ba = b.spawn(); - // // Thread.sleep(delay); - // // - // // Node bb = b.spawn(); - // // Thread.sleep(delay); - // // - // // Node bc = b.spawn(); - // // Thread.sleep(delay); - // // - // // Node bd = b.spawn(); - // // Thread.sleep(delay); - // // - // // Node be = b.spawn(); - // // Thread.sleep(delay); - // - // a.leave(); - // Thread.sleep(delay); - // - // b.leave(); - // Thread.sleep(delay); - // - // c.leave(); - // Thread.sleep(delay); - // - // d.leave(); - // - // } catch (IOException e) { - // e.printStackTrace(); - // } catch (InterruptedException e) { - // e.printStackTrace(); - // } } -} +} \ No newline at end of file diff --git a/ws2012/P2P/uebungen/4/src/common/MessageType.java b/ws2012/P2P/uebungen/4/src/node/MessageType.java similarity index 93% rename from ws2012/P2P/uebungen/4/src/common/MessageType.java rename to ws2012/P2P/uebungen/4/src/node/MessageType.java index 3f2dbe8e..8637a0bf 100644 --- a/ws2012/P2P/uebungen/4/src/common/MessageType.java +++ b/ws2012/P2P/uebungen/4/src/node/MessageType.java @@ -1,4 +1,4 @@ -package common; +package node; public class MessageType { public final static byte INVITE = 7; diff --git a/ws2012/P2P/uebungen/4/src/peer/Node.java b/ws2012/P2P/uebungen/4/src/node/Node.java similarity index 94% rename from ws2012/P2P/uebungen/4/src/peer/Node.java rename to ws2012/P2P/uebungen/4/src/node/Node.java index 6f549ba5..f10a7a2e 100644 --- a/ws2012/P2P/uebungen/4/src/peer/Node.java +++ b/ws2012/P2P/uebungen/4/src/node/Node.java @@ -1,4 +1,4 @@ -package peer; +package node; import java.io.IOException; import java.net.InetSocketAddress; @@ -9,8 +9,6 @@ import java.util.ArrayList; import java.util.List; import java.util.logging.Logger; -import common.MessageType; - public class Node { private final static Logger LOGGER = Logger.getLogger(Node.class.getName()); @@ -108,7 +106,6 @@ public class Node { putAddrInBuf(buf, neighbors.get(j)); channel.send(buf, neighbors.get(i)); } catch (IOException e) { - // TODO Auto-generated catch block e.printStackTrace(); } } @@ -136,10 +133,6 @@ public class Node { } } - public boolean hasNeighbors() { - return (this.neighbors.size() > 0); - } - public boolean hasNeighbor(SocketAddress adr) { for (SocketAddress n : neighbors) { if (n.toString().equals(adr.toString())) { @@ -193,7 +186,7 @@ public class Node { case MessageType.NEW_NEIGHBOR: StringBuilder theAddr = new StringBuilder(); - // Read 4 Bytes and 1 Int + // Read 4 Bytes and 1 int for (int i = 0; i < 4; i++) { theAddr.append(buf.get()); if (i < 3) @@ -213,10 +206,6 @@ public class Node { + receivedFrom.toString() + " received new neighbor:" + new_neighbor.toString()); - - // TODO: maybe send PING to new neighbor and expect - // wait to get a PONG - break; default: @@ -224,7 +213,6 @@ public class Node { + " received unknown command from " + receivedFrom.toString() + ": " + messageType + new String(buf.array())); - } } else { try { @@ -244,4 +232,4 @@ public class Node { running = false; } } -} +} \ No newline at end of file