From 61dc4a1a3220ec6e67ccf3546c9fa2f33ef417b4 Mon Sep 17 00:00:00 2001 From: Denis Date: Sun, 10 Feb 2013 13:43:08 +0100 Subject: [PATCH] added rpc-feature to store-function --- ws2012/P2P/uebungen/11/src/node/UDPHandler.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/ws2012/P2P/uebungen/11/src/node/UDPHandler.java b/ws2012/P2P/uebungen/11/src/node/UDPHandler.java index 9e236c60..584a3e37 100644 --- a/ws2012/P2P/uebungen/11/src/node/UDPHandler.java +++ b/ws2012/P2P/uebungen/11/src/node/UDPHandler.java @@ -219,12 +219,14 @@ public class UDPHandler implements Runnable { node.sendClosestNodesTo(fromID, idToFind, rpc_id); } - private void receiveStore(NodeIdentifier fromID, Identifier rpc_id) { + private void receiveStore(NodeIdentifier fromID, Identifier rpcID) { Identifier fileID = getIDFromBuffer(); - System.out.println("Received store from " + fromID.toString()); + LOGGER.log(Level.INFO, "Received [STORE{0}] from Node {1}", + new Object[] { fileID, fromID }); node.storePair(fileID, fromID); + node.receivedRPC(fromID, rpcID); } public void terminate() {