X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fldk%2FPeerTest.java;h=e5967cf5b611cc3ae3f0b50e1a70abaec87fbe6b;hb=16eb386ba053e6901da5edd024dd0613c1700084;hp=7dc3f1a39df568c31362d562388836752e2076a8;hpb=dc1457cedad113904e9120d9427c527f3c72e25f;p=ldk-java diff --git a/src/test/java/org/ldk/PeerTest.java b/src/test/java/org/ldk/PeerTest.java index 7dc3f1a3..e5967cf5 100644 --- a/src/test/java/org/ldk/PeerTest.java +++ b/src/test/java/org/ldk/PeerTest.java @@ -7,6 +7,7 @@ import org.ldk.enums.Network; import org.ldk.enums.Recipient; import org.ldk.impl.bindings; +import java.lang.ref.Reference; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; @@ -216,14 +217,16 @@ public class PeerTest { }; descriptor1.val = bindings.LDKSocketDescriptor_new(sock2); - long init_vec = bindings.PeerManager_new_outbound_connection(peer1.peer_manager, peer2.node_id, descriptor1.val); + long no_netaddr = bindings.COption_NetAddressZ_none(); + long init_vec = bindings.PeerManager_new_outbound_connection(peer1.peer_manager, peer2.node_id, descriptor1.val, no_netaddr); assert(bindings.CResult_CVec_u8ZPeerHandleErrorZ_is_ok(init_vec)); - long con_res = bindings.PeerManager_new_inbound_connection(peer2.peer_manager, descriptor2); + long con_res = bindings.PeerManager_new_inbound_connection(peer2.peer_manager, descriptor2, no_netaddr); assert(bindings.CResult_NonePeerHandleErrorZ_is_ok(con_res)); bindings.CResult_NonePeerHandleErrorZ_free(con_res); do_read_event(list, peer2.peer_manager, descriptor2, bindings.CResult_CVec_u8ZPeerHandleErrorZ_get_ok(init_vec)); bindings.CResult_CVec_u8ZPeerHandleErrorZ_free(init_vec); + bindings.COption_NetAddressZ_free(no_netaddr); deliver_peer_messages(list, peer1.peer_manager, peer2.peer_manager); @@ -234,7 +237,8 @@ public class PeerTest { deliver_peer_messages(list, peer1.peer_manager, peer2.peer_manager); ArrayList events = new ArrayList(); - long handler = bindings.LDKEventHandler_new(events::add); + bindings.LDKEventHandler events_adder = events::add; + long handler = bindings.LDKEventHandler_new(events_adder); bindings.EventsProvider_process_pending_events(peer1.chan_manager_events, handler); assert events.size() == 1; @@ -293,7 +297,7 @@ public class PeerTest { bindings.COption_u64Z_free(no_u64); long route_params = bindings.RouteParameters_new(payee, 1000, 42); long route = bindings.find_route(peer1.node_id, route_params, peer1.router, peer1_chans, - peer1.logger, scorer_interface); + peer1.logger, scorer_interface, new byte[32]); bindings.RouteParameters_free(route_params); bindings.PaymentParameters_free(payee); bindings.Score_free(scorer_interface); @@ -336,6 +340,7 @@ public class PeerTest { bindings.LDKEvent sent_path = bindings.LDKEvent_ref_from_ptr(events.get(0)); assert sent_path instanceof bindings.LDKEvent.PaymentPathSuccessful; bindings.Event_free(events.remove(0)); + Reference.reachabilityFence(events_adder); bindings.EventHandler_free(handler);