Limework/RedisBungee
2
0
Fork 0
mirror of https://github.com/proxiodev/RedisBungee.git synced 2024-11-23 04:28:01 +00:00
Code Releases Activity

Notify if a server is behind every 30 seconds. This is a /very/ common issue.

Browse Source
This commit is contained in:
Tux 2014-06-06 17:38:03 -04:00
parent 16ca96562f
commit eca670c43d
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/imaginarycode/minecraft/redisbungee/RedisBungee.java
View File

@ -35,6 +35,7 @@ import java.util.*;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level; import java.util.logging.Level;
import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkArgument;
@ -60,6 +61,7 @@ public final class RedisBungee extends Plugin {
private static RedisBungeeAPI api; private static RedisBungeeAPI api;
private static PubSubListener psl = null; private static PubSubListener psl = null;
private List<String> serverIds; private List<String> serverIds;
private AtomicInteger nagAboutServers = new AtomicInteger();
private int globalCount; private int globalCount;
/** /**
@ -82,6 +84,10 @@ public final class RedisBungee extends Plugin {
final List<String> getCurrentServerIds() { final List<String> getCurrentServerIds() {
Jedis jedis = pool.getResource(); Jedis jedis = pool.getResource();
try { try {
int nag = nagAboutServers.decrementAndGet();
if (nag <= 0) {
nagAboutServers.set(10);
}
ImmutableList.Builder<String> servers = ImmutableList.builder(); ImmutableList.Builder<String> servers = ImmutableList.builder();
Map<String, String> heartbeats = jedis.hgetAll("heartbeats"); Map<String, String> heartbeats = jedis.hgetAll("heartbeats");
for (Map.Entry<String, String> entry : heartbeats.entrySet()) { for (Map.Entry<String, String> entry : heartbeats.entrySet()) {
@ -89,6 +95,9 @@ public final class RedisBungee extends Plugin {
long stamp = Long.valueOf(entry.getValue()); long stamp = Long.valueOf(entry.getValue());
if (System.currentTimeMillis() < stamp + 30000) if (System.currentTimeMillis() < stamp + 30000)
servers.add(entry.getKey()); servers.add(entry.getKey());
else if (nag == 0) {
getLogger().severe(entry.getKey() + " is " + (System.currentTimeMillis() - stamp) + "ms behind! (Time not synchronized or server down?)");
}
} catch (NumberFormatException ignored) { } catch (NumberFormatException ignored) {
} }
} }