diff options
Diffstat (limited to 'src/main/java/ganarchy/friendcode/client/I2PSamPinger.java')
-rw-r--r-- | src/main/java/ganarchy/friendcode/client/I2PSamPinger.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main/java/ganarchy/friendcode/client/I2PSamPinger.java b/src/main/java/ganarchy/friendcode/client/I2PSamPinger.java index 96448db..0476c61 100644 --- a/src/main/java/ganarchy/friendcode/client/I2PSamPinger.java +++ b/src/main/java/ganarchy/friendcode/client/I2PSamPinger.java @@ -12,7 +12,6 @@ public class I2PSamPinger extends LanServerPinger implements LanSendPing { private I2PSamStreamForwarder stream; private final String port; private volatile Status status = Status.IDLE; - private boolean hasWarned; private volatile boolean stopSam; public I2PSamPinger(String motd, String port) throws IOException { @@ -62,6 +61,9 @@ public class I2PSamPinger extends LanServerPinger implements LanSendPing { @Override public void friendcodeSendPing() { + if (this.status != Status.RUNNING) { + return; + } if (this.stopSam) { if (this.stream != null) { try { @@ -74,7 +76,6 @@ public class I2PSamPinger extends LanServerPinger implements LanSendPing { } catch (IOException ignored) { } this.status = Status.CONNECTION_CLOSED; - this.hasWarned = true; return; } if (this.sam.sendPing() < 0) { @@ -85,8 +86,7 @@ public class I2PSamPinger extends LanServerPinger implements LanSendPing { this.status = Status.CONNECTION_CLOSED; } } - if (this.status == Status.CONNECTION_CLOSED && !this.hasWarned) { - this.hasWarned = true; + if (this.status == Status.CONNECTION_CLOSED) { FriendCode.LOGGER.warn("Friend Code connection closed!"); } } |