ulfgebhardt/college
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed whom 2 send request

Browse Source
This commit is contained in:
Ulf Gebhardt 2013-02-11 12:08:47 +01:00
parent 2ef74f7707
commit 54d7791990
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ws2012/P2P/uebungen/11/src/node/Node.java
View File

@ -52,6 +52,8 @@ public class Node {
private InetSocketAddress address;
private DatagramChannel channel;
public NodeIdentifier lastlookup = null;
private Map<Identifier, List<Ack>> rpcs = new HashMap<Identifier, List<Ack>>();
private Map<Identifier, Identifier> values = new HashMap<Identifier, Identifier>();
@ -227,9 +229,12 @@ public class Node {
public void sendDataReq(FileIdentifier fileID){
//TODO
String id = "128";
NodeIdentifier receiver = new NodeIdentifier(8, id.getBytes(), new InetSocketAddress("localhost", INITIAL_PORT));
send(receiver, MessageType.DATA_REQ, fileID.getBytes(), true, null);
if(lastlookup == null){
new Exception("lookup first!").printStackTrace();
return;}
//String id = "128";
//NodeIdentifier receiver = new NodeIdentifier(8, id.getBytes(), new InetSocketAddress("localhost", INITIAL_PORT));
send(lastlookup, MessageType.DATA_REQ, fileID.getBytes(), true, null);
}
public void sendData(NodeIdentifier receiver, Identifier fileID) {

3
ws2012/P2P/uebungen/11/src/node/UDPHandler.java
View File

@ -196,6 +196,7 @@ public class UDPHandler implements Runnable {
private void receiveFoundValue(NodeIdentifier fromID, Identifier rpcID) {
Identifier idToFind = getIDFromBuffer();
node.lastlookup = fromID;
// TODO Auto-generated method stub
// Node kontaktieren, damit Datei gesendet werden kann.
@ -254,7 +255,7 @@ public class UDPHandler implements Runnable {
//TODO Reihenfolge!!!
file += chunklist.get(fid).get(i);
}
//node.store(fid);
node.store(fid);
node.storeData(fid, file);
chunklist.remove(fid);
LOGGER.log(Level.INFO,"FILE DATA: "+file);