1 package org.ldk.structs;
3 import org.ldk.impl.bindings;
4 import org.ldk.enums.*;
6 import java.util.Arrays;
8 @SuppressWarnings("unchecked") // We correctly assign various generic arrays
9 public class PeerManager extends CommonBase {
10 PeerManager(Object _dummy, long ptr) { super(ptr); }
11 @Override @SuppressWarnings("deprecation")
12 protected void finalize() throws Throwable {
14 bindings.PeerManager_free(ptr);
17 public static PeerManager constructor_new(ChannelMessageHandler message_handler_chan_handler_arg, RoutingMessageHandler message_handler_route_handler_arg, byte[] our_node_secret, byte[] ephemeral_random_data, Logger logger) {
18 long ret = bindings.PeerManager_new(bindings.MessageHandler_new(message_handler_chan_handler_arg == null ? 0 : message_handler_chan_handler_arg.ptr, message_handler_route_handler_arg == null ? 0 : message_handler_route_handler_arg.ptr), our_node_secret, ephemeral_random_data, logger == null ? 0 : logger.ptr);
19 PeerManager ret_hu_conv = new PeerManager(null, ret);
20 ret_hu_conv.ptrs_to.add(message_handler_chan_handler_arg);
21 ret_hu_conv.ptrs_to.add(message_handler_route_handler_arg);
22 ret_hu_conv.ptrs_to.add(logger);
26 public byte[][] get_peer_node_ids() {
27 byte[][] ret = bindings.PeerManager_get_peer_node_ids(this.ptr);
31 // Skipped PeerManager_new_outbound_connection
32 // Skipped PeerManager_new_inbound_connection
33 // Skipped PeerManager_write_buffer_space_avail
34 // Skipped PeerManager_read_event
35 public void process_events() {
36 bindings.PeerManager_process_events(this.ptr);
39 public void socket_disconnected(SocketDescriptor descriptor) {
40 bindings.PeerManager_socket_disconnected(this.ptr, descriptor == null ? 0 : descriptor.ptr);
41 this.ptrs_to.add(descriptor);
44 public void timer_tick_occured() {
45 bindings.PeerManager_timer_tick_occured(this.ptr);