import org.junit.jupiter.api.Test;
import org.ldk.impl.bindings;
import org.ldk.enums.*;
+import org.ldk.structs.Result_NoneChannelMonitorUpdateErrZ;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
bindings.LDKBroadcasterInterface broad_trait;
bindings.LDKLogger log_trait;
bindings.LDKWatch watcher;
+ ArrayList<Long> results_to_free;
Peer(byte seed) {
this.log_trait = (String arg)-> System.out.println(seed + ": " + arg);
this.broad_trait = tx -> {
// We should broadcast
};
+ this.results_to_free = new ArrayList<>();
this.tx_broadcaster = bindings.LDKBroadcasterInterface_new(this.broad_trait);
this.monitors = new HashMap<>();
this.watcher = new bindings.LDKWatch() {
assert monitors.put(Arrays.toString(bindings.OutPoint_get_txid(funding_txo)), monitor) == null;
}
bindings.OutPoint_free(funding_txo);
- return bindings.CResult_NoneChannelMonitorUpdateErrZ_ok();
+ long res = bindings.CResult_NoneChannelMonitorUpdateErrZ_ok();
+ results_to_free.add(res);
+ return res;
}
@Override
synchronized (monitors) {
String txid = Arrays.toString(bindings.OutPoint_get_txid(funding_txo));
assert monitors.containsKey(txid);
- long update_res = bindings.ChannelMonitor_update_monitor(monitors.get(txid), update, tx_broadcaster, logger);
+ long update_res = bindings.ChannelMonitor_update_monitor(monitors.get(txid), update, tx_broadcaster, fee_estimator, logger);
assert bindings.LDKCResult_NoneMonitorUpdateErrorZ_result_ok(update_res);
bindings.CResult_NoneMonitorUpdateErrorZ_free(update_res);
}
bindings.OutPoint_free(funding_txo);
bindings.ChannelMonitorUpdate_free(update);
- return bindings.CResult_NoneChannelMonitorUpdateErrZ_ok();
+ long res = bindings.CResult_NoneChannelMonitorUpdateErrZ_ok();
+ results_to_free.add(res);
+ return res;
}
@Override
this.chan_manager_events = bindings.ChannelManager_as_EventsProvider(chan_manager);
this.chan_handler = bindings.ChannelManager_as_ChannelMessageHandler(chan_manager);
- this.router = bindings.NetGraphMsgHandler_new(0, logger);
+ this.router = bindings.NetGraphMsgHandler_new(new byte[32], 0, logger);
this.route_handler = bindings.NetGraphMsgHandler_as_RoutingMessageHandler(router);
this.message_handler = bindings.MessageHandler_new(chan_handler, route_handler);
txn = new long[0];
long[] ret = bindings.ChannelMonitor_block_connected(mon, header, txn, height, tx_broadcaster, fee_estimator, logger);
for (long r : ret) {
- bindings.C2Tuple_TxidCVec_TxOutZZ_free(r);
+ bindings.C2Tuple_TxidCVec_C2Tuple_u32TxOutZZZ_free(r);
}
}
}
bindings.ChannelMonitor_free(mon);
}
}
+ for (Long res : results_to_free) {
+ bindings.CResult_NoneChannelMonitorUpdateErrZ_free(res);
+ }
}
}
}
@Override public void disconnect_socket() { assert false; }
- @Override public boolean eq(long other_arg) { return bindings.LDKSocketDescriptor_get_obj_from_jcalls(other_arg).hash() == 2; }
+ @Override public boolean eq(long other_arg) { boolean ret = bindings.SocketDescriptor_hash(other_arg) == 2; bindings.SocketDescriptor_free(other_arg); return ret; }
@Override public long hash() { return 2; }
};
long descriptor2 = bindings.LDKSocketDescriptor_new(sock1);
}
@Override public void disconnect_socket() { assert false; }
- @Override public boolean eq(long other_arg) { return bindings.LDKSocketDescriptor_get_obj_from_jcalls(other_arg).hash() == 1; }
+ @Override public boolean eq(long other_arg) { boolean ret = bindings.SocketDescriptor_hash(other_arg) == 1; bindings.SocketDescriptor_free(other_arg); return ret; }
@Override public long hash() { return 1; }
};
descriptor1.val = bindings.LDKSocketDescriptor_new(sock2);