AFSelector: Bring back Java 7 compatibility

kohlschuetter · kohlschuetter · commit efacb5ae8e14 · 2023-11-12T13:56:12.000+01:00
Fix errors only occurring with -Drelease #145
diff --git a/junixsocket-common/src/main/java/org/newsclub/net/unix/AFSelector.java b/junixsocket-common/src/main/java/org/newsclub/net/unix/AFSelector.java
@@ -199,8 +199,8 @@ private void setOpsReady(PollFd pfd, int selectId) {
         int rops = pfd.rops[i];
         AFSelectionKey key = pfd.keys[i];
         key.setOpsReady(rops);
-        if (rops != 0) {
-          keysRegistered.computeIfPresent(key, (k, v) -> selectId);
+        if (rops != 0 && keysRegistered.containsKey(key)) {
+          keysRegistered.put(key, selectId);
         }
       }
     }
diff --git a/junixsocket-common/src/main/java/org/newsclub/net/unix/MapValueSet.java b/junixsocket-common/src/main/java/org/newsclub/net/unix/MapValueSet.java
@@ -25,7 +25,6 @@
 import java.util.NoSuchElementException;
 import java.util.Objects;
 import java.util.Set;
-import java.util.function.Supplier;
 
 import org.eclipse.jdt.annotation.NonNull;
 
@@ -41,16 +40,21 @@
  */
 final class MapValueSet<T, V> implements Set<T> {
   private final Map<T, V> map;
-  private final Supplier<@NonNull V> valueSupplier;
+  private final ValueSupplier<@NonNull V> valueSupplier;
   private final V removedSentinel;
 
   @SuppressWarnings("unchecked")
-  MapValueSet(Map<? extends T, V> map, Supplier<@NonNull V> valueSupplier, V removedSentinel) {
+  MapValueSet(Map<? extends T, V> map, ValueSupplier<@NonNull V> valueSupplier, V removedSentinel) {
     this.valueSupplier = Objects.requireNonNull(valueSupplier);
     this.removedSentinel = removedSentinel;
     this.map = (Map<T, V>) map;
   }
 
+  @FunctionalInterface
+  interface ValueSupplier<V> {
+    V supplyValue();
+  }
+
   /**
    * Marks the given element as "removed"; this may actually add an element to the underlying map.
    * <p>
@@ -83,7 +87,7 @@ public void markAllRemoved() {
   }
 
   private @NonNull V getValue() {
-    return Objects.requireNonNull(valueSupplier.get());
+    return Objects.requireNonNull(valueSupplier.supplyValue());
   }
 
   @Override
@@ -220,22 +224,26 @@ public <E> E[] toArray(E[] a) {
    * 
    * @param e The entry to update.
    */
-  public void update(T e) {
-    map.computeIfPresent(e, (k, v) -> getValue());
+  public boolean update(T e) {
+    if (map.containsKey(e)) {
+      map.put(e, getValue());
+      return true;
+    } else {
+      return false;
+    }
   }
 
   /**
    * Adds an entry to the set, adding it to the backing map if necessary.
    */
   @Override
   public boolean add(T e) {
-    if (!map.containsKey(e)) {
-      map.computeIfAbsent(e, (k) -> getValue());
-      return true;
-    } else if (contains(e)) {
+    if (contains(e)) {
       return false;
+    } else if (update(e)) {
+      return true;
     } else {
-      update(e);
+      map.put(e, getValue());
       return true;
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -199,8 +199,8 @@ private void setOpsReady(PollFd pfd, int selectId) {`
`199`	`199`	`int rops = pfd.rops[i];`
`200`	`200`	`AFSelectionKey key = pfd.keys[i];`
`201`	`201`	`key.setOpsReady(rops);`
`202`		`- if (rops != 0) {`
`203`		`- keysRegistered.computeIfPresent(key, (k, v) -> selectId);`
	`202`	`+ if (rops != 0 && keysRegistered.containsKey(key)) {`
	`203`	`+ keysRegistered.put(key, selectId);`
`204`	`204`	`}`
`205`	`205`	`}`
`206`	`206`	`}`