Code cleanup

Author: Federico Fissore

arduino-core/src/cc/arduino/contributions/GZippedJsonDownloader.java

@@ -67,7 +67,7 @@ private void decompress(File gzipTmpFile, File tmpFile) throws IOException {
       os = new FileOutputStream(tmpFile);
       gzipIs = new GzipCompressorInputStream(new FileInputStream(gzipTmpFile));
       final byte[] buffer = new byte[4096];
-      int n = 0;
+      int n;
       while (-1 != (n = gzipIs.read(buffer))) {
         os.write(buffer, 0, n);
       }

arduino-core/src/cc/arduino/contributions/JsonDownloader.java

@@ -49,7 +49,6 @@ public void download(File tmpFile, Progress progress, String statusText) throws
       downloader.download(url, tmpFile, progress, statusText);
     } catch (InterruptedException e) {
       // Download interrupted... just exit
-      return;
     }
   }
 }

arduino-core/src/cc/arduino/contributions/libraries/ContributedLibrary.java

@@ -142,7 +142,7 @@ public boolean equals(Object obj) {
     String thisVersion = getParsedVersion();
     String otherVersion = ((ContributedLibrary) obj).getParsedVersion();
 
-    boolean versionEquals = thisVersion == otherVersion || (thisVersion != null && otherVersion != null && thisVersion.equals(otherVersion));
+    boolean versionEquals = thisVersion != null && otherVersion != null && thisVersion.equals(otherVersion);
 
     String thisName = getName();
     String otherName = ((ContributedLibrary) obj).getName();

arduino-core/src/cc/arduino/contributions/libraries/LibraryInstaller.java

@@ -79,7 +79,6 @@ public void updateIndex() throws Exception {
     final MultiStepProgress progress = new MultiStepProgress(2);
 
     // Step 1: Download index
-    URL url = new URL(LIBRARY_INDEX_URL);
     File outputFile = indexer.getIndexFile();
     File tmpFile = new File(outputFile.getAbsolutePath() + ".tmp");
     try {

arduino-core/src/cc/arduino/packages/discoverers/NetworkDiscovery.java

@@ -56,15 +56,15 @@ public class NetworkDiscovery implements Discovery, ServiceListener, cc.arduino.
 
   public NetworkDiscovery() {
     DNSTaskStarter.Factory.setClassDelegate(new ArduinoDNSTaskStarter());
-    this.boardPortsDiscoveredWithJmDNS = new LinkedList<BoardPort>();
-    this.mappedJmDNSs = new Hashtable<InetAddress, JmDNS>();
-    this.reachableBoardPorts = new LinkedList<BoardPort>();
+    this.boardPortsDiscoveredWithJmDNS = new LinkedList<>();
+    this.mappedJmDNSs = new Hashtable<>();
+    this.reachableBoardPorts = new LinkedList<>();
   }
 
   @Override
   public List<BoardPort> listDiscoveredBoards() {
     synchronized (reachableBoardPorts) {
-      return new LinkedList<BoardPort>(reachableBoardPorts);
+      return new LinkedList<>(reachableBoardPorts);
     }
   }
 
@@ -77,7 +77,7 @@ public void setReachableBoardPorts(List<BoardPort> newReachableBoardPorts) {
 
   public List<BoardPort> getBoardPortsDiscoveredWithJmDNS() {
     synchronized (boardPortsDiscoveredWithJmDNS) {
-      return new LinkedList<BoardPort>(boardPortsDiscoveredWithJmDNS);
+      return new LinkedList<>(boardPortsDiscoveredWithJmDNS);
     }
   }
 
@@ -114,11 +114,7 @@ public void serviceAdded(ServiceEvent serviceEvent) {
   public void serviceRemoved(ServiceEvent serviceEvent) {
     String name = serviceEvent.getName();
     synchronized (boardPortsDiscoveredWithJmDNS) {
-      for (BoardPort port : boardPortsDiscoveredWithJmDNS) {
-        if (port.getBoardName().equals(name)) {
-          boardPortsDiscoveredWithJmDNS.remove(port);
-        }
-      }
+      boardPortsDiscoveredWithJmDNS.stream().filter(port -> port.getBoardName().equals(name)).forEach(boardPortsDiscoveredWithJmDNS::remove);
     }
   }
 

arduino-core/src/cc/arduino/packages/discoverers/SerialDiscovery.java

@@ -43,17 +43,17 @@ public class SerialDiscovery implements Discovery {
   private final List<BoardPort> serialBoardPorts;
 
   public SerialDiscovery() {
-    this.serialBoardPorts = new LinkedList<BoardPort>();
+    this.serialBoardPorts = new LinkedList<>();
   }
 
   @Override
   public List<BoardPort> listDiscoveredBoards() {
     return getSerialBoardPorts();
   }
 
-  public List<BoardPort> getSerialBoardPorts() {
+  private List<BoardPort> getSerialBoardPorts() {
     synchronized (serialBoardPorts) {
-      return new LinkedList<BoardPort>(serialBoardPorts);
+      return new LinkedList<>(serialBoardPorts);
     }
   }
 

arduino-core/src/cc/arduino/packages/discoverers/network/BoardReachabilityFilter.java

@@ -61,7 +61,7 @@ public void run() {
         InetAddress inetAddress = InetAddress.getByName(board.getAddress());
         int broadcastedPort = Integer.valueOf(board.getPrefs().get("port"));
 
-        List<Integer> ports = new LinkedList<Integer>();
+        List<Integer> ports = new LinkedList<>();
         ports.add(broadcastedPort);
 
         //dirty code: allows non up to date yuns to be discovered. Newer yuns will broadcast port 22

arduino-core/src/cc/arduino/packages/discoverers/network/NetworkChecker.java

@@ -44,7 +44,7 @@ public NetworkChecker(NetworkTopologyListener topologyListener, NetworkTopologyD
     super();
     this.topologyListener = topologyListener;
     this.topology = topology;
-    this.knownAddresses = Collections.synchronizedSet(new HashSet<InetAddress>());
+    this.knownAddresses = Collections.synchronizedSet(new HashSet<>());
   }
 
   public void start(Timer timer) {
@@ -55,18 +55,14 @@ public void start(Timer timer) {
   public void run() {
     try {
       InetAddress[] curentAddresses = topology.getInetAddresses();
-      Set<InetAddress> current = new HashSet<InetAddress>(curentAddresses.length);
+      Set<InetAddress> current = new HashSet<>(curentAddresses.length);
       for (InetAddress address : curentAddresses) {
         current.add(address);
         if (!knownAddresses.contains(address)) {
           topologyListener.inetAddressAdded(address);
         }
       }
-      for (InetAddress address : knownAddresses) {
-        if (!current.contains(address)) {
-          topologyListener.inetAddressRemoved(address);
-        }
-      }
+      knownAddresses.stream().filter(address -> !current.contains(address)).forEach(topologyListener::inetAddressRemoved);
       knownAddresses = current;
     } catch (Exception e) {
       e.printStackTrace();

arduino-core/src/cc/arduino/packages/discoverers/serial/SerialBoardsLister.java

@@ -66,7 +66,7 @@ public void run() {
       return;
     }
 
-    List<BoardPort> boardPorts = new LinkedList<BoardPort>();
+    List<BoardPort> boardPorts = new LinkedList<>();
 
     List<String> ports = Serial.list();
 

arduino-core/src/cc/arduino/packages/ssh/SCP.java

@@ -61,15 +61,15 @@ public void open() throws IOException {
     }
   }
 
-  public void close() throws IOException {
+  public void close() {
     IOUtils.closeQuietly(out);
     IOUtils.closeQuietly(in);
     if (channel != null) {
       channel.disconnect();
     }
   }
 
-  protected void ensureAcknowledged() throws IOException {
+  private void ensureAcknowledged() throws IOException {
     out.flush();
 
     int b = in.read();