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

updated send date stuff

Browse Source
This commit is contained in:
Michael Scholz 2013-02-10 20:41:42 +01:00
parent f1c1f3396b
commit 31dec13fc3
3 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ws2012/P2P/uebungen/11/src/CLI.java
View File

@ -1,7 +1,11 @@
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.nio.MappedByteBuffer;
import java.util.logging.LogManager;
import node.Identifier;
@ -28,6 +32,7 @@ public class CLI {
String[] splitted = s.split(" ");
String cmd = splitted[0];
String nodeID = splitted[1];
switch (cmd) {
case "status":
@ -41,6 +46,19 @@ public class CLI {
Identifier fileIDToFind = new Identifier(8, Identifier.getStaticIdentifier(8).getBytes());
node.findValue(fileIDToFind);
break;
case "data":
File file = new File("/Users/Michael/Uni/allgemeiner Git/college/ws2012/P2P/uebungen/11/testfile.txt");
FileWriter fw = new FileWriter(file, true);
fw.write("ichbininhalteinesfiles");
fw.flush();
fw.close();
//node.storeFile(file);
NodeIdentifier nodeIdenti = new NodeIdentifier(8,
nodeID.getBytes(), new InetSocketAddress(
"127.0.0.1", 50000));
node.sendFile(nodeIdenti, file);
break;
case "leave":
node.leave();
break;

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

@ -62,7 +62,7 @@ public class Node {
private Identifier nodeID = Identifier.getRandomIdentifier(ID_BITS);
private IRoutingTable routingTable = new RoutingTableImpl(BUCKET_SIZE, this);
private ArrayList<File> files;
private ArrayList<File> files = new ArrayList<File>();
public Node() {
System.setProperty("java.net.preferIPv4Stack", "true");
@ -435,8 +435,9 @@ public class Node {
public void storeFile(File file) {
files.add(file);
}
private void sendFile(NodeIdentifier nodeID, File file) {
public void sendFile(NodeIdentifier nodeID, File file) {
// calculate chunk size = BUFFER - ID_BITS - fileID - eofChar
int CHUNK_SIZE = BUFFER_SIZE - ID_BITS - 10 - 1;

1
ws2012/P2P/uebungen/11/testfile.txt Normal file
View File

@ -0,0 +1 @@
ichbininhalteinesfilesichbininhalteinesfilesichbininhalteinesfilesichbininhalteinesfilesichbininhalteinesfiles