Fix potential exceptions in FdEventReader users am: a51a28854f

Change-Id: Ie1358a7b62ad5331adbeb2143de98d747e936d2b

3 files changed, 23 insertions, 6 deletions

diff --git a/src/android/net/dhcp/DhcpPacketListener.java b/src/android/net/dhcp/DhcpPacketListener.java
index c9235da..656b642 100644
--- a/src/android/net/dhcp/DhcpPacketListener.java
+++ b/src/android/net/dhcp/DhcpPacketListener.java
@@ -19,6 +19,7 @@ package android.net.dhcp;
 import android.net.util.FdEventsReader;
 import android.os.Handler;
 import android.system.Os;
+import android.util.Log;
 
 import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
@@ -59,6 +60,8 @@ abstract class DhcpPacketListener extends FdEventsReader<DhcpPacketListener.Payl
             onReceive(packet, recvbuf.mSrcAddr, recvbuf.mSrcPort);
         } catch (DhcpPacket.ParseException e) {
             logParseError(recvbuf.mBytes, length, e);
+        } catch (Throwable e) {
+            Log.wtf(DhcpPacketListener.class.getSimpleName(), "Error handling DHCP packet", e);
         }
     }
 
diff --git a/src/android/net/ip/ConnectivityPacketTracker.java b/src/android/net/ip/ConnectivityPacketTracker.java
index bbaf61e..aa85f3a 100644
--- a/src/android/net/ip/ConnectivityPacketTracker.java
+++ b/src/android/net/ip/ConnectivityPacketTracker.java
@@ -133,9 +133,14 @@ public class ConnectivityPacketTracker {
                 return;
             }
 
-            final String summary = ConnectivityPacketSummary.summarize(
-                    mInterface.macAddr, recvbuf, length);
-            if (summary == null) return;
+            final String summary;
+            try {
+                summary = ConnectivityPacketSummary.summarize(mInterface.macAddr, recvbuf, length);
+                if (summary == null) return;
+            } catch (Exception e) {
+                if (DBG) Log.d(mTag, "Error creating packet summary", e);
+                return;
+            }
 
             if (DBG) Log.d(mTag, summary);
             addLogEntry(summary + "\n[" + HexDump.toHexString(recvbuf, 0, length) + "]");
diff --git a/src/android/net/ip/IpReachabilityMonitor.java b/src/android/net/ip/IpReachabilityMonitor.java
index db928d6..2a0ca5d 100644
--- a/src/android/net/ip/IpReachabilityMonitor.java
+++ b/src/android/net/ip/IpReachabilityMonitor.java
@@ -341,7 +341,14 @@ public class IpReachabilityMonitor {
             // TODO: Consider using NeighborEvent#isValid() here; it's more
             // strict but may interact badly if other entries are somehow in
             // NUD_INCOMPLETE (say, during network attach).
-            if (entry.getValue().nudState != StructNdMsg.NUD_FAILED) continue;
+            final NeighborEvent val = entry.getValue();
+
+            // Find all the neighbors that have gone into FAILED state.
+            // Ignore entries for which we have never received an event. If there are neighbors
+            // that never respond to ARP/ND, the kernel will send several FAILED event, then
+            // an INCOMPLETE event, and then more FAILED events. The INCOMPLETE event will
+            // populate the map and the subsequent FAILED event will be processed.
+            if (val == null || val.nudState != StructNdMsg.NUD_FAILED) continue;
 
             ip = entry.getKey();
             for (RouteInfo route : mLinkProperties.getRoutes()) {
@@ -378,10 +385,12 @@ public class IpReachabilityMonitor {
                 Log.d(TAG, "neighbour IPv4(v6): " + entry.getKey() + " neighbour state: "
                         + StructNdMsg.stringForNudState(entry.getValue().nudState));
             }
-            if (entry.getValue().nudState != StructNdMsg.NUD_REACHABLE) return;
+            final NeighborEvent val = entry.getValue();
+            // If an entry is null, consider that probing for that neighbour has completed.
+            if (val == null || val.nudState != StructNdMsg.NUD_REACHABLE) return;
         }
 
-        // All neighbours in the watchlist are in REACHABLE state and connection is stable,
+        // Probing for all neighbours in the watchlist is complete and the connection is stable,
         // restore NUD probe parameters to steadystate value. In the case where neighbours
         // are responsive, this code will run before the wakelock expires.
         setNeighbourParametersForSteadyState();