diff --git a/ws2012/P2P/uebungen/4/src/node/Node.java b/ws2012/P2P/uebungen/4/src/node/Node.java index ddb5bcec..d25f2823 100644 --- a/ws2012/P2P/uebungen/4/src/node/Node.java +++ b/ws2012/P2P/uebungen/4/src/node/Node.java @@ -188,7 +188,7 @@ public class Node { } protected void forwardBroadcast(int packet_id, byte command, byte[] data, - SocketAddress originalSender) { + SocketAddress receivedFrom) { ByteBuffer buffer = ByteBuffer.allocate(BUF_SIZE); buffer.put(MessageType.BROADCAST); @@ -205,7 +205,7 @@ public class Node { buffer.flip(); for (SocketAddress n : neighbors) { - if (!n.equals(originalSender)) { + if (!n.equals(receivedFrom)) { try { channel.send(buffer, n); buffer.clear(); diff --git a/ws2012/P2P/uebungen/4/src/node/UDPHandler.java b/ws2012/P2P/uebungen/4/src/node/UDPHandler.java index cc307296..be06d4e7 100644 --- a/ws2012/P2P/uebungen/4/src/node/UDPHandler.java +++ b/ws2012/P2P/uebungen/4/src/node/UDPHandler.java @@ -84,7 +84,7 @@ public class UDPHandler implements Runnable { // "originalSender" and "data" are the same, because the only // data of a STATUS broadcast is the original sender node.forwardBroadcast(packet_id, command, - BufferUtil.addrToBytes(originalSender), originalSender); + BufferUtil.addrToBytes(originalSender), from); LOGGER.log( Level.INFO, @@ -111,7 +111,8 @@ public class UDPHandler implements Runnable { } private void receiveStatus(SocketAddress receivedFrom) { - LOGGER.info("Received status from " + receivedFrom.toString()); + LOGGER.log(Level.INFO, "{0}: Received status from {1}", + new Object[] { node.getName(), receivedFrom.toString() }); List neighbors = new ArrayList(); while (buf.hasRemaining()) {