added rpc-feature to store-function
This commit is contained in:
parent
2f4d364998
commit
61dc4a1a32
@ -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() {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user