geforkt von Mirrors/FastAsyncWorldEdit
begin centralizing world height constants
Dieser Commit ist enthalten in:
Jesse Boyd
Ursprung
22a7ad7503
Commit
2c22f02c20
@ -22,6 +22,11 @@ import java.util.concurrent.ThreadPoolExecutor;
|
|||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
public class FaweCache implements Trimable {
|
public class FaweCache implements Trimable {
|
||||||
|
public static int CHUNK_LAYERS = 16;
|
||||||
|
public static int WORLD_HEIGHT = CHUNK_LAYERS << 4;
|
||||||
|
public static int WORLD_MAX_Y = WORLD_HEIGHT - 1;
|
||||||
|
|
||||||
|
|
||||||
public static final char[] EMPTY_CHAR_4096 = new char[4096];
|
public static final char[] EMPTY_CHAR_4096 = new char[4096];
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|||||||
@ -1,801 +0,0 @@
|
|||||||
package com.boydti.fawe.example;
|
|
||||||
|
|
||||||
import com.boydti.fawe.Fawe;
|
|
||||||
import com.boydti.fawe.FaweAPI;
|
|
||||||
import com.boydti.fawe.config.Settings;
|
|
||||||
import com.boydti.fawe.object.FaweChunk;
|
|
||||||
import com.boydti.fawe.object.FaweQueue;
|
|
||||||
import com.boydti.fawe.object.IntegerPair;
|
|
||||||
import com.boydti.fawe.object.RunnableVal;
|
|
||||||
import com.boydti.fawe.object.RunnableVal2;
|
|
||||||
import com.boydti.fawe.object.exception.FaweException;
|
|
||||||
import com.boydti.fawe.object.extent.LightingExtent;
|
|
||||||
import com.boydti.fawe.util.MathMan;
|
|
||||||
import com.boydti.fawe.util.SetQueue;
|
|
||||||
import com.boydti.fawe.util.TaskManager;
|
|
||||||
import com.sk89q.jnbt.CompoundTag;
|
|
||||||
import com.sk89q.worldedit.EditSession;
|
|
||||||
import com.sk89q.worldedit.world.World;
|
|
||||||
import com.sk89q.worldedit.world.biome.BiomeType;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockTypes;
|
|
||||||
|
|
||||||
import java.util.ArrayDeque;
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.HashSet;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.concurrent.ConcurrentLinkedDeque;
|
|
||||||
import java.util.concurrent.ForkJoinPool;
|
|
||||||
import java.util.concurrent.TimeUnit;
|
|
||||||
|
|
||||||
public abstract class MappedFaweQueue<WORLD, CHUNK, CHUNKSECTIONS, SECTION> implements LightingExtent, FaweQueue {
|
|
||||||
|
|
||||||
private WORLD impWorld;
|
|
||||||
|
|
||||||
private IFaweQueueMap map;
|
|
||||||
|
|
||||||
public int lastSectionX = Integer.MIN_VALUE;
|
|
||||||
public int lastSectionZ = Integer.MIN_VALUE;
|
|
||||||
public int lastSectionY = Integer.MIN_VALUE;
|
|
||||||
public CHUNK lastChunk;
|
|
||||||
public CHUNKSECTIONS lastChunkSections;
|
|
||||||
public SECTION lastSection;
|
|
||||||
|
|
||||||
|
|
||||||
private World weWorld;
|
|
||||||
private String world;
|
|
||||||
private ConcurrentLinkedDeque<EditSession> sessions;
|
|
||||||
private long modified = System.currentTimeMillis();
|
|
||||||
private RunnableVal2<FaweChunk, FaweChunk> changeTask;
|
|
||||||
private RunnableVal2<ProgressType, Integer> progressTask;
|
|
||||||
private SetQueue.QueueStage stage;
|
|
||||||
private Settings settings = Settings.IMP;
|
|
||||||
public ConcurrentLinkedDeque<Runnable> tasks = new ConcurrentLinkedDeque<>();
|
|
||||||
|
|
||||||
private CHUNK cachedLoadChunk;
|
|
||||||
public final RunnableVal<IntegerPair> loadChunk = new RunnableVal<IntegerPair>() {
|
|
||||||
|
|
||||||
{
|
|
||||||
this.value = new IntegerPair(0, 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void run(IntegerPair coord) {
|
|
||||||
cachedLoadChunk = loadChunk(getWorld(), coord.x, coord.z, true);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
public MappedFaweQueue(final World world) {
|
|
||||||
this(world, null);
|
|
||||||
}
|
|
||||||
|
|
||||||
public MappedFaweQueue(final String world) {
|
|
||||||
this.world = world;
|
|
||||||
map = getSettings().PREVENT_CRASHES ? new WeakFaweQueueMap(this) : new DefaultFaweQueueMap(this);
|
|
||||||
}
|
|
||||||
|
|
||||||
public MappedFaweQueue(final String world, IFaweQueueMap map) {
|
|
||||||
this.world = world;
|
|
||||||
if (map == null) {
|
|
||||||
map = getSettings().PREVENT_CRASHES ? new WeakFaweQueueMap(this) : new DefaultFaweQueueMap(this);
|
|
||||||
}
|
|
||||||
this.map = map;
|
|
||||||
}
|
|
||||||
|
|
||||||
public MappedFaweQueue(final World world, IFaweQueueMap map) {
|
|
||||||
this.weWorld = world;
|
|
||||||
if (world != null) this.world = world.getName();
|
|
||||||
if (map == null) {
|
|
||||||
map = getSettings().PREVENT_CRASHES ? new WeakFaweQueueMap(this) : new DefaultFaweQueueMap(this);
|
|
||||||
}
|
|
||||||
this.map = map;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getMaxY() {
|
|
||||||
return weWorld == null ? 255 : weWorld.getMaxY();
|
|
||||||
}
|
|
||||||
|
|
||||||
public IFaweQueueMap getFaweQueueMap() {
|
|
||||||
return map;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Collection<FaweChunk> getFaweChunks() {
|
|
||||||
return map.getFaweChunks();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void optimize() {
|
|
||||||
final ForkJoinPool pool = TaskManager.IMP.getPublicForkJoinPool();
|
|
||||||
map.forEachChunk(new RunnableVal<FaweChunk>() {
|
|
||||||
@Override
|
|
||||||
public void run(final FaweChunk chunk) {
|
|
||||||
pool.submit(chunk::optimize);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
pool.awaitQuiescence(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
|
|
||||||
}
|
|
||||||
|
|
||||||
public abstract WORLD getImpWorld();
|
|
||||||
|
|
||||||
public abstract boolean regenerateChunk(WORLD world, int x, int z, BiomeType biome, Long seed);
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public abstract FaweChunk getFaweChunk(int x, int z);
|
|
||||||
|
|
||||||
public abstract CHUNK loadChunk(WORLD world, int x, int z, boolean generate);
|
|
||||||
|
|
||||||
public abstract CHUNKSECTIONS getSections(CHUNK chunk);
|
|
||||||
|
|
||||||
public abstract CHUNKSECTIONS getCachedSections(WORLD world, int cx, int cz);
|
|
||||||
|
|
||||||
public abstract CHUNK getCachedChunk(WORLD world, int cx, int cz);
|
|
||||||
|
|
||||||
public WORLD getWorld() {
|
|
||||||
if (impWorld != null) {
|
|
||||||
return impWorld;
|
|
||||||
}
|
|
||||||
return impWorld = getImpWorld();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean regenerateChunk(int x, int z, BiomeType biome, Long seed) {
|
|
||||||
return regenerateChunk(getWorld(), x, z, biome, seed);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean setBlock(int x, int y, int z, int id) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk chunk = map.getFaweChunk(cx, cz);
|
|
||||||
chunk.setBlock(x & 15, y, z & 15, id);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setTile(int x, int y, int z, CompoundTag tag) {
|
|
||||||
if ((y >= FaweChunk.HEIGHT) || (y < 0)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk chunk = map.getFaweChunk(cx, cz);
|
|
||||||
chunk.setTile(x & 15, y, z & 15, tag);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setEntity(int x, int y, int z, CompoundTag tag) {
|
|
||||||
if ((y >= FaweChunk.HEIGHT) || (y < 0)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk chunk = map.getFaweChunk(cx, cz);
|
|
||||||
chunk.setEntity(tag);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void removeEntity(int x, int y, int z, UUID uuid) {
|
|
||||||
if ((y >= FaweChunk.HEIGHT) || (y < 0)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk chunk = map.getFaweChunk(cx, cz);
|
|
||||||
chunk.removeEntity(uuid);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean setBiome(int x, int z, BiomeType biome) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk chunk = map.getFaweChunk(cx, cz);
|
|
||||||
chunk.setBiome(x & 15, z & 15, biome);
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean next(int amount, long time) {
|
|
||||||
return map.next(amount, time);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void start(FaweChunk chunk) {
|
|
||||||
chunk.start();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void end(FaweChunk chunk) {
|
|
||||||
if (getProgressTask() != null) {
|
|
||||||
getProgressTask().run(ProgressType.DISPATCH, size() + 1);
|
|
||||||
}
|
|
||||||
chunk.end();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void runTasks() {
|
|
||||||
synchronized (this) {
|
|
||||||
this.notifyAll();
|
|
||||||
}
|
|
||||||
if (getProgressTask() != null) {
|
|
||||||
try {
|
|
||||||
getProgressTask().run(ProgressType.DONE, 1);
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
while (!tasks.isEmpty()) {
|
|
||||||
Runnable task = tasks.poll();
|
|
||||||
if (task != null) {
|
|
||||||
try {
|
|
||||||
task.run();
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (getProgressTask() != null) {
|
|
||||||
try {
|
|
||||||
getProgressTask().run(ProgressType.DONE, 1);
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
ArrayDeque<Runnable> tmp = new ArrayDeque<>(tasks);
|
|
||||||
tasks.clear();
|
|
||||||
for (Runnable run : tmp) {
|
|
||||||
try {
|
|
||||||
run.run();
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Settings getSettings() {
|
|
||||||
return settings;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setSettings(Settings settings) {
|
|
||||||
this.settings = settings == null ? Settings.IMP : settings;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setWorld(String world) {
|
|
||||||
this.world = world;
|
|
||||||
this.weWorld = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public World getWEWorld() {
|
|
||||||
return weWorld != null ? weWorld : (weWorld = FaweAPI.getWorld(world));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getWorldName() {
|
|
||||||
return world;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Collection<EditSession> getEditSessions() {
|
|
||||||
Collection<EditSession> tmp = sessions;
|
|
||||||
if (tmp == null) tmp = new HashSet<>();
|
|
||||||
return tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void addEditSession(EditSession session) {
|
|
||||||
ConcurrentLinkedDeque<EditSession> tmp = sessions;
|
|
||||||
if (tmp == null) tmp = new ConcurrentLinkedDeque<>();
|
|
||||||
tmp.add(session);
|
|
||||||
this.sessions = tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean supports(Capability capability) {
|
|
||||||
return capability == Capability.CHANGE_TASKS;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setSessions(ConcurrentLinkedDeque<EditSession> sessions) {
|
|
||||||
this.sessions = sessions;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public long getModified() {
|
|
||||||
return modified;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setModified(long modified) {
|
|
||||||
this.modified = modified;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public RunnableVal2<ProgressType, Integer> getProgressTask() {
|
|
||||||
return progressTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setProgressTask(RunnableVal2<ProgressType, Integer> progressTask) {
|
|
||||||
this.progressTask = progressTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setChangeTask(RunnableVal2<FaweChunk, FaweChunk> changeTask) {
|
|
||||||
this.changeTask = changeTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public RunnableVal2<FaweChunk, FaweChunk> getChangeTask() {
|
|
||||||
return changeTask;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public SetQueue.QueueStage getStage() {
|
|
||||||
return stage;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setStage(SetQueue.QueueStage stage) {
|
|
||||||
this.stage = stage;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void addNotifyTask(Runnable runnable) {
|
|
||||||
this.tasks.add(runnable);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void addTask(Runnable whenFree) {
|
|
||||||
tasks.add(whenFree);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int size() {
|
|
||||||
int size = map.size();
|
|
||||||
if (size == 0 && getStage() == SetQueue.QueueStage.NONE) {
|
|
||||||
runTasks();
|
|
||||||
}
|
|
||||||
return size;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void clear() {
|
|
||||||
lastSectionX = Integer.MIN_VALUE;
|
|
||||||
lastSectionZ = Integer.MIN_VALUE;
|
|
||||||
lastSectionY = -1;
|
|
||||||
lastChunk = null;
|
|
||||||
lastChunkSections = null;
|
|
||||||
map.clear();
|
|
||||||
runTasks();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setChunk(FaweChunk chunk) {
|
|
||||||
map.add(chunk);
|
|
||||||
}
|
|
||||||
|
|
||||||
public SECTION getCachedSection(CHUNKSECTIONS chunk, int cy) {
|
|
||||||
return (SECTION) lastChunkSections;
|
|
||||||
}
|
|
||||||
|
|
||||||
public abstract int getCombinedId4Data(SECTION section, int x, int y, int z);
|
|
||||||
|
|
||||||
public int getLocalCombinedId4Data(CHUNK chunk, int x, int y, int z) {
|
|
||||||
CHUNKSECTIONS sections = getSections(lastChunk);
|
|
||||||
SECTION section = getCachedSection(sections, y >> 4);
|
|
||||||
if (section == null) {
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
return getCombinedId4Data(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
public abstract BiomeType getBiome(CHUNK chunk, int x, int z);
|
|
||||||
|
|
||||||
public abstract CompoundTag getTileEntity(CHUNK chunk, int x, int y, int z);
|
|
||||||
|
|
||||||
public CHUNK ensureChunkLoaded(int cx, int cz) throws FaweException.FaweChunkLoadException {
|
|
||||||
CHUNK chunk = getCachedChunk(getWorld(), cx, cz);
|
|
||||||
if (chunk != null) {
|
|
||||||
return chunk;
|
|
||||||
}
|
|
||||||
boolean sync = Fawe.isMainThread();
|
|
||||||
if (sync) {
|
|
||||||
return loadChunk(getWorld(), cx, cz, true);
|
|
||||||
} else if (getSettings().HISTORY.CHUNK_WAIT_MS > 0) {
|
|
||||||
cachedLoadChunk = null;
|
|
||||||
loadChunk.value.x = cx;
|
|
||||||
loadChunk.value.z = cz;
|
|
||||||
TaskManager.IMP.syncWhenFree(loadChunk, getSettings().HISTORY.CHUNK_WAIT_MS);
|
|
||||||
return cachedLoadChunk;
|
|
||||||
} else {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean queueChunkLoad(final int cx, final int cz) {
|
|
||||||
CHUNK chunk = getCachedChunk(getWorld(), cx, cz);
|
|
||||||
if (chunk == null) {
|
|
||||||
SetQueue.IMP.addTask(() -> loadChunk(getWorld(), cx, cz, true));
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean queueChunkLoad(final int cx, final int cz, RunnableVal<CHUNK> operation) {
|
|
||||||
operation.value = getCachedChunk(getWorld(), cx, cz);
|
|
||||||
if (operation.value == null) {
|
|
||||||
SetQueue.IMP.addTask(() -> {
|
|
||||||
operation.value = loadChunk(getWorld(), cx, cz, true);
|
|
||||||
if (operation.value != null) TaskManager.IMP.async(operation);
|
|
||||||
});
|
|
||||||
return true;
|
|
||||||
} else {
|
|
||||||
TaskManager.IMP.async(operation);
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean hasBlock(int x, int y, int z) throws FaweException.FaweChunkLoadException {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
return hasBlock(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean hasBlock(SECTION section, int x, int y, int z) {
|
|
||||||
return getCombinedId4Data(lastSection, x, y, z) != 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getOpacity(SECTION section, int x, int y, int z) {
|
|
||||||
int combined = getCombinedId4Data(section, x, y, z);
|
|
||||||
if (combined == 0) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return Math.min(15, BlockTypes.getFromStateId(combined).getMaterial().getLightOpacity());
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getBrightness(SECTION section, int x, int y, int z) {
|
|
||||||
int combined = getCombinedId4Data(section, x, y, z);
|
|
||||||
if (combined == 0) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return Math.min(15, BlockTypes.getFromStateId(combined).getMaterial().getLightValue());
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getOpacityBrightnessPair(SECTION section, int x, int y, int z) {
|
|
||||||
return MathMan.pair16(Math.min(15, getOpacity(section, x, y, z)), getBrightness(section, x, y, z));
|
|
||||||
}
|
|
||||||
|
|
||||||
public abstract int getSkyLight(SECTION sections, int x, int y, int z);
|
|
||||||
|
|
||||||
public abstract int getEmmittedLight(SECTION sections, int x, int y, int z);
|
|
||||||
|
|
||||||
public int getLight(SECTION sections, int x, int y, int z) {
|
|
||||||
if (!hasSky()) {
|
|
||||||
return getEmmittedLight(sections, x, y, z);
|
|
||||||
}
|
|
||||||
return Math.max(getSkyLight(sections, x, y, z), getEmmittedLight(sections, x, y, z));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getLight(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return getLight(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getSkyLight(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
if (lastChunkSections == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
int max = FaweChunk.HEIGHT >> 4;
|
|
||||||
do {
|
|
||||||
if (++cy >= max) {
|
|
||||||
return 15;
|
|
||||||
}
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} while (lastSection == null);
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
|
|
||||||
return getSkyLight(x, y + 16, z);
|
|
||||||
}
|
|
||||||
return getSkyLight(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getBlockLight(int x, int y, int z) {
|
|
||||||
return getEmmittedLight(x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getEmmittedLight(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return getEmmittedLight(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getOpacity(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return getOpacity(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getOpacityBrightnessPair(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return getOpacityBrightnessPair(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getBrightness(int x, int y, int z) {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
return getBrightness(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getCachedCombinedId4Data(int x, int y, int z) throws FaweException.FaweChunkLoadException {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
FaweChunk fc = map.getCachedFaweChunk(cx, cz);
|
|
||||||
if (fc != null) {
|
|
||||||
int combined = fc.getBlockCombinedId(x & 15, y, z & 15);
|
|
||||||
if (combined != 0) {
|
|
||||||
return combined;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
return getCombinedId4Data(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getCombinedId4Data(int x, int y, int z) throws FaweException.FaweChunkLoadException {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
int cy = y >> 4;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
} else if (cy != lastSectionY) {
|
|
||||||
if (lastChunkSections != null) {
|
|
||||||
lastSection = getCachedSection(lastChunkSections, cy);
|
|
||||||
} else {
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (lastSection == null) {
|
|
||||||
return BlockTypes.AIR.getInternalId();
|
|
||||||
}
|
|
||||||
return getCombinedId4Data(lastSection, x, y, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BiomeType getBiomeType(int x, int z) throws FaweException.FaweChunkLoadException {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
lastSectionY = -1;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
} else if (lastChunk == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return getBiome(lastChunk, x, z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CompoundTag getTileEntity(int x, int y, int z) throws FaweException.FaweChunkLoadException {
|
|
||||||
int cx = x >> 4;
|
|
||||||
int cz = z >> 4;
|
|
||||||
lastSectionY = -1;
|
|
||||||
if (cx != lastSectionX || cz != lastSectionZ) {
|
|
||||||
lastSectionX = cx;
|
|
||||||
lastSectionZ = cz;
|
|
||||||
lastChunk = ensureChunkLoaded(cx, cz);
|
|
||||||
if (lastChunk != null) {
|
|
||||||
lastChunkSections = getSections(lastChunk);
|
|
||||||
} else {
|
|
||||||
lastChunkSections = null;
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
} else if (lastChunk == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return getTileEntity(lastChunk, x, y, z);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -2,12 +2,11 @@ package com.boydti.fawe.object.changeset;
|
|||||||
|
|
||||||
import com.boydti.fawe.Fawe;
|
import com.boydti.fawe.Fawe;
|
||||||
import com.boydti.fawe.FaweAPI;
|
import com.boydti.fawe.FaweAPI;
|
||||||
|
import com.boydti.fawe.FaweCache;
|
||||||
import com.boydti.fawe.config.Settings;
|
import com.boydti.fawe.config.Settings;
|
||||||
import com.boydti.fawe.logging.rollback.RollbackOptimizedHistory;
|
import com.boydti.fawe.logging.rollback.RollbackOptimizedHistory;
|
||||||
import com.boydti.fawe.object.FaweChunk;
|
|
||||||
import com.boydti.fawe.object.FawePlayer;
|
import com.boydti.fawe.object.FawePlayer;
|
||||||
import com.boydti.fawe.object.FaweQueue;
|
import com.boydti.fawe.object.FaweQueue;
|
||||||
import com.boydti.fawe.object.RunnableVal2;
|
|
||||||
import com.boydti.fawe.util.EditSessionBuilder;
|
import com.boydti.fawe.util.EditSessionBuilder;
|
||||||
import com.boydti.fawe.util.MainUtil;
|
import com.boydti.fawe.util.MainUtil;
|
||||||
import com.boydti.fawe.util.TaskManager;
|
import com.boydti.fawe.util.TaskManager;
|
||||||
@ -56,7 +55,7 @@ public abstract class FaweChangeSet implements ChangeSet {
|
|||||||
public FaweChangeSet(String world) {
|
public FaweChangeSet(String world) {
|
||||||
this.worldName = world;
|
this.worldName = world;
|
||||||
this.mainThread = (Fawe.get() == null) || Fawe.isMainThread();
|
this.mainThread = (Fawe.get() == null) || Fawe.isMainThread();
|
||||||
this.layers = FaweChunk.HEIGHT >> 4;
|
this.layers = FaweCache.CHUNK_LAYERS;
|
||||||
}
|
}
|
||||||
|
|
||||||
public FaweChangeSet(World world) {
|
public FaweChangeSet(World world) {
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
package com.boydti.fawe.object.collection;
|
package com.boydti.fawe.object.collection;
|
||||||
|
|
||||||
|
import com.boydti.fawe.FaweCache;
|
||||||
import com.sk89q.worldedit.math.BlockVector2;
|
import com.sk89q.worldedit.math.BlockVector2;
|
||||||
import com.sk89q.worldedit.math.BlockVector3;
|
import com.sk89q.worldedit.math.BlockVector3;
|
||||||
import com.sk89q.worldedit.math.MutableBlockVector2;
|
import com.sk89q.worldedit.math.MutableBlockVector2;
|
||||||
@ -20,7 +21,6 @@ import java.util.Set;
|
|||||||
* - Grouping / iteration is by chunk section, and the y>z>x order
|
* - Grouping / iteration is by chunk section, and the y>z>x order
|
||||||
*/
|
*/
|
||||||
public final class MemBlockSet extends BlockSet {
|
public final class MemBlockSet extends BlockSet {
|
||||||
private final static int CHUNK_LAYERS = 16;
|
|
||||||
private final static int BITS_PER_LAYER = 4096;
|
private final static int BITS_PER_LAYER = 4096;
|
||||||
private final static int BITS_PER_WORD = 6;
|
private final static int BITS_PER_WORD = 6;
|
||||||
private final static int WORDS = BITS_PER_LAYER >> BITS_PER_WORD;
|
private final static int WORDS = BITS_PER_LAYER >> BITS_PER_WORD;
|
||||||
@ -357,7 +357,7 @@ public final class MemBlockSet extends BlockSet {
|
|||||||
maxy = y + 1;
|
maxy = y + 1;
|
||||||
}
|
}
|
||||||
by = (Y << 4) + y;
|
by = (Y << 4) + y;
|
||||||
if (by == 255) return 255;
|
if (by == FaweCache.WORLD_MAX_Y) return FaweCache.WORLD_MAX_Y;
|
||||||
break outer;
|
break outer;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -825,8 +825,8 @@ public final class MemBlockSet extends BlockSet {
|
|||||||
private final IRow[] rows;
|
private final IRow[] rows;
|
||||||
|
|
||||||
public RowZ() {
|
public RowZ() {
|
||||||
this.rows = new IRow[CHUNK_LAYERS];
|
this.rows = new IRow[FaweCache.CHUNK_LAYERS];
|
||||||
for (int i = 0; i < CHUNK_LAYERS; i++) rows[i] = NULL_ROW_Y;
|
for (int i = 0; i < FaweCache.CHUNK_LAYERS; i++) rows[i] = NULL_ROW_Y;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren