mirror/CoreProtect
2
0
Fork 0
mirror of https://github.com/PlayPro/CoreProtect.git synced 2024-11-27 04:30:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fixed block spread cache not always being properly utilized

Browse Source
This commit is contained in:
Intelli 2024-04-19 19:17:35 -06:00
parent a239b51ed1
commit 32688c55cf
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/net/coreprotect/listener/block/BlockSpreadListener.java
View File

@ -14,6 +14,7 @@ import net.coreprotect.config.Config;
import net.coreprotect.consumer.Queue;
import net.coreprotect.model.BlockGroup;
import net.coreprotect.thread.CacheHandler;
import net.coreprotect.utility.Util;
public final class BlockSpreadListener extends Queue implements Listener {
@ -81,14 +82,14 @@ public final class BlockSpreadListener extends Queue implements Listener {
}
private boolean checkCacheData(Block block, Material type) {
Location location = block.getLocation();
int timestamp = (int) (System.currentTimeMillis() / 1000L);
Object[] cacheData = CacheHandler.spreadCache.get(location);
CacheHandler.spreadCache.put(location, new Object[] { timestamp, type });
if (cacheData != null && ((Material) cacheData[1]) == type) {
return true;
int log = 0;
String cacheId = block.getX() + "." + block.getY() + "." + block.getZ() + "." + Util.getWorldId(block.getWorld().getName()) + "." + type.name();
if (CacheHandler.spreadCache.get(cacheId) == null) {
log = 1;
}
int timestamp = (int) (System.currentTimeMillis() / 1000L);
CacheHandler.spreadCache.put(cacheId, new Object[] { timestamp });
return false;
return (log == 0);
}
}

4
src/main/java/net/coreprotect/thread/CacheHandler.java
View File

@ -18,7 +18,7 @@ public class CacheHandler implements Runnable {
public static Map<String, Object[]> interactCache = Collections.synchronizedMap(new HashMap<>());
public static Map<String, Object[]> entityCache = Collections.synchronizedMap(new HashMap<>());
public static ConcurrentHashMap<String, Object[]> pistonCache = new ConcurrentHashMap<>(16, 0.75f, 2);
public static ConcurrentHashMap<Location, Object[]> spreadCache = new ConcurrentHashMap<>(16, 0.75f, 2);
public static ConcurrentHashMap<String, Object[]> spreadCache = new ConcurrentHashMap<>(16, 0.75f, 2);
public static ConcurrentHashMap<Location, Object[]> redstoneCache = new ConcurrentHashMap<>(16, 0.75f, 2);
@SuppressWarnings({ "unchecked", "rawtypes" })
@ -41,7 +41,7 @@ public class CacheHandler implements Runnable {
break;
case 3:
cache = CacheHandler.spreadCache;
scanTime = 900; // 15 minutes
scanTime = 1800; // 30 minutes
break;
case 4:
cache = CacheHandler.interactCache;