X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fldk%2Fbatteries%2FNioPeerHandler.java;h=e0dd83e9edc570b542716ae88caacb4e45b58940;hb=0f3b80a2f43d596821643e1b2d151c12d8234389;hp=afe728b059c482cc35983051ab3f72ed998b0e99;hpb=99d1a3bd6dc5c7ed1499b30bfc2b4c66ffaf858a;p=ldk-java diff --git a/src/main/java/org/ldk/batteries/NioPeerHandler.java b/src/main/java/org/ldk/batteries/NioPeerHandler.java index afe728b0..e0dd83e9 100644 --- a/src/main/java/org/ldk/batteries/NioPeerHandler.java +++ b/src/main/java/org/ldk/batteries/NioPeerHandler.java @@ -5,6 +5,7 @@ import org.ldk.structs.*; import java.io.IOException; import java.lang.reflect.Field; +import java.lang.ref.Reference; import java.util.LinkedList; import java.net.SocketAddress; import java.net.StandardSocketOptions; @@ -217,8 +218,8 @@ public class NioPeerHandler { buf.get(read_bytes, 0, read); long read_result_pointer = bindings.PeerManager_read_event( peer_manager_raw_pointer, peer.descriptor_raw_pointer, read_bytes); - if (bindings.LDKCResult_boolPeerHandleErrorZ_result_ok(read_result_pointer)) { - if (bindings.LDKCResult_boolPeerHandleErrorZ_get_ok(read_result_pointer)) { + if (bindings.CResult_boolPeerHandleErrorZ_is_ok(read_result_pointer)) { + if (bindings.CResult_boolPeerHandleErrorZ_get_ok(read_result_pointer)) { key.interestOps(key.interestOps() & (~SelectionKey.OP_READ)); } } else { @@ -339,6 +340,7 @@ public class NioPeerHandler { } } catch (IOException ignored) {} } + Reference.reachabilityFence(this.peer_manager); // Almost certainly overkill, but no harm in it } /**