Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Let our examples compile with java 1.6, or almost
authorMartin Quinson <martin.quinson@loria.fr>
Wed, 11 Jan 2017 14:25:08 +0000 (15:25 +0100)
committerMartin Quinson <martin.quinson@loria.fr>
Wed, 11 Jan 2017 14:25:08 +0000 (15:25 +0100)
examples/java/app/bittorrent/Peer.java
examples/java/app/bittorrent/Tracker.java
examples/java/app/bittorrent/TrackerTask.java
examples/java/app/centralizedmutex/Coordinator.java
examples/java/cloud/masterworker/Master.java
examples/java/cloud/migration/Test.java
examples/java/dht/kademlia/Bucket.java
examples/java/energy/vm/EnergyVMRunner.java

index 0bdc770..649c3b5 100644 (file)
@@ -33,10 +33,10 @@ public class Peer extends Process {
   protected char[][] bitfieldBlocks = new char[Common.FILE_PIECES][Common.PIECES_BLOCKS];
   protected short[] piecesCount = new short[Common.FILE_PIECES];
   protected int piecesRequested = 0;
-  protected ArrayList<Integer> currentPieces = new ArrayList<>();
+  protected ArrayList<Integer> currentPieces = new ArrayList<Integer>();
   protected int currentPiece = -1;
-  protected HashMap<Integer, Connection> activePeers = new HashMap<>();
-  protected HashMap<Integer, Connection> peers = new HashMap<>();
+  protected HashMap<Integer, Connection> activePeers = new HashMap<Integer, Connection>();
+  protected HashMap<Integer, Connection> peers = new HashMap<Integer, Connection>();
   protected Comm commReceived = null;
 
   public Peer(Host host, String name, String[]args) {
index 980d9c6..b8126a8 100644 (file)
@@ -36,7 +36,7 @@ public class Tracker extends Process {
     //Retrieve the end time
     deadline = Double.parseDouble(args[0]);
     //Building peers array
-    peersList = new ArrayList<>();
+    peersList = new ArrayList<Integer>();
 
     Msg.info("Tracker launched.");
     while (Msg.getClock() < deadline) {
index d27a7d7..ec4ee36 100644 (file)
@@ -39,6 +39,6 @@ public class TrackerTask extends Task {
     this.uploaded = uploaded;
     this.downloaded = downloaded;
     this.left = left;
-    this.peers = new ArrayList<>();
+    this.peers = new ArrayList<Integer>();
   }
 }
index 1931293..d6cd28f 100644 (file)
@@ -14,7 +14,7 @@ import org.simgrid.msg.Process;
 import org.simgrid.msg.MsgException;
 
 public class Coordinator extends Process {
-  LinkedList<RequestTask> waitingQueue=new LinkedList<>();
+  LinkedList<RequestTask> waitingQueue=new LinkedList<RequestTask>();
   int csToServe;
 
   public Coordinator(Host host, String name, String[]args) {
index c2b95d9..f2e23e2 100644 (file)
@@ -25,7 +25,7 @@ public class Master extends Process {
 
   public void main(String[] args) throws MsgException {
     int workersCount = Main.NHOSTS;
-    ArrayList<VM> vms = new ArrayList<>();
+    ArrayList<VM> vms = new ArrayList<VM>();
 
     // Create one VM per host and bind a process inside each one. 
     for (int i = 0; i < workersCount; i++) {
index 5d63841..c64a4dc 100644 (file)
@@ -37,7 +37,7 @@ public class Test extends Process{
       e.printStackTrace();
     }
 
-    List<VM> vms = new ArrayList<>();
+    List<VM> vms = new ArrayList<VM>();
 
     /* Create VM1 */
     int dpRate = 70;
index 1abceb1..c0eaa92 100644 (file)
@@ -12,7 +12,7 @@ public class Bucket {
   private int id;
 
   public Bucket(int id) {
-    this.nodes = new ArrayList<>();
+    this.nodes = new ArrayList<Integer>();
     this.id = id;
   }
 
index 0e636f6..be5d65f 100644 (file)
@@ -28,7 +28,7 @@ public class EnergyVMRunner extends Process {
       Task  task = new Task(this.getHost().getName()+"-task", 300E6 , 0);
       try {
         task.execute();
-      } catch (HostFailureException | TaskCancelledException e) {
+      } catch (HostFailureException | TaskCancelledException e) { // If your compiler fails on that multicatch, please proceed to Java 1.7 or higher
         Msg.error(e.getMessage());
         e.printStackTrace();
       }