/ - Diff - sdis1819-t7g06 - FEUP Project Manager

     import Peers.Peer;
     import java.io.IOException;
     import java.io.Serializable;
     import java.net.*;
     import java.util.concurrent.TimeUnit;
     public class Channel implements Runnable {
     public class Channel implements Runnable, Serializable {
         Peer peer;
-...
             } catch (UnknownHostException e) {
                 e.printStackTrace();
+            }
-...
                 byte[] mes = message.messagePacket();
                 DatagramPacket data = new DatagramPacket(mes, mes.length, this.address, this.port);
                 System.out.println("Sending " + message.getType().toString() + " Packet");
                 socket.send(data);
             } catch (IOException e) {
                 e.printStackTrace();

src/compile.sh
	1	#!/usr/bin/env bash
	2	javac TestApp.java
	3	javac Peers/Peer.java

             try {
                 String head = buffer.readLine();
                 int size = head.length() + 4;
                 System.out.println("Size = " + size);
                 System.out.println("MSlength = " + messageLength);
                 this.body = new byte[messageLength - size];
                 System.arraycopy(data, size, this.body, 0, messageLength - size);
                 System.out.println("body size = " + this.body.length);
                 String[] l = head.split(" ");
                 ms(l);
-...
             } catch (IOException e) {
                 e.printStackTrace();
                 //e.printStackTrace();
+            }
+        }
-...
                 return messageByte;
             } catch (Exception e) {
                 e.printStackTrace();
                // e.printStackTrace();
+            }
             return null;
+        }

         public WorkMessage(DatagramPacket packet, Peer peer) {
             try {
                 this.packet = new Message(packet);
                 System.out.println("Received " + this.packet.getType().toString() + " Packet");
             } catch (Exception e) {
                 e.printStackTrace();
                 //e.printStackTrace();
+            }
             this.peer = peer;

src/Peers/Control.java
3	3	import Message.*;
4	4	import Storage.Chunk;
5	5
	6	import java.io.Serializable;
6	7	import java.util.*;
7	8	import java.util.concurrent.ConcurrentHashMap;
8	9	import java.util.concurrent.ConcurrentSkipListSet;
9	10	import java.util.concurrent.TimeUnit;
10	11
11	12
12		public class Control {
	13	public class Control implements Serializable {
13	14
14	15	// chunkNo + fileid, nº of stored
15	16	ConcurrentHashMap<String, Integer> storedMessages = new ConcurrentHashMap<>();
...	...
20	21	ConcurrentHashMap<String, ConcurrentSkipListSet<Chunk>> restoredChunks = new ConcurrentHashMap<>();
21	22
22	23
	24	ConcurrentHashMap<String, String> backedUpFiles = new ConcurrentHashMap<>();
	25
23	26	private Peer peer;
24	27
25	28	Control(Peer peer) {
...	...
51	54
52	55	} catch (Exception e) {
53	56
54		e.printStackTrace();
	57	// e.printStackTrace();
55	58	}
56	59
57	60	}
...	...
107	110	}
108	111	}
109	112	} catch (Exception e) {
110		e.printStackTrace();
	113	//e.printStackTrace();
111	114	}
112	115	}
113	116
...	...
170	173
171	174
172	175	}
	176
	177	public ConcurrentHashMap<String, String> getBackedUpFiles() {
	178	return backedUpFiles;
	179	}
	180
173	181	}

     package Peers;
     import java.io.FileOutputStream;
     import java.io.IOException;
     import java.io.ObjectOutputStream;
     import java.io.Serializable;
     import java.io.*;
     import java.rmi.RemoteException;
     import java.rmi.registry.LocateRegistry;
     import java.rmi.registry.Registry;
-...
         Control control;
         ConcurrentHashMap<String, String> backedUpFiles = new ConcurrentHashMap<>();
         public Peer(String version, String peerId, String remoteName, String mcAddr, int mcPort, String mdbAddr, int mdbPort, String mdrAddr, int mdrPort) {
-...
                 mc_channel = new Channel(mcAddr, mcPort, this);
                 mdb_channel = new Channel(mdbAddr, mdbPort, this);
                 mdr_channel = new Channel(mdrAddr, mdrPort, this);
                 this.control = new Control(this);
                 if(!loadStatus())
                     this.control = new Control(this);
                 // save data every 2 seconds
                 threadPool.scheduleAtFixedRate(() -> {
                     this.saveState();
                 }, 0, 2, TimeUnit.SECONDS);
             } catch (IOException e) {
                 e.printStackTrace();
                // e.printStackTrace();
+            }
-...
             Peer peer = null;
             try {
                 peer = new Peer(args[0], args[1], args[2], args[3], Integer.parseInt(args[4]), args[5], Integer.parseInt(args[6]), args[7], Integer.parseInt(args[8]));
                 Service serv = (Service) UnicastRemoteObject.exportObject(peer, 0);
                 Registry registry = LocateRegistry.getRegistry();
-...
             try {
                 peer.threadPool.awaitTermination(1, TimeUnit.DAYS);
             } catch (Exception e) {
                 e.printStackTrace();
               //  e.printStackTrace();
+            }
+        }
-...
             return control;
+        }
         public ConcurrentHashMap<String, String> getBackedUpFiles() {
             return backedUpFiles;
+        }
         private void saveState() {
             try {
                 FileOutputStream file = new FileOutputStream(Paths.get(System.getProperty("user.dir")).toString() + "/objs/");
                 ObjectOutputStream out = new ObjectOutputStream(file);
                 FileOutputStream fileCtrl = new FileOutputStream(Paths.get(System.getProperty("user.dir")).toString() + "/objs/" + id + "Ctrl.ser");
                 ObjectOutputStream out2 = new ObjectOutputStream(fileCtrl);
                 out2.writeObject(this.control);
                 out2.close();
                 fileCtrl.close();
             } catch (IOException e) {
                 e.printStackTrace();
                 new File(Paths.get(System.getProperty("user.dir")).toString() + "/objs").mkdir();
                 try {
                     new File(Paths.get(System.getProperty("user.dir")).toString() + "/objs/" + id + "Ctrl.ser").createNewFile();
                 } catch (IOException e1) {
                    // e1.printStackTrace();
+                }
                 //e.printStackTrace();
+            }
+        }
         private boolean loadStatus() {
             try {
                 FileInputStream fileCtrl = new FileInputStream(Paths.get(System.getProperty("user.dir")).toString() + "/objs/" + id + "Ctrl.ser");
                 ObjectInputStream obj2 = new ObjectInputStream(fileCtrl);
                 this.control = (Control) obj2.readObject();
                 obj2.close();
                 fileCtrl.close();
                 return true;
             } catch (Exception e) {
                 System.out.println("no files found");
+            }
             return false;
+        }
+    }

             try {
                 String id = calculateFileId(peer, filepath);
                 String[] name = filepath.split("/");
                 peer.getBackedUpFiles().put(name[name.length - 1], id);
                 peer.getControl().getBackedUpFiles().put(name[name.length - 1], id);
-...
+                    }
                     for (Message k : messages) {
                         peer.getMdb_channel().send(k);
                         System.out.println("sending...");
+                    }
                     i++;
                 } while (confirmMessage(messages, sleep));

         @Override
         public void run() {
             String[] name = filepath.split("/");
             String fid = this.peer.getBackedUpFiles().get(name[name.length - 1]);
             String fid = this.peer.getControl().getBackedUpFiles().get(name[name.length - 1]);
             File n = new File(filepath);
             Message ms = new DeleteMsg(peer.getVersionProtocol(), peer.getId(), peer.getBackedUpFiles().get(name[name.length - 1]));
             Message ms = new DeleteMsg(peer.getVersionProtocol(), peer.getId(), peer.getControl().getBackedUpFiles().get(name[name.length - 1]));
             peer.getMc_channel().send(ms);
             System.out.println("Deleted");
+        }
+    }

src/Protocols/RestoreProtocol.java
44	44
45	45	String[] name = file.split("/");
46	46
47		if (!peer.getBackedUpFiles().containsKey(name[name.length - 1])) {
	47	if (!peer.getControl().getBackedUpFiles().containsKey(name[name.length - 1])) {
48	48	System.out.println("wrong in ");
49	49	return;
50	50	}
...	...
58	58	return;
59	59	}
60	60
61		ArrayList<Message> messages = createMessages(size, peer.getBackedUpFiles().get(name[name.length - 1]));
	61	ArrayList<Message> messages = createMessages(size, peer.getControl().getBackedUpFiles().get(name[name.length - 1]));
62	62
63	63
64	64	do {
...	...
83	83	my_stream.write(i.getInfo());
84	84	}
85	85	fileInfo = my_stream.toByteArray();
86		peer.getStorage().saveFile(peer.getBackedUpFiles().get(name[name.length - 1]), fileInfo);
	86	peer.getStorage().saveFile(peer.getControl().getBackedUpFiles().get(name[name.length - 1]), fileInfo);
87	87	} catch (Exception e) {
88	88	e.printStackTrace();
89	89	}
90	90
	91	System.out.println("Restored");
	92
91	93	}
92	94
93	95

src/Storage/ChunksManager.java
63	63
64	64	fileInfo.close();
65	65	} catch (IOException e) {
66		e.printStackTrace();
	66	//e.printStackTrace();
67	67	}
68	68	}
69	69

src/Storage/FileSystem.java
24	24
25	25	private String base;
26	26
27		private List<Chunk> chunks;
28
29		private List<String> FilesStored;
30
31	27	public FileSystem(int maxSize, String directory, int peerID, Peer peer) {
32	28
33	29	this.maxSize = maxSize;
...	...
103	99	}
104	100	}
105	101
106
107	102	public boolean saveChunk(Chunk chunk, String fileId) {
108	103	if (chunk.getInfo().length > availableSpace())
109	104	return false;
...	...
137	132	return false;
138	133	}
139	134
140
141	135	public HashMap<String, byte[]> getChunks(String fileId) {
142	136
143	137	HashMap<String, byte[]> chunksInfo = new HashMap<>();
...	...
154	148	}
155	149	}
156	150	} catch (Exception e) {
157		e.printStackTrace();
	151	// e.printStackTrace();
158	152	}
159	153
160	154	return chunksInfo;
...	...
169	163	Files.createDirectories(pathres);
170	164	Files.createDirectory(pathchunks);
171	165	} catch (IOException e) {
172		e.printStackTrace();
	166	// e.printStackTrace();
173	167	}
174	168
175	169	}
...	...
210	204	}catch (Exception e){
211	205	e.printStackTrace();
212	206
213		System.out.println("");
214	207	}
215	208
216	209	return false;

     Compiling:
     javac TestApp.java
     javac Peers/Peer.java
     Start RMI:
     rmiregistry
     Run Program:
     > Peer:
     java Peer.Peer <version> <server_id> <access_point> <MC_IP_address> <MC_port> <MDB_IP_address> <MDB_port> <MDR_IP_address> <MDR_port>
     E.g.: Peer 2.0 1 Peer1 224.0.0.15 8001 224.0.0.16 8002 224.0.0.17 8003
     > Backup:
     java TestApp <host> <peer_access_point> BACKUP <file_path> <desired_replication_degree>
     E.g.:  App localhost Peer1 BACKUP /home/daniel/Desktop/Faculdade/SDIS/FEUP-SDIS/project1/Proj/src/test.txt 2
     > Restore:
     TestApp <host> <peer_access_point> RESTORE <file_path>
     E.g.:  App localhost/Peer1 RESTORE /home/daniel/Desktop/Faculdade/SDIS/FEUP-SDIS/project1/Proj/src/test.txt
     > Delete:
     java TestApp <host> <peer_access_point> DELETE <file_path>
     E.g.:  App localhost/Peer1 DELETE /home/daniel/Desktop/Faculdade/SDIS/FEUP-SDIS/project1/Proj/src/test.txt

src/run.sh
	1	#!/usr/bin/env bash
	2	java Peers.Peer "$1" "$2" "$3" "${4:-224.0.0.15}" "${5:-8001}" "${6:-224.0.0.16}" "${7:-8003}" "${8:-224.0.0.17}" "${9:-8004}" &
	3

Project

General

Profile

sdis1819-t7g06

Revision 2