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;
long read_result_pointer = bindings.PeerManager_read_event(
peer_manager_raw_pointer, peer.descriptor_raw_pointer, read_bytes);
if (bindings.CResult_boolPeerHandleErrorZ_is_ok(read_result_pointer)) {
- if (bindings.LDKCResult_boolPeerHandleErrorZ_get_ok(read_result_pointer)) {
+ if (bindings.CResult_boolPeerHandleErrorZ_get_ok(read_result_pointer)) {
key.interestOps(key.interestOps() & (~SelectionKey.OP_READ));
}
} else {
}
} catch (IOException ignored) {}
}
+ Reference.reachabilityFence(this.peer_manager); // Almost certainly overkill, but no harm in it
}
/**