Qortal/qortal
1
0
Fork 0
mirror of https://github.com/Qortal/qortal.git synced 2025-04-23 19:37:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix pingRemote

Browse Source
This commit is contained in:
Jürg Schulthess 2024-07-10 20:23:29 +02:00
parent 706dc03b3e
commit 1d9347ed23
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/qortal/network/RNSPeer.java
View File

@ -230,6 +230,8 @@ public class RNSPeer {
/** Utility methods */ /** Utility methods */
public void pingRemote() { public void pingRemote() {
var link = this.peerLink; var link = this.peerLink;
if (nonNull(link)) {
if (peerLink.getStatus() == ACTIVE) {
log.info("pinging remote: {}", link); log.info("pinging remote: {}", link);
var data = "ping".getBytes(UTF_8); var data = "ping".getBytes(UTF_8);
link.setPacketCallback(this::linkPacketReceived); link.setPacketCallback(this::linkPacketReceived);
@ -238,6 +240,11 @@ public class RNSPeer {
//packetReceipt.setTimeout(3L); //packetReceipt.setTimeout(3L);
packetReceipt.setTimeoutCallback(this::packetTimedOut); packetReceipt.setTimeoutCallback(this::packetTimedOut);
packetReceipt.setDeliveryCallback(this::packetDelivered); packetReceipt.setDeliveryCallback(this::packetDelivered);
} else {
log.info("can't send ping to a peer {} with (link) status: {}",
Hex.encodeHexString(peerLink.getDestination().getHash()), peerLink.getStatus());
}
}
} }
//public void shutdownLink(Link link) { //public void shutdownLink(Link link) {