mirror of
https://github.com/TotalFreedomMC/TF-EssentialsX.git
synced 2024-09-17 23:47:40 +00:00
121 lines
2.4 KiB
Java
121 lines
2.4 KiB
Java
package com.earth2me.essentials;
|
|
|
|
import java.util.HashSet;
|
|
import java.util.Iterator;
|
|
import java.util.LinkedList;
|
|
import java.util.Set;
|
|
import java.util.logging.Level;
|
|
import org.bukkit.entity.Player;
|
|
|
|
|
|
public class EssentialsTimer implements Runnable
|
|
{
|
|
private final transient IEssentials ess;
|
|
private final transient Set<User> onlineUsers = new HashSet<User>();
|
|
private transient long lastPoll = System.nanoTime();
|
|
private final LinkedList<Double> history = new LinkedList<Double>();
|
|
private int skip1 = 0;
|
|
private int skip2 = 0;
|
|
private final long maxTime = 10 * 1000000;
|
|
private final long tickInterval = 50;
|
|
|
|
EssentialsTimer(final IEssentials ess)
|
|
{
|
|
this.ess = ess;
|
|
}
|
|
|
|
@Override
|
|
public void run()
|
|
{
|
|
final long startTime = System.nanoTime();
|
|
final long currentTime = System.currentTimeMillis();
|
|
long timeSpent = (startTime - lastPoll) / 1000;
|
|
if (timeSpent == 0)
|
|
{
|
|
timeSpent = 1;
|
|
}
|
|
if (history.size() > 10)
|
|
{
|
|
history.remove();
|
|
}
|
|
double tps = tickInterval * 1000000.0 / timeSpent;
|
|
if (tps <= 20)
|
|
{
|
|
history.add(tps);
|
|
}
|
|
lastPoll = startTime;
|
|
int count = 0;
|
|
for (Player player : ess.getServer().getOnlinePlayers())
|
|
{
|
|
count++;
|
|
if (skip1 > 0)
|
|
{
|
|
skip1--;
|
|
continue;
|
|
}
|
|
if (count % 10 == 0)
|
|
{
|
|
if (System.nanoTime() - startTime > maxTime / 2)
|
|
{
|
|
skip1 = count - 1;
|
|
break;
|
|
}
|
|
}
|
|
try
|
|
{
|
|
final User user = ess.getUser(player);
|
|
onlineUsers.add(user);
|
|
user.setLastOnlineActivity(currentTime);
|
|
user.checkActivity();
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
ess.getLogger().log(Level.WARNING, "EssentialsTimer Error:", e);
|
|
}
|
|
}
|
|
|
|
count = 0;
|
|
final Iterator<User> iterator = onlineUsers.iterator();
|
|
while (iterator.hasNext())
|
|
{
|
|
count++;
|
|
if (skip2 > 0)
|
|
{
|
|
skip2--;
|
|
continue;
|
|
}
|
|
if (count % 10 == 0)
|
|
{
|
|
if (System.nanoTime() - startTime > maxTime)
|
|
{
|
|
skip2 = count - 1;
|
|
break;
|
|
}
|
|
}
|
|
final User user = iterator.next();
|
|
if (user.getLastOnlineActivity() < currentTime && user.getLastOnlineActivity() > user.getLastLogout())
|
|
{
|
|
user.setLastLogout(user.getLastOnlineActivity());
|
|
iterator.remove();
|
|
continue;
|
|
}
|
|
user.checkMuteTimeout(currentTime);
|
|
user.checkJailTimeout(currentTime);
|
|
user.resetInvulnerabilityAfterTeleport();
|
|
}
|
|
}
|
|
|
|
public double getAverageTPS()
|
|
{
|
|
double avg = 0;
|
|
for (Double f : history)
|
|
{
|
|
if (f != null)
|
|
{
|
|
avg += f;
|
|
}
|
|
}
|
|
return avg / history.size();
|
|
}
|
|
}
|