FileIdentifier class isnt really needed, fixed it. It has to be deleted, dont know how to do it atm :)
This commit is contained in:
parent
ab8030bd71
commit
41c5c62dc6
@ -125,7 +125,7 @@ public class Node {
|
||||
}
|
||||
}
|
||||
|
||||
void sendFindValue(NodeIdentifier receiver, FileIdentifier idToFind) {
|
||||
void sendFindValue(NodeIdentifier receiver, Identifier idToFind) {
|
||||
boolean successful = send(receiver, MessageType.FIND_VALUE,
|
||||
idToFind.getBytes(), true, null);
|
||||
|
||||
@ -173,7 +173,7 @@ public class Node {
|
||||
}
|
||||
}
|
||||
|
||||
public void sendStore(NodeIdentifier receiver, FileIdentifier fileID) {
|
||||
public void sendStore(NodeIdentifier receiver, Identifier fileID) {
|
||||
boolean successful = send(receiver, MessageType.STORE, fileID.getBytes(), true, null);
|
||||
|
||||
if (successful) {
|
||||
@ -313,13 +313,14 @@ public class Node {
|
||||
return routingTable.getEntries();
|
||||
}
|
||||
|
||||
public void StorePair(FileIdentifier key, NodeIdentifier id) {
|
||||
System.out.println("Key: " + key.getKey());
|
||||
System.out.println("Node: " + id.getAddress());
|
||||
public void StorePair(Identifier key, NodeIdentifier id) {
|
||||
System.out.println(values.size());
|
||||
System.out.println(key.toString());
|
||||
values.put(key, id);
|
||||
System.out.println(values.size());
|
||||
}
|
||||
|
||||
public boolean hasKey(FileIdentifier key) {
|
||||
public boolean hasKey(Identifier key) {
|
||||
return values.containsKey(key);
|
||||
}
|
||||
|
||||
|
||||
@ -218,7 +218,7 @@ public class UDPHandler implements Runnable {
|
||||
private void receiveStore(NodeIdentifier fromID, Identifier rpc_id) {
|
||||
//TODO Cast geht an dieser stelle nicht, getIDFromBuffer() müsste man für
|
||||
// FileID implementieren.
|
||||
FileIdentifier fileID = (FileIdentifier) getIDFromBuffer();
|
||||
Identifier fileID = getIDFromBuffer();
|
||||
|
||||
node.StorePair(fileID, fromID);
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user