X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fldk%2Fstructs%2FChannelMessageHandler.java;h=8bb6667f048231bb67b5eb7164a97a35bf843e16;hb=1854b5cebef22ace9e9e4dd191f609818df9ce08;hp=f4546bd4f6c4d329802e645d26ea66959bdfbbf7;hpb=5fd405f7a48aaeca779c45c88ec6b3d3d3dbf0e4;p=ldk-java

diff --git a/src/main/java/org/ldk/structs/ChannelMessageHandler.java b/src/main/java/org/ldk/structs/ChannelMessageHandler.java
index f4546bd4..8bb6667f 100644
--- a/src/main/java/org/ldk/structs/ChannelMessageHandler.java
+++ b/src/main/java/org/ldk/structs/ChannelMessageHandler.java
@@ -4,6 +4,7 @@ import org.ldk.impl.bindings;
 import org.ldk.enums.*;
 import org.ldk.util.*;
 import java.util.Arrays;
+import java.lang.ref.Reference;
 import javax.annotation.Nullable;
 
 /**
@@ -218,6 +219,10 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_open_channel(byte[] their_node_id, InitFeatures their_features, OpenChannel msg) {
 		bindings.ChannelMessageHandler_handle_open_channel(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), their_features == null ? 0 : their_features.ptr & ~1, msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(their_features);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -226,6 +231,10 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_accept_channel(byte[] their_node_id, InitFeatures their_features, AcceptChannel msg) {
 		bindings.ChannelMessageHandler_handle_accept_channel(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), their_features == null ? 0 : their_features.ptr & ~1, msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(their_features);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -234,6 +243,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_funding_created(byte[] their_node_id, FundingCreated msg) {
 		bindings.ChannelMessageHandler_handle_funding_created(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -242,6 +254,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_funding_signed(byte[] their_node_id, FundingSigned msg) {
 		bindings.ChannelMessageHandler_handle_funding_signed(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -250,6 +265,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_funding_locked(byte[] their_node_id, FundingLocked msg) {
 		bindings.ChannelMessageHandler_handle_funding_locked(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -258,6 +276,10 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_shutdown(byte[] their_node_id, InitFeatures their_features, Shutdown msg) {
 		bindings.ChannelMessageHandler_handle_shutdown(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), their_features == null ? 0 : their_features.ptr & ~1, msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(their_features);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(their_features);
 		this.ptrs_to.add(msg);
 	}
@@ -267,6 +289,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_closing_signed(byte[] their_node_id, ClosingSigned msg) {
 		bindings.ChannelMessageHandler_handle_closing_signed(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -275,6 +300,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_update_add_htlc(byte[] their_node_id, UpdateAddHTLC msg) {
 		bindings.ChannelMessageHandler_handle_update_add_htlc(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -283,6 +311,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_update_fulfill_htlc(byte[] their_node_id, UpdateFulfillHTLC msg) {
 		bindings.ChannelMessageHandler_handle_update_fulfill_htlc(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -291,6 +322,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_update_fail_htlc(byte[] their_node_id, UpdateFailHTLC msg) {
 		bindings.ChannelMessageHandler_handle_update_fail_htlc(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -299,6 +333,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_update_fail_malformed_htlc(byte[] their_node_id, UpdateFailMalformedHTLC msg) {
 		bindings.ChannelMessageHandler_handle_update_fail_malformed_htlc(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -307,6 +344,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_commitment_signed(byte[] their_node_id, CommitmentSigned msg) {
 		bindings.ChannelMessageHandler_handle_commitment_signed(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -315,6 +355,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_revoke_and_ack(byte[] their_node_id, RevokeAndACK msg) {
 		bindings.ChannelMessageHandler_handle_revoke_and_ack(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -323,6 +366,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_update_fee(byte[] their_node_id, UpdateFee msg) {
 		bindings.ChannelMessageHandler_handle_update_fee(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -331,6 +377,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_announcement_signatures(byte[] their_node_id, AnnouncementSignatures msg) {
 		bindings.ChannelMessageHandler_handle_announcement_signatures(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -342,6 +391,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void peer_disconnected(byte[] their_node_id, boolean no_connection_possible) {
 		bindings.ChannelMessageHandler_peer_disconnected(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), no_connection_possible);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(no_connection_possible);
 	}
 
 	/**
@@ -349,6 +401,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void peer_connected(byte[] their_node_id, Init msg) {
 		bindings.ChannelMessageHandler_peer_connected(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -357,6 +412,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_channel_reestablish(byte[] their_node_id, ChannelReestablish msg) {
 		bindings.ChannelMessageHandler_handle_channel_reestablish(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -365,6 +423,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_channel_update(byte[] their_node_id, ChannelUpdate msg) {
 		bindings.ChannelMessageHandler_handle_channel_update(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}
 
@@ -373,6 +434,9 @@ public class ChannelMessageHandler extends CommonBase {
 	 */
 	public void handle_error(byte[] their_node_id, ErrorMessage msg) {
 		bindings.ChannelMessageHandler_handle_error(this.ptr, InternalUtils.check_arr_len(their_node_id, 33), msg == null ? 0 : msg.ptr & ~1);
+		Reference.reachabilityFence(this);
+		Reference.reachabilityFence(their_node_id);
+		Reference.reachabilityFence(msg);
 		this.ptrs_to.add(msg);
 	}