Mirror von
https://github.com/IntellectualSites/FastAsyncWorldEdit.git
synchronisiert 2024-12-25 02:20:07 +01:00
Remove 1.13 and 1.14 code
Dieser Commit ist enthalten in:
MattBDev
Ursprung
9bef8d5664
Commit
a137d719cb
@ -1,8 +1,6 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter;
|
package com.boydti.fawe.bukkit.adapter;
|
||||||
|
|
||||||
import com.sk89q.worldedit.world.block.BlockID;
|
import com.sk89q.worldedit.world.block.BlockID;
|
||||||
import net.minecraft.server.v1_14_R1.ChunkSection;
|
|
||||||
|
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
|
|
||||||
public class NMSAdapter<T> {
|
public class NMSAdapter<T> {
|
||||||
|
|||||||
@ -1,153 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_13;
|
|
||||||
|
|
||||||
import com.sk89q.util.ReflectionUtil;
|
|
||||||
import com.sk89q.worldedit.world.registry.BlockMaterial;
|
|
||||||
import net.minecraft.server.v1_13_R2.Block;
|
|
||||||
import net.minecraft.server.v1_13_R2.EnumPistonReaction;
|
|
||||||
import net.minecraft.server.v1_13_R2.IBlockData;
|
|
||||||
import net.minecraft.server.v1_13_R2.ITileEntity;
|
|
||||||
import net.minecraft.server.v1_13_R2.Material;
|
|
||||||
import org.bukkit.craftbukkit.v1_13_R2.block.data.CraftBlockData;
|
|
||||||
|
|
||||||
public class BlockMaterial_1_13 implements BlockMaterial {
|
|
||||||
private final Block block;
|
|
||||||
private final IBlockData defaultState;
|
|
||||||
private final Material material;
|
|
||||||
private final boolean isTranslucent;
|
|
||||||
private final CraftBlockData craftBlockData;
|
|
||||||
private final org.bukkit.Material craftMaterial;
|
|
||||||
|
|
||||||
public BlockMaterial_1_13(Block block) {
|
|
||||||
this(block, block.getBlockData());
|
|
||||||
}
|
|
||||||
|
|
||||||
public BlockMaterial_1_13(Block block, IBlockData defaultState) {
|
|
||||||
this.block = block;
|
|
||||||
this.defaultState = defaultState;
|
|
||||||
this.material = defaultState.getMaterial();
|
|
||||||
this.craftBlockData = CraftBlockData.fromData(defaultState);
|
|
||||||
this.craftMaterial = craftBlockData.getMaterial();
|
|
||||||
this.isTranslucent = ReflectionUtil.getField(Block.class, block, "n");
|
|
||||||
}
|
|
||||||
|
|
||||||
public Block getBlock() {
|
|
||||||
return block;
|
|
||||||
}
|
|
||||||
|
|
||||||
public IBlockData getState() {
|
|
||||||
return defaultState;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CraftBlockData getCraftBlockData() {
|
|
||||||
return craftBlockData;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Material getMaterial() {
|
|
||||||
return material;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isAir() {
|
|
||||||
return defaultState.isAir();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isFullCube() {
|
|
||||||
return craftMaterial.isOccluding();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isOpaque() {
|
|
||||||
return material.f();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isPowerSource() {
|
|
||||||
return defaultState.isPowerSource();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isLiquid() {
|
|
||||||
return material.isLiquid();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isSolid() {
|
|
||||||
return material.isBuildable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getHardness() {
|
|
||||||
return block.strength;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getResistance() {
|
|
||||||
return block.getDurability();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getSlipperiness() {
|
|
||||||
return block.n();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getLightValue() {
|
|
||||||
return defaultState.e();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getLightOpacity() {
|
|
||||||
return isTranslucent() ? 15 : 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isFragileWhenPushed() {
|
|
||||||
return material.getPushReaction() == EnumPistonReaction.DESTROY;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isUnpushable() {
|
|
||||||
return material.getPushReaction() == EnumPistonReaction.BLOCK;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isTicksRandomly() {
|
|
||||||
return block.isTicking(defaultState);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isMovementBlocker() {
|
|
||||||
return material.isSolid();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isBurnable() {
|
|
||||||
return material.isBurnable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isToolRequired() {
|
|
||||||
return !material.isAlwaysDestroyable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isReplacedDuringPlacement() {
|
|
||||||
return material.isReplaceable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isTranslucent() {
|
|
||||||
return isTranslucent;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean hasContainer() {
|
|
||||||
return block instanceof ITileEntity;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getMapColor() {
|
|
||||||
return material.i().rgb;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,287 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_13;
|
|
||||||
|
|
||||||
import com.boydti.fawe.Fawe;
|
|
||||||
import com.boydti.fawe.FaweCache;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.DelegateLock;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.NMSAdapter;
|
|
||||||
import com.boydti.fawe.config.Settings;
|
|
||||||
import com.boydti.fawe.object.collection.BitArray4096;
|
|
||||||
import com.boydti.fawe.util.MathMan;
|
|
||||||
import com.boydti.fawe.util.TaskManager;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockState;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockTypesCache;
|
|
||||||
import io.papermc.lib.PaperLib;
|
|
||||||
import net.jpountz.util.UnsafeUtils;
|
|
||||||
import net.minecraft.server.v1_13_R2.Block;
|
|
||||||
import net.minecraft.server.v1_13_R2.Chunk;
|
|
||||||
import net.minecraft.server.v1_13_R2.ChunkCoordIntPair;
|
|
||||||
import net.minecraft.server.v1_13_R2.ChunkSection;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataBits;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPalette;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPaletteBlock;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPaletteLinear;
|
|
||||||
import net.minecraft.server.v1_13_R2.GameProfileSerializer;
|
|
||||||
import net.minecraft.server.v1_13_R2.IBlockData;
|
|
||||||
import net.minecraft.server.v1_13_R2.PlayerChunk;
|
|
||||||
import net.minecraft.server.v1_13_R2.PlayerChunkMap;
|
|
||||||
import org.bukkit.craftbukkit.v1_13_R2.CraftChunk;
|
|
||||||
import org.bukkit.craftbukkit.v1_13_R2.CraftWorld;
|
|
||||||
import sun.misc.Unsafe;
|
|
||||||
|
|
||||||
import java.lang.reflect.Field;
|
|
||||||
import java.lang.reflect.Modifier;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.concurrent.CompletableFuture;
|
|
||||||
import java.util.concurrent.locks.Lock;
|
|
||||||
import java.util.function.Function;
|
|
||||||
|
|
||||||
public final class BukkitAdapter_1_13 extends NMSAdapter {
|
|
||||||
/*
|
|
||||||
NMS fields
|
|
||||||
*/
|
|
||||||
public final static Field fieldBits;
|
|
||||||
public final static Field fieldPalette;
|
|
||||||
public final static Field fieldSize;
|
|
||||||
|
|
||||||
public final static Field fieldFluidCount;
|
|
||||||
public final static Field fieldTickingBlockCount;
|
|
||||||
public final static Field fieldNonEmptyBlockCount;
|
|
||||||
|
|
||||||
private final static Field fieldDirtyCount;
|
|
||||||
private final static Field fieldDirtyBits;
|
|
||||||
|
|
||||||
private static final int CHUNKSECTION_BASE;
|
|
||||||
private static final int CHUNKSECTION_SHIFT;
|
|
||||||
|
|
||||||
private static final Field fieldLock;
|
|
||||||
|
|
||||||
static {
|
|
||||||
try {
|
|
||||||
fieldSize = DataPaletteBlock.class.getDeclaredField("i");
|
|
||||||
fieldSize.setAccessible(true);
|
|
||||||
fieldBits = DataPaletteBlock.class.getDeclaredField("a");
|
|
||||||
fieldBits.setAccessible(true);
|
|
||||||
fieldPalette = DataPaletteBlock.class.getDeclaredField("h");
|
|
||||||
fieldPalette.setAccessible(true);
|
|
||||||
|
|
||||||
fieldFluidCount = ChunkSection.class.getDeclaredField("e");
|
|
||||||
fieldFluidCount.setAccessible(true);
|
|
||||||
fieldTickingBlockCount = ChunkSection.class.getDeclaredField("tickingBlockCount");
|
|
||||||
fieldTickingBlockCount.setAccessible(true);
|
|
||||||
fieldNonEmptyBlockCount = ChunkSection.class.getDeclaredField("nonEmptyBlockCount");
|
|
||||||
fieldNonEmptyBlockCount.setAccessible(true);
|
|
||||||
|
|
||||||
fieldDirtyCount = PlayerChunk.class.getDeclaredField("dirtyCount");
|
|
||||||
fieldDirtyCount.setAccessible(true);
|
|
||||||
fieldDirtyBits = PlayerChunk.class.getDeclaredField("h");
|
|
||||||
fieldDirtyBits.setAccessible(true);
|
|
||||||
|
|
||||||
{
|
|
||||||
Field tmp;
|
|
||||||
try {
|
|
||||||
tmp = DataPaletteBlock.class.getDeclaredField("writeLock");
|
|
||||||
} catch (NoSuchFieldException paper) {
|
|
||||||
tmp = DataPaletteBlock.class.getDeclaredField("j");
|
|
||||||
}
|
|
||||||
Field modifiersField = Field.class.getDeclaredField("modifiers");
|
|
||||||
modifiersField.setAccessible(true);
|
|
||||||
int modifiers = modifiersField.getInt(tmp);
|
|
||||||
int newModifiers = modifiers & (~Modifier.FINAL);
|
|
||||||
if (newModifiers != modifiers) modifiersField.setInt(tmp, newModifiers);
|
|
||||||
fieldLock = tmp;
|
|
||||||
fieldLock.setAccessible(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
Unsafe unsafe = UnsafeUtils.getUNSAFE();
|
|
||||||
CHUNKSECTION_BASE = unsafe.arrayBaseOffset(ChunkSection[].class);
|
|
||||||
int scale = unsafe.arrayIndexScale(ChunkSection[].class);
|
|
||||||
if ((scale & (scale - 1)) != 0)
|
|
||||||
throw new Error("data type scale not a power of two");
|
|
||||||
CHUNKSECTION_SHIFT = 31 - Integer.numberOfLeadingZeros(scale);
|
|
||||||
} catch (RuntimeException e) {
|
|
||||||
throw e;
|
|
||||||
} catch (Throwable rethrow) {
|
|
||||||
rethrow.printStackTrace();
|
|
||||||
throw new RuntimeException(rethrow);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static boolean setSectionAtomic(ChunkSection[] sections, ChunkSection expected, ChunkSection value, int layer) {
|
|
||||||
long offset = ((long) layer << CHUNKSECTION_SHIFT) + CHUNKSECTION_BASE;
|
|
||||||
if (layer >= 0 && layer < sections.length) {
|
|
||||||
return UnsafeUtils.getUNSAFE().compareAndSwapObject(sections, offset, expected, value);
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static DelegateLock applyLock(ChunkSection section) {
|
|
||||||
try {
|
|
||||||
synchronized (section) {
|
|
||||||
DataPaletteBlock<IBlockData> blocks = section.getBlocks();
|
|
||||||
Lock currentLock = (Lock) fieldLock.get(blocks);
|
|
||||||
if (currentLock instanceof DelegateLock) {
|
|
||||||
return (DelegateLock) currentLock;
|
|
||||||
}
|
|
||||||
DelegateLock newLock = new DelegateLock(currentLock);
|
|
||||||
fieldLock.set(blocks, newLock);
|
|
||||||
return newLock;
|
|
||||||
}
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public static Chunk ensureLoaded(net.minecraft.server.v1_13_R2.World nmsWorld, int X, int Z) {
|
|
||||||
Chunk nmsChunk = nmsWorld.getChunkIfLoaded(X, Z);
|
|
||||||
if (nmsChunk != null) {
|
|
||||||
return nmsChunk;
|
|
||||||
}
|
|
||||||
if (Fawe.isMainThread()) {
|
|
||||||
return nmsWorld.getChunkAt(X, Z);
|
|
||||||
}
|
|
||||||
if (PaperLib.isPaper()) {
|
|
||||||
CraftWorld craftWorld = nmsWorld.getWorld();
|
|
||||||
CompletableFuture<org.bukkit.Chunk> future = craftWorld.getChunkAtAsync(X, Z, true);
|
|
||||||
try {
|
|
||||||
CraftChunk chunk = (CraftChunk) future.get();
|
|
||||||
return chunk.getHandle();
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// TODO optimize
|
|
||||||
return TaskManager.IMP.sync(() -> nmsWorld.getChunkAt(X, Z));
|
|
||||||
}
|
|
||||||
|
|
||||||
public static PlayerChunk getPlayerChunk(net.minecraft.server.v1_13_R2.WorldServer nmsWorld, final int cx, final int cz) {
|
|
||||||
PlayerChunkMap chunkMap = nmsWorld.getPlayerChunkMap();
|
|
||||||
PlayerChunk playerChunk = chunkMap.getChunk(cx, cz);
|
|
||||||
if (playerChunk == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return playerChunk;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void sendChunk(net.minecraft.server.v1_13_R2.WorldServer nmsWorld, int X, int Z, int mask) {
|
|
||||||
PlayerChunk playerChunk = getPlayerChunk(nmsWorld, X, Z);
|
|
||||||
if (playerChunk == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (playerChunk.e()) {
|
|
||||||
Chunk nmsChunk = playerChunk.chunk;
|
|
||||||
ChunkSection[] sections = nmsChunk.getSections();
|
|
||||||
for (int layer = 0; layer < 16; layer++) {
|
|
||||||
if (sections[layer] == null && (mask & (1 << layer)) != 0) {
|
|
||||||
sections[layer] = new ChunkSection(layer << 4, nmsWorld.worldProvider.g());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
TaskManager.IMP.sync(() -> {
|
|
||||||
try {
|
|
||||||
int dirtyBits = fieldDirtyBits.getInt(playerChunk);
|
|
||||||
if (dirtyBits == 0) {
|
|
||||||
nmsWorld.getPlayerChunkMap().a(playerChunk);
|
|
||||||
}
|
|
||||||
if (mask == 0) {
|
|
||||||
dirtyBits = 65535;
|
|
||||||
} else {
|
|
||||||
dirtyBits |= mask;
|
|
||||||
}
|
|
||||||
|
|
||||||
fieldDirtyBits.set(playerChunk, dirtyBits);
|
|
||||||
fieldDirtyCount.set(playerChunk, 64);
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
NMS conversion
|
|
||||||
*/
|
|
||||||
public static ChunkSection newChunkSection(final int layer, final char[] blocks, boolean light) {
|
|
||||||
return newChunkSection(layer, null, blocks, light);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static ChunkSection newChunkSection(final int layer, final Function<Integer, char[]> get, char[] set, boolean light) {
|
|
||||||
if (set == null) {
|
|
||||||
return newChunkSection(layer, light);
|
|
||||||
}
|
|
||||||
final int[] blockToPalette = FaweCache.IMP.BLOCK_TO_PALETTE.get();
|
|
||||||
final int[] paletteToBlock = FaweCache.IMP.PALETTE_TO_BLOCK.get();
|
|
||||||
final long[] blockStates = FaweCache.IMP.BLOCK_STATES.get();
|
|
||||||
final int[] blocksCopy = FaweCache.IMP.SECTION_BLOCKS.get();
|
|
||||||
try {
|
|
||||||
int[] num_palette_buffer = new int[1];
|
|
||||||
int air;
|
|
||||||
if (get == null) {
|
|
||||||
air = createPalette(blockToPalette, paletteToBlock, blocksCopy, num_palette_buffer, set);
|
|
||||||
} else {
|
|
||||||
air = createPalette(layer, blockToPalette, paletteToBlock, blocksCopy, num_palette_buffer, get, set);
|
|
||||||
}
|
|
||||||
int num_palette = num_palette_buffer[0];
|
|
||||||
// BlockStates
|
|
||||||
int bitsPerEntry = MathMan.log2nlz(num_palette - 1);
|
|
||||||
if (Settings.IMP.PROTOCOL_SUPPORT_FIX || num_palette != 1) {
|
|
||||||
bitsPerEntry = Math.max(bitsPerEntry, 4); // Protocol support breaks <4 bits per entry
|
|
||||||
} else {
|
|
||||||
bitsPerEntry = Math.max(bitsPerEntry, 1); // For some reason minecraft needs 4096 bits to store 0 entries
|
|
||||||
}
|
|
||||||
|
|
||||||
final int blockBitArrayEnd = (bitsPerEntry * 4096) >> 6;
|
|
||||||
if (num_palette == 1) {
|
|
||||||
for (int i = 0; i < blockBitArrayEnd; i++) blockStates[i] = 0;
|
|
||||||
} else {
|
|
||||||
final BitArray4096 bitArray = new BitArray4096(blockStates, bitsPerEntry);
|
|
||||||
bitArray.fromRaw(blocksCopy);
|
|
||||||
}
|
|
||||||
|
|
||||||
ChunkSection section = newChunkSection(layer, light);
|
|
||||||
// set palette & data bits
|
|
||||||
final DataPaletteBlock<IBlockData> dataPaletteBlocks = section.getBlocks();
|
|
||||||
// private DataPalette<T> h;
|
|
||||||
// protected DataBits a;
|
|
||||||
final long[] bits = Arrays.copyOfRange(blockStates, 0, blockBitArrayEnd);
|
|
||||||
final DataBits nmsBits = new DataBits(bitsPerEntry, 4096, bits);
|
|
||||||
final DataPalette<IBlockData> palette;
|
|
||||||
// palette = new DataPaletteHash<>(Block.REGISTRY_ID, bitsPerEntry, dataPaletteBlocks, GameProfileSerializer::d, GameProfileSerializer::a);
|
|
||||||
palette = new DataPaletteLinear<>(Block.REGISTRY_ID, bitsPerEntry, dataPaletteBlocks, GameProfileSerializer::d);
|
|
||||||
|
|
||||||
// set palette
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
final int ordinal = paletteToBlock[i];
|
|
||||||
blockToPalette[ordinal] = Integer.MAX_VALUE;
|
|
||||||
final BlockState state = BlockTypesCache.states[ordinal];
|
|
||||||
final IBlockData ibd = ((BlockMaterial_1_13) state.getMaterial()).getState();
|
|
||||||
palette.a(ibd);
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
fieldBits.set(dataPaletteBlocks, nmsBits);
|
|
||||||
fieldPalette.set(dataPaletteBlocks, palette);
|
|
||||||
fieldSize.set(dataPaletteBlocks, bitsPerEntry);
|
|
||||||
setCount(0, 4096 - air, section);
|
|
||||||
} catch (final IllegalAccessException | NoSuchFieldException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
|
|
||||||
return section;
|
|
||||||
} catch (final Throwable e){
|
|
||||||
Arrays.fill(blockToPalette, Integer.MAX_VALUE);
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private static ChunkSection newChunkSection(int layer, boolean light) {
|
|
||||||
return new ChunkSection(layer << 4, light);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void setCount(final int tickingBlockCount, final int nonEmptyBlockCount, final ChunkSection section) throws NoSuchFieldException, IllegalAccessException {
|
|
||||||
fieldFluidCount.setShort(section, (short) 0); // TODO FIXME
|
|
||||||
fieldTickingBlockCount.setShort(section, (short) tickingBlockCount);
|
|
||||||
fieldNonEmptyBlockCount.setShort(section, (short) nonEmptyBlockCount);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,654 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_13;
|
|
||||||
|
|
||||||
import com.boydti.fawe.Fawe;
|
|
||||||
import com.boydti.fawe.FaweCache;
|
|
||||||
import com.boydti.fawe.beta.IChunkSet;
|
|
||||||
import com.boydti.fawe.beta.implementation.blocks.CharGetBlocks;
|
|
||||||
import com.boydti.fawe.beta.implementation.queue.QueueHandler;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.DelegateLock;
|
|
||||||
import com.boydti.fawe.object.collection.AdaptedMap;
|
|
||||||
import com.boydti.fawe.object.collection.BitArray4096;
|
|
||||||
import com.boydti.fawe.util.ReflectionUtils;
|
|
||||||
import com.google.common.base.Suppliers;
|
|
||||||
import com.google.common.collect.Iterables;
|
|
||||||
import com.sk89q.jnbt.CompoundTag;
|
|
||||||
import com.sk89q.jnbt.ListTag;
|
|
||||||
import com.sk89q.jnbt.LongTag;
|
|
||||||
import com.sk89q.jnbt.StringTag;
|
|
||||||
import com.sk89q.jnbt.Tag;
|
|
||||||
import com.sk89q.worldedit.bukkit.BukkitAdapter;
|
|
||||||
import com.sk89q.worldedit.bukkit.WorldEditPlugin;
|
|
||||||
import com.sk89q.worldedit.bukkit.adapter.BukkitImplAdapter;
|
|
||||||
import com.sk89q.worldedit.bukkit.adapter.impl.FAWE_Spigot_v1_13_R2;
|
|
||||||
import com.sk89q.worldedit.internal.Constants;
|
|
||||||
import com.sk89q.worldedit.math.BlockVector3;
|
|
||||||
import com.sk89q.worldedit.world.biome.BiomeType;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockTypes;
|
|
||||||
import net.minecraft.server.v1_13_R2.BiomeBase;
|
|
||||||
import net.minecraft.server.v1_13_R2.BlockPosition;
|
|
||||||
import net.minecraft.server.v1_13_R2.Chunk;
|
|
||||||
import net.minecraft.server.v1_13_R2.ChunkSection;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataBits;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPalette;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPaletteBlock;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPaletteHash;
|
|
||||||
import net.minecraft.server.v1_13_R2.DataPaletteLinear;
|
|
||||||
import net.minecraft.server.v1_13_R2.Entity;
|
|
||||||
import net.minecraft.server.v1_13_R2.EntityTypes;
|
|
||||||
import net.minecraft.server.v1_13_R2.IBlockData;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTTagCompound;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTTagInt;
|
|
||||||
import net.minecraft.server.v1_13_R2.TileEntity;
|
|
||||||
import net.minecraft.server.v1_13_R2.WorldServer;
|
|
||||||
import org.bukkit.World;
|
|
||||||
import org.bukkit.block.Biome;
|
|
||||||
import org.bukkit.craftbukkit.v1_13_R2.CraftWorld;
|
|
||||||
import org.bukkit.craftbukkit.v1_13_R2.block.CraftBlock;
|
|
||||||
import org.bukkit.event.entity.CreatureSpawnEvent;
|
|
||||||
import org.jetbrains.annotations.NotNull;
|
|
||||||
|
|
||||||
import javax.annotation.Nullable;
|
|
||||||
import java.util.AbstractSet;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.Iterator;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Set;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.concurrent.Callable;
|
|
||||||
import java.util.concurrent.Future;
|
|
||||||
import java.util.function.Function;
|
|
||||||
|
|
||||||
import static org.slf4j.LoggerFactory.getLogger;
|
|
||||||
|
|
||||||
public class BukkitGetBlocks_1_13 extends CharGetBlocks {
|
|
||||||
public ChunkSection[] sections;
|
|
||||||
public Chunk nmsChunk;
|
|
||||||
public WorldServer world;
|
|
||||||
public int X, Z;
|
|
||||||
|
|
||||||
public BukkitGetBlocks_1_13(World world, int X, int Z) {
|
|
||||||
this(((CraftWorld) world).getHandle(), X, Z);
|
|
||||||
}
|
|
||||||
|
|
||||||
public BukkitGetBlocks_1_13(WorldServer world, int X, int Z) {
|
|
||||||
this.world = world;
|
|
||||||
this.X = X;
|
|
||||||
this.Z = Z;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getX() {
|
|
||||||
return X;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getZ() {
|
|
||||||
return Z;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BiomeType getBiomeType(int x, int z) {
|
|
||||||
BiomeBase base = getChunk().getBiomeIndex()[(z << 4) + x];
|
|
||||||
return BukkitAdapter.adapt(CraftBlock.biomeBaseToBiome(base));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CompoundTag getTag(int x, int y, int z) {
|
|
||||||
TileEntity tileEntity = getChunk().getTileEntity(new BlockPosition((x & 15) + (X << 4), y, (z & 15) + (Z << 4)));
|
|
||||||
return new LazyCompoundTag_1_13(Suppliers.memoize(() -> tileEntity.save(new NBTTagCompound())));
|
|
||||||
}
|
|
||||||
|
|
||||||
private static final Function<BlockPosition, BlockVector3> posNms2We = new Function<BlockPosition, BlockVector3>() {
|
|
||||||
@Override
|
|
||||||
public BlockVector3 apply(BlockPosition v) {
|
|
||||||
return BlockVector3.at(v.getX(), v.getY(), v.getZ());
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
private final static Function<TileEntity, CompoundTag> nmsTile2We = new Function<TileEntity, CompoundTag>() {
|
|
||||||
@Override
|
|
||||||
public CompoundTag apply(TileEntity tileEntity) {
|
|
||||||
return new LazyCompoundTag_1_13(Suppliers.memoize(() -> tileEntity.save(new NBTTagCompound())));
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Map<BlockVector3, CompoundTag> getTiles() {
|
|
||||||
Map<BlockPosition, TileEntity> nmsTiles = getChunk().getTileEntities();
|
|
||||||
if (nmsTiles.isEmpty()) {
|
|
||||||
return Collections.emptyMap();
|
|
||||||
}
|
|
||||||
return AdaptedMap.immutable(nmsTiles, posNms2We, nmsTile2We);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CompoundTag getEntity(UUID uuid) {
|
|
||||||
Entity entity = world.getEntity(uuid);
|
|
||||||
if (entity != null) {
|
|
||||||
org.bukkit.entity.Entity bukkitEnt = entity.getBukkitEntity();
|
|
||||||
return BukkitAdapter.adapt(bukkitEnt).getState().getNbtData();
|
|
||||||
}
|
|
||||||
for (List<Entity> entry : getChunk().getEntitySlices()) {
|
|
||||||
if (entry != null) {
|
|
||||||
for (Entity ent : entry) {
|
|
||||||
if (uuid.equals(ent.getUniqueID())) {
|
|
||||||
org.bukkit.entity.Entity bukkitEnt = ent.getBukkitEntity();
|
|
||||||
return BukkitAdapter.adapt(bukkitEnt).getState().getNbtData();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Set<CompoundTag> getEntities() {
|
|
||||||
List<Entity>[] slices = getChunk().getEntitySlices();
|
|
||||||
int size = 0;
|
|
||||||
for (List<Entity> slice : slices) {
|
|
||||||
if (slice != null) size += slice.size();
|
|
||||||
}
|
|
||||||
if (slices.length == 0) {
|
|
||||||
return Collections.emptySet();
|
|
||||||
}
|
|
||||||
int finalSize = size;
|
|
||||||
return new AbstractSet<CompoundTag>() {
|
|
||||||
@Override
|
|
||||||
public int size() {
|
|
||||||
return finalSize;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isEmpty() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean contains(Object get) {
|
|
||||||
if (!(get instanceof CompoundTag)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
CompoundTag getTag = (CompoundTag) get;
|
|
||||||
Map<String, Tag> value = getTag.getValue();
|
|
||||||
CompoundTag getParts = (CompoundTag) value.get("UUID");
|
|
||||||
UUID getUUID = new UUID(getParts.getLong("Most"), getParts.getLong("Least"));
|
|
||||||
for (List<Entity> slice : slices) {
|
|
||||||
if (slice != null) {
|
|
||||||
for (Entity entity : slice) {
|
|
||||||
UUID uuid = entity.getUniqueID();
|
|
||||||
if (uuid.equals(getUUID)) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@NotNull
|
|
||||||
@Override
|
|
||||||
public Iterator<CompoundTag> iterator() {
|
|
||||||
Iterable<CompoundTag> result = Iterables.transform(Iterables.concat(slices), new com.google.common.base.Function<Entity, CompoundTag>() {
|
|
||||||
@Nullable
|
|
||||||
@Override
|
|
||||||
public CompoundTag apply(@Nullable Entity input) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
NBTTagCompound tag = new NBTTagCompound();
|
|
||||||
return (CompoundTag) adapter.toNative(input.save(tag));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
return result.iterator();
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
private void updateGet(BukkitGetBlocks_1_13 get, Chunk nmsChunk, ChunkSection[] sections, ChunkSection section, char[] arr, int layer) {
|
|
||||||
synchronized (get) {
|
|
||||||
if (this.nmsChunk != nmsChunk) {
|
|
||||||
this.nmsChunk = nmsChunk;
|
|
||||||
this.sections = sections.clone();
|
|
||||||
this.reset();
|
|
||||||
}
|
|
||||||
if (this.sections == null) {
|
|
||||||
this.sections = sections.clone();
|
|
||||||
}
|
|
||||||
if (this.sections[layer] != section) {
|
|
||||||
this.sections[layer] = section;
|
|
||||||
}
|
|
||||||
this.blocks[layer] = arr;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void removeEntity(Entity entity) {
|
|
||||||
entity.die();
|
|
||||||
entity.valid = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Chunk ensureLoaded(net.minecraft.server.v1_13_R2.World nmsWorld, int X, int Z) {
|
|
||||||
return BukkitAdapter_1_13.ensureLoaded(nmsWorld, X, Z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T extends Future<T>> T call(IChunkSet set, Runnable finalizer) {
|
|
||||||
try {
|
|
||||||
WorldServer nmsWorld = world;
|
|
||||||
boolean light = nmsWorld.worldProvider.g();
|
|
||||||
Chunk nmsChunk = ensureLoaded(nmsWorld, X, Z);
|
|
||||||
|
|
||||||
// Remove existing tiles
|
|
||||||
{
|
|
||||||
Map<BlockPosition, TileEntity> tiles = nmsChunk.getTileEntities();
|
|
||||||
if (!tiles.isEmpty()) {
|
|
||||||
final Iterator<Map.Entry<BlockPosition, TileEntity>> iterator = tiles.entrySet().iterator();
|
|
||||||
while (iterator.hasNext()) {
|
|
||||||
final Map.Entry<BlockPosition, TileEntity> entry = iterator.next();
|
|
||||||
final BlockPosition pos = entry.getKey();
|
|
||||||
final int lx = pos.getX() & 15;
|
|
||||||
final int ly = pos.getY();
|
|
||||||
final int lz = pos.getZ() & 15;
|
|
||||||
final int layer = ly >> 4;
|
|
||||||
if (!set.hasSection(layer)) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
if (set.getBlock(lx, ly, lz).getOrdinal() != 0) {
|
|
||||||
TileEntity tile = entry.getValue();
|
|
||||||
tile.y();
|
|
||||||
tile.invalidateBlockCache();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
int bitMask = 0;
|
|
||||||
synchronized (nmsChunk) {
|
|
||||||
ChunkSection[] sections = nmsChunk.getSections();
|
|
||||||
|
|
||||||
for (int layer = 0; layer < 16; layer++) {
|
|
||||||
if (!set.hasSection(layer)) continue;
|
|
||||||
|
|
||||||
bitMask |= 1 << layer;
|
|
||||||
|
|
||||||
char[] setArr = set.load(layer);
|
|
||||||
ChunkSection newSection;
|
|
||||||
ChunkSection existingSection = sections[layer];
|
|
||||||
if (existingSection == null) {
|
|
||||||
newSection = BukkitAdapter_1_13.newChunkSection(layer, setArr, light);
|
|
||||||
if (BukkitAdapter_1_13.setSectionAtomic(sections, null, newSection, layer)) {
|
|
||||||
updateGet(this, nmsChunk, sections, newSection, setArr, layer);
|
|
||||||
continue;
|
|
||||||
} else {
|
|
||||||
existingSection = sections[layer];
|
|
||||||
if (existingSection == null) {
|
|
||||||
System.out.println("Skipping invalid null section. chunk:" + X + "," + Z + " layer: " + layer);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
DelegateLock lock = BukkitAdapter_1_13.applyLock(existingSection);
|
|
||||||
synchronized (this) {
|
|
||||||
synchronized (lock) {
|
|
||||||
lock.untilFree();
|
|
||||||
ChunkSection getSection;
|
|
||||||
if (this.nmsChunk != nmsChunk) {
|
|
||||||
this.nmsChunk = nmsChunk;
|
|
||||||
this.sections = null;
|
|
||||||
this.reset();
|
|
||||||
} else {
|
|
||||||
getSection = this.getSections()[layer];
|
|
||||||
if (getSection != existingSection) {
|
|
||||||
this.sections[layer] = existingSection;
|
|
||||||
this.reset();
|
|
||||||
} else if (lock.isModified()) {
|
|
||||||
this.reset(layer);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
newSection = BukkitAdapter_1_13.newChunkSection(layer, this::load, setArr, light);
|
|
||||||
if (!BukkitAdapter_1_13.setSectionAtomic(sections, existingSection, newSection, layer)) {
|
|
||||||
System.out.println("Failed to set chunk section:" + X + "," + Z + " layer: " + layer);
|
|
||||||
continue;
|
|
||||||
} else {
|
|
||||||
updateGet(this, nmsChunk, sections, newSection, setArr, layer);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Biomes
|
|
||||||
BiomeType[] biomes = set.getBiomes();
|
|
||||||
if (biomes != null) {
|
|
||||||
// set biomes
|
|
||||||
final BiomeBase[] currentBiomes = nmsChunk.getBiomeIndex();
|
|
||||||
for (int i = 0; i < biomes.length; i++) {
|
|
||||||
final BiomeType biome = biomes[i];
|
|
||||||
if (biome != null) {
|
|
||||||
final Biome craftBiome = BukkitAdapter.adapt(biome);
|
|
||||||
currentBiomes[i] = CraftBlock.biomeToBiomeBase(craftBiome);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Runnable[] syncTasks = null;
|
|
||||||
|
|
||||||
int bx = X << 4;
|
|
||||||
int bz = Z << 4;
|
|
||||||
|
|
||||||
Set<UUID> entityRemoves = set.getEntityRemoves();
|
|
||||||
if (entityRemoves != null && !entityRemoves.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[3];
|
|
||||||
|
|
||||||
syncTasks[2] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
final List<Entity>[] entities = nmsChunk.getEntitySlices();
|
|
||||||
|
|
||||||
for (int i = 0; i < entities.length; i++) {
|
|
||||||
final Collection<Entity> ents = entities[i];
|
|
||||||
if (!ents.isEmpty()) {
|
|
||||||
final Iterator<Entity> iter = ents.iterator();
|
|
||||||
while (iter.hasNext()) {
|
|
||||||
final Entity entity = iter.next();
|
|
||||||
if (entityRemoves.contains(entity.getUniqueID())) {
|
|
||||||
iter.remove();
|
|
||||||
removeEntity(entity);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
Set<CompoundTag> entities = set.getEntities();
|
|
||||||
if (entities != null && !entities.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[2];
|
|
||||||
|
|
||||||
syncTasks[1] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
for (final CompoundTag nativeTag : entities) {
|
|
||||||
final Map<String, Tag> entityTagMap = ReflectionUtils.getMap(nativeTag.getValue());
|
|
||||||
final StringTag idTag = (StringTag) entityTagMap.get("Id");
|
|
||||||
final ListTag posTag = (ListTag) entityTagMap.get("Pos");
|
|
||||||
final ListTag rotTag = (ListTag) entityTagMap.get("Rotation");
|
|
||||||
if (idTag == null || posTag == null || rotTag == null) {
|
|
||||||
getLogger(BukkitGetBlocks_1_13.class).debug("Unknown entity tag: " + nativeTag);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
final double x = posTag.getDouble(0);
|
|
||||||
final double y = posTag.getDouble(1);
|
|
||||||
final double z = posTag.getDouble(2);
|
|
||||||
final float yaw = rotTag.getFloat(0);
|
|
||||||
final float pitch = rotTag.getFloat(1);
|
|
||||||
final String id = idTag.getValue();
|
|
||||||
|
|
||||||
EntityTypes<?> type = EntityTypes.a(id);
|
|
||||||
if (type != null) {
|
|
||||||
Entity entity = type.a(nmsWorld);
|
|
||||||
if (entity != null) {
|
|
||||||
UUID uuid = entity.getUniqueID();
|
|
||||||
entityTagMap.put("UUIDMost", new LongTag(uuid.getMostSignificantBits()));
|
|
||||||
entityTagMap.put("UUIDLeast", new LongTag(uuid.getLeastSignificantBits()));
|
|
||||||
if (nativeTag != null) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
final NBTTagCompound tag = (NBTTagCompound) adapter.fromNative(nativeTag);
|
|
||||||
for (final String name : Constants.NO_COPY_ENTITY_NBT_FIELDS) {
|
|
||||||
tag.remove(name);
|
|
||||||
}
|
|
||||||
entity.f(tag);
|
|
||||||
}
|
|
||||||
entity.setLocation(x, y, z, yaw, pitch);
|
|
||||||
nmsWorld.addEntity(entity, CreatureSpawnEvent.SpawnReason.CUSTOM);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// set tiles
|
|
||||||
Map<BlockVector3, CompoundTag> tiles = set.getTiles();
|
|
||||||
if (tiles != null && !tiles.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[1];
|
|
||||||
|
|
||||||
syncTasks[0] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
for (final Map.Entry<BlockVector3, CompoundTag> entry : tiles.entrySet()) {
|
|
||||||
final CompoundTag nativeTag = entry.getValue();
|
|
||||||
final BlockVector3 blockHash = entry.getKey();
|
|
||||||
final int x = blockHash.getX() + bx;
|
|
||||||
final int y = blockHash.getY();
|
|
||||||
final int z = blockHash.getZ() + bz;
|
|
||||||
final BlockPosition pos = new BlockPosition(x, y, z);
|
|
||||||
|
|
||||||
synchronized (nmsWorld) {
|
|
||||||
TileEntity tileEntity = nmsWorld.getTileEntity(pos);
|
|
||||||
if (tileEntity == null || tileEntity.x()) {
|
|
||||||
nmsWorld.n(pos);
|
|
||||||
tileEntity = nmsWorld.getTileEntity(pos);
|
|
||||||
}
|
|
||||||
if (tileEntity != null) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
final NBTTagCompound tag = (NBTTagCompound) adapter.fromNative(nativeTag);
|
|
||||||
tag.set("x", new NBTTagInt(x));
|
|
||||||
tag.set("y", new NBTTagInt(y));
|
|
||||||
tag.set("z", new NBTTagInt(z));
|
|
||||||
tileEntity.load(tag);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
// {//Lighting
|
|
||||||
// for (int layer = 0; layer < 16; layer++) {
|
|
||||||
// if (!set.hasSection(layer)) continue;
|
|
||||||
// //TODO lighting
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
|
|
||||||
Runnable callback;
|
|
||||||
if (bitMask == 0 && biomes == null) {
|
|
||||||
callback = null;
|
|
||||||
} else {
|
|
||||||
int finalMask = bitMask;
|
|
||||||
callback = () -> {
|
|
||||||
// Set Modified
|
|
||||||
nmsChunk.f(true); // Set Modified
|
|
||||||
nmsChunk.mustSave = true;
|
|
||||||
nmsChunk.markDirty();
|
|
||||||
// send to player
|
|
||||||
BukkitAdapter_1_13.sendChunk(nmsWorld, X, Z, finalMask);
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
};
|
|
||||||
}
|
|
||||||
if (syncTasks != null) {
|
|
||||||
QueueHandler queueHandler = Fawe.get().getQueueHandler();
|
|
||||||
Runnable[] finalSyncTasks = syncTasks;
|
|
||||||
|
|
||||||
// Chain the sync tasks and the callback
|
|
||||||
Callable<Future> chain = new Callable<Future>() {
|
|
||||||
@Override
|
|
||||||
public Future call() {
|
|
||||||
try {
|
|
||||||
// Run the sync tasks
|
|
||||||
for (int i = 0; i < finalSyncTasks.length; i++) {
|
|
||||||
Runnable task = finalSyncTasks[i];
|
|
||||||
if (task != null) {
|
|
||||||
task.run();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (callback == null) {
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
return null;
|
|
||||||
} else {
|
|
||||||
return queueHandler.async(callback, null);
|
|
||||||
}
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
return (T) (Future) queueHandler.sync(chain);
|
|
||||||
} else {
|
|
||||||
if (callback == null) {
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
} else {
|
|
||||||
callback.run();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public synchronized char[] update(int layer, char[] data) {
|
|
||||||
ChunkSection section = getSections()[layer];
|
|
||||||
// Section is null, return empty array
|
|
||||||
if (section == null) {
|
|
||||||
return FaweCache.IMP.EMPTY_CHAR_4096;
|
|
||||||
}
|
|
||||||
if (data == null || data == FaweCache.IMP.EMPTY_CHAR_4096) {
|
|
||||||
data = new char[4096];
|
|
||||||
}
|
|
||||||
DelegateLock lock = BukkitAdapter_1_13.applyLock(section);
|
|
||||||
synchronized (lock) {
|
|
||||||
lock.untilFree();
|
|
||||||
lock.setModified(false);
|
|
||||||
// Efficiently convert ChunkSection to raw data
|
|
||||||
try {
|
|
||||||
FAWE_Spigot_v1_13_R2 adapter = ((FAWE_Spigot_v1_13_R2) WorldEditPlugin.getInstance().getBukkitImplAdapter());
|
|
||||||
|
|
||||||
final DataPaletteBlock<IBlockData> blocks = section.getBlocks();
|
|
||||||
final DataBits bits = (DataBits) BukkitAdapter_1_13.fieldBits.get(blocks);
|
|
||||||
final DataPalette<IBlockData> palette = (DataPalette<IBlockData>) BukkitAdapter_1_13.fieldPalette.get(blocks);
|
|
||||||
|
|
||||||
final int bitsPerEntry = bits.c();
|
|
||||||
final long[] blockStates = bits.a();
|
|
||||||
|
|
||||||
new BitArray4096(blockStates, bitsPerEntry).toRaw(data);
|
|
||||||
|
|
||||||
int num_palette;
|
|
||||||
if (palette instanceof DataPaletteLinear) {
|
|
||||||
num_palette = ((DataPaletteLinear<IBlockData>) palette).b();
|
|
||||||
} else if (palette instanceof DataPaletteHash) {
|
|
||||||
num_palette = ((DataPaletteHash<IBlockData>) palette).b();
|
|
||||||
} else {
|
|
||||||
num_palette = 0;
|
|
||||||
int[] paletteToBlockInts = FaweCache.IMP.PALETTE_TO_BLOCK.get();
|
|
||||||
char[] paletteToBlockChars = FaweCache.IMP.PALETTE_TO_BLOCK_CHAR.get();
|
|
||||||
try {
|
|
||||||
for (int i = 0; i < 4096; i++) {
|
|
||||||
char paletteVal = data[i];
|
|
||||||
char ordinal = paletteToBlockChars[paletteVal];
|
|
||||||
if (ordinal == Character.MAX_VALUE) {
|
|
||||||
paletteToBlockInts[num_palette++] = paletteVal;
|
|
||||||
IBlockData ibd = palette.a(data[i]);
|
|
||||||
if (ibd == null) {
|
|
||||||
ordinal = BlockTypes.AIR.getDefaultState().getOrdinalChar();
|
|
||||||
} else {
|
|
||||||
ordinal = adapter.adaptToChar(ibd);
|
|
||||||
}
|
|
||||||
paletteToBlockChars[paletteVal] = ordinal;
|
|
||||||
}
|
|
||||||
data[i] = ordinal;
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
int paletteVal = paletteToBlockInts[i];
|
|
||||||
paletteToBlockChars[paletteVal] = Character.MAX_VALUE;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return data;
|
|
||||||
}
|
|
||||||
|
|
||||||
char[] paletteToOrdinal = FaweCache.IMP.PALETTE_TO_BLOCK_CHAR.get();
|
|
||||||
try {
|
|
||||||
if (num_palette != 1) {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
char ordinal = ordinal(palette.a(i), adapter);
|
|
||||||
paletteToOrdinal[i] = ordinal;
|
|
||||||
}
|
|
||||||
for (int i = 0; i < 4096; i++) {
|
|
||||||
char paletteVal = data[i];
|
|
||||||
char val = paletteToOrdinal[paletteVal];
|
|
||||||
if (val == Character.MAX_VALUE) {
|
|
||||||
val = ordinal(palette.a(i), adapter);
|
|
||||||
paletteToOrdinal[i] = val;
|
|
||||||
}
|
|
||||||
data[i] = val;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
char ordinal = ordinal(palette.a(0), adapter);
|
|
||||||
Arrays.fill(data, ordinal);
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
paletteToOrdinal[i] = Character.MAX_VALUE;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return data;
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private final char ordinal(IBlockData ibd, FAWE_Spigot_v1_13_R2 adapter) {
|
|
||||||
if (ibd == null) {
|
|
||||||
return BlockTypes.AIR.getDefaultState().getOrdinalChar();
|
|
||||||
} else {
|
|
||||||
return adapter.adaptToChar(ibd);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public ChunkSection[] getSections() {
|
|
||||||
ChunkSection[] tmp = sections;
|
|
||||||
if (tmp == null) {
|
|
||||||
synchronized (this) {
|
|
||||||
tmp = sections;
|
|
||||||
if (tmp == null) {
|
|
||||||
Chunk chunk = getChunk();
|
|
||||||
sections = tmp = chunk.getSections().clone();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Chunk getChunk() {
|
|
||||||
Chunk tmp = nmsChunk;
|
|
||||||
if (tmp == null) {
|
|
||||||
synchronized (this) {
|
|
||||||
tmp = nmsChunk;
|
|
||||||
if (tmp == null) {
|
|
||||||
nmsChunk = tmp = ensureLoaded(this.world, X, Z);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean hasSection(int layer) {
|
|
||||||
return getSections()[layer] != null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean trim(boolean aggressive) {
|
|
||||||
if (aggressive) {
|
|
||||||
sections = null;
|
|
||||||
nmsChunk = null;
|
|
||||||
}
|
|
||||||
return super.trim(aggressive);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,152 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_13;
|
|
||||||
|
|
||||||
import com.sk89q.jnbt.CompoundTag;
|
|
||||||
import com.sk89q.jnbt.ListTag;
|
|
||||||
import com.sk89q.jnbt.StringTag;
|
|
||||||
import com.sk89q.jnbt.Tag;
|
|
||||||
import com.sk89q.worldedit.bukkit.WorldEditPlugin;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTBase;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTNumber;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTTagCompound;
|
|
||||||
import net.minecraft.server.v1_13_R2.NBTTagList;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.function.Supplier;
|
|
||||||
|
|
||||||
public class LazyCompoundTag_1_13 extends CompoundTag {
|
|
||||||
private final Supplier<NBTTagCompound> nmsTag;
|
|
||||||
|
|
||||||
public LazyCompoundTag_1_13(Supplier<NBTTagCompound> tag) {
|
|
||||||
super(null);
|
|
||||||
this.nmsTag = tag;
|
|
||||||
}
|
|
||||||
|
|
||||||
public LazyCompoundTag_1_13(NBTTagCompound tag) {
|
|
||||||
this(() -> tag);
|
|
||||||
}
|
|
||||||
|
|
||||||
public NBTTagCompound get() {
|
|
||||||
return nmsTag.get();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Map<String, Tag> getValue() {
|
|
||||||
Map<String, Tag> value = super.getValue();
|
|
||||||
if (value == null) {
|
|
||||||
Tag tag = WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(nmsTag.get());
|
|
||||||
setValue(((CompoundTag) tag).getValue());
|
|
||||||
}
|
|
||||||
return super.getValue();
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean containsKey(String key) {
|
|
||||||
return nmsTag.get().hasKey(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public byte[] getByteArray(String key) {
|
|
||||||
return nmsTag.get().getByteArray(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public byte getByte(String key) {
|
|
||||||
return nmsTag.get().getByte(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public double getDouble(String key) {
|
|
||||||
return nmsTag.get().getDouble(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public double asDouble(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asDouble();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public float getFloat(String key) {
|
|
||||||
return nmsTag.get().getFloat(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int[] getIntArray(String key) {
|
|
||||||
return nmsTag.get().getIntArray(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getInt(String key) {
|
|
||||||
return nmsTag.get().getInt(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int asInt(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asInt();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<Tag> getList(String key) {
|
|
||||||
NBTBase tag = nmsTag.get().get(key);
|
|
||||||
if (tag instanceof NBTTagList) {
|
|
||||||
ArrayList<Tag> list = new ArrayList<>();
|
|
||||||
NBTTagList nbtList = (NBTTagList) tag;
|
|
||||||
for (NBTBase elem : nbtList) {
|
|
||||||
if (elem instanceof NBTTagCompound) {
|
|
||||||
list.add(new LazyCompoundTag_1_13((NBTTagCompound) elem));
|
|
||||||
} else {
|
|
||||||
list.add(WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(elem));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return list;
|
|
||||||
}
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
|
|
||||||
public ListTag getListTag(String key) {
|
|
||||||
NBTBase tag = nmsTag.get().get(key);
|
|
||||||
if (tag instanceof NBTTagList) {
|
|
||||||
return (ListTag) WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(tag);
|
|
||||||
}
|
|
||||||
return new ListTag(StringTag.class, Collections.<Tag>emptyList());
|
|
||||||
}
|
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public <T extends Tag> List<T> getList(String key, Class<T> listType) {
|
|
||||||
ListTag listTag = getListTag(key);
|
|
||||||
if (listTag.getType().equals(listType)) {
|
|
||||||
return (List<T>) listTag.getValue();
|
|
||||||
} else {
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public long[] getLongArray(String key) {
|
|
||||||
return nmsTag.get().o(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public long getLong(String key) {
|
|
||||||
return nmsTag.get().getLong(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public long asLong(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asLong();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public short getShort(String key) {
|
|
||||||
return nmsTag.get().getShort(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getString(String key) {
|
|
||||||
return nmsTag.get().getString(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String toString() {
|
|
||||||
return nmsTag.get().toString();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,27 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_13;
|
|
||||||
|
|
||||||
import com.boydti.fawe.bukkit.adapter.MapChunkUtil;
|
|
||||||
import net.minecraft.server.v1_13_R2.PacketPlayOutMapChunk;
|
|
||||||
|
|
||||||
public class MapChunkUtil_1_13 extends MapChunkUtil<PacketPlayOutMapChunk> {
|
|
||||||
public MapChunkUtil_1_13() throws NoSuchFieldException {
|
|
||||||
fieldX = PacketPlayOutMapChunk.class.getDeclaredField("a");
|
|
||||||
fieldZ = PacketPlayOutMapChunk.class.getDeclaredField("b");
|
|
||||||
fieldBitMask = PacketPlayOutMapChunk.class.getDeclaredField("c");
|
|
||||||
fieldChunkData = PacketPlayOutMapChunk.class.getDeclaredField("d");
|
|
||||||
fieldBlockEntities = PacketPlayOutMapChunk.class.getDeclaredField("e");
|
|
||||||
fieldFull = PacketPlayOutMapChunk.class.getDeclaredField("f");
|
|
||||||
|
|
||||||
fieldX.setAccessible(true);
|
|
||||||
fieldZ.setAccessible(true);
|
|
||||||
fieldBitMask.setAccessible(true);
|
|
||||||
fieldChunkData.setAccessible(true);
|
|
||||||
fieldBlockEntities.setAccessible(true);
|
|
||||||
fieldFull.setAccessible(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PacketPlayOutMapChunk createPacket() {
|
|
||||||
return new PacketPlayOutMapChunk();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,153 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_14;
|
|
||||||
|
|
||||||
import com.sk89q.util.ReflectionUtil;
|
|
||||||
import com.sk89q.worldedit.world.registry.BlockMaterial;
|
|
||||||
import net.minecraft.server.v1_14_R1.Block;
|
|
||||||
import net.minecraft.server.v1_14_R1.EnumPistonReaction;
|
|
||||||
import net.minecraft.server.v1_14_R1.IBlockData;
|
|
||||||
import net.minecraft.server.v1_14_R1.ITileEntity;
|
|
||||||
import net.minecraft.server.v1_14_R1.Material;
|
|
||||||
import org.bukkit.craftbukkit.v1_14_R1.block.data.CraftBlockData;
|
|
||||||
|
|
||||||
public class BlockMaterial_1_14 implements BlockMaterial {
|
|
||||||
private final Block block;
|
|
||||||
private final IBlockData defaultState;
|
|
||||||
private final Material material;
|
|
||||||
private final boolean isTranslucent;
|
|
||||||
private final CraftBlockData craftBlockData;
|
|
||||||
private final org.bukkit.Material craftMaterial;
|
|
||||||
|
|
||||||
public BlockMaterial_1_14(Block block) {
|
|
||||||
this(block, block.getBlockData());
|
|
||||||
}
|
|
||||||
|
|
||||||
public BlockMaterial_1_14(Block block, IBlockData defaultState) {
|
|
||||||
this.block = block;
|
|
||||||
this.defaultState = defaultState;
|
|
||||||
this.material = defaultState.getMaterial();
|
|
||||||
this.craftBlockData = CraftBlockData.fromData(defaultState);
|
|
||||||
this.craftMaterial = craftBlockData.getMaterial();
|
|
||||||
this.isTranslucent = ReflectionUtil.getField(Block.class, block, "v");
|
|
||||||
}
|
|
||||||
|
|
||||||
public Block getBlock() {
|
|
||||||
return block;
|
|
||||||
}
|
|
||||||
|
|
||||||
public IBlockData getState() {
|
|
||||||
return defaultState;
|
|
||||||
}
|
|
||||||
|
|
||||||
public CraftBlockData getCraftBlockData() {
|
|
||||||
return craftBlockData;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Material getMaterial() {
|
|
||||||
return material;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isAir() {
|
|
||||||
return defaultState.isAir();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isFullCube() {
|
|
||||||
return craftMaterial.isOccluding();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isOpaque() {
|
|
||||||
return material.f();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isPowerSource() {
|
|
||||||
return defaultState.isPowerSource();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isLiquid() {
|
|
||||||
return material.isLiquid();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isSolid() {
|
|
||||||
return material.isBuildable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getHardness() {
|
|
||||||
return block.strength;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getResistance() {
|
|
||||||
return block.getDurability();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public float getSlipperiness() {
|
|
||||||
return block.m();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getLightValue() {
|
|
||||||
return defaultState.h();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getLightOpacity() {
|
|
||||||
return isTranslucent() ? 15 : 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isFragileWhenPushed() {
|
|
||||||
return material.getPushReaction() == EnumPistonReaction.DESTROY;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isUnpushable() {
|
|
||||||
return material.getPushReaction() == EnumPistonReaction.BLOCK;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isTicksRandomly() {
|
|
||||||
return block.isTicking(defaultState);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isMovementBlocker() {
|
|
||||||
return material.isSolid();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isBurnable() {
|
|
||||||
return material.isBurnable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isToolRequired() {
|
|
||||||
return !material.isAlwaysDestroyable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isReplacedDuringPlacement() {
|
|
||||||
return material.isReplaceable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isTranslucent() {
|
|
||||||
return isTranslucent;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean hasContainer() {
|
|
||||||
return block instanceof ITileEntity;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int getMapColor() {
|
|
||||||
return material.i().rgb;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,280 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_14;
|
|
||||||
|
|
||||||
import com.boydti.fawe.Fawe;
|
|
||||||
import com.boydti.fawe.FaweCache;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.NMSAdapter;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.DelegateLock;
|
|
||||||
import com.boydti.fawe.config.Settings;
|
|
||||||
import com.boydti.fawe.object.collection.BitArray4096;
|
|
||||||
import com.boydti.fawe.util.MathMan;
|
|
||||||
import com.boydti.fawe.util.TaskManager;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockState;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockTypesCache;
|
|
||||||
import io.papermc.lib.PaperLib;
|
|
||||||
import net.jpountz.util.UnsafeUtils;
|
|
||||||
import net.minecraft.server.v1_14_R1.Block;
|
|
||||||
import net.minecraft.server.v1_14_R1.Chunk;
|
|
||||||
import net.minecraft.server.v1_14_R1.ChunkCoordIntPair;
|
|
||||||
import net.minecraft.server.v1_14_R1.ChunkSection;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataBits;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPalette;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPaletteBlock;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPaletteLinear;
|
|
||||||
import net.minecraft.server.v1_14_R1.GameProfileSerializer;
|
|
||||||
import net.minecraft.server.v1_14_R1.IBlockData;
|
|
||||||
import net.minecraft.server.v1_14_R1.PlayerChunk;
|
|
||||||
import net.minecraft.server.v1_14_R1.PlayerChunkMap;
|
|
||||||
import org.bukkit.craftbukkit.v1_14_R1.CraftChunk;
|
|
||||||
import org.bukkit.craftbukkit.v1_14_R1.CraftWorld;
|
|
||||||
import sun.misc.Unsafe;
|
|
||||||
|
|
||||||
import java.lang.reflect.Field;
|
|
||||||
import java.lang.reflect.Modifier;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.concurrent.CompletableFuture;
|
|
||||||
import java.util.concurrent.locks.Lock;
|
|
||||||
import java.util.function.Function;
|
|
||||||
|
|
||||||
public final class BukkitAdapter_1_14 extends NMSAdapter {
|
|
||||||
/*
|
|
||||||
NMS fields
|
|
||||||
*/
|
|
||||||
public final static Field fieldBits;
|
|
||||||
public final static Field fieldPalette;
|
|
||||||
public final static Field fieldSize;
|
|
||||||
|
|
||||||
public final static Field fieldFluidCount;
|
|
||||||
public final static Field fieldTickingBlockCount;
|
|
||||||
public final static Field fieldNonEmptyBlockCount;
|
|
||||||
|
|
||||||
private final static Field fieldDirtyCount;
|
|
||||||
private final static Field fieldDirtyBits;
|
|
||||||
|
|
||||||
private static final int CHUNKSECTION_BASE;
|
|
||||||
private static final int CHUNKSECTION_SHIFT;
|
|
||||||
|
|
||||||
private static final Field fieldLock;
|
|
||||||
|
|
||||||
static {
|
|
||||||
try {
|
|
||||||
fieldSize = DataPaletteBlock.class.getDeclaredField("i");
|
|
||||||
fieldSize.setAccessible(true);
|
|
||||||
fieldBits = DataPaletteBlock.class.getDeclaredField("a");
|
|
||||||
fieldBits.setAccessible(true);
|
|
||||||
fieldPalette = DataPaletteBlock.class.getDeclaredField("h");
|
|
||||||
fieldPalette.setAccessible(true);
|
|
||||||
|
|
||||||
fieldFluidCount = ChunkSection.class.getDeclaredField("e");
|
|
||||||
fieldFluidCount.setAccessible(true);
|
|
||||||
fieldTickingBlockCount = ChunkSection.class.getDeclaredField("tickingBlockCount");
|
|
||||||
fieldTickingBlockCount.setAccessible(true);
|
|
||||||
fieldNonEmptyBlockCount = ChunkSection.class.getDeclaredField("nonEmptyBlockCount");
|
|
||||||
fieldNonEmptyBlockCount.setAccessible(true);
|
|
||||||
|
|
||||||
fieldDirtyCount = PlayerChunk.class.getDeclaredField("dirtyCount");
|
|
||||||
fieldDirtyCount.setAccessible(true);
|
|
||||||
fieldDirtyBits = PlayerChunk.class.getDeclaredField("r");
|
|
||||||
fieldDirtyBits.setAccessible(true);
|
|
||||||
|
|
||||||
{
|
|
||||||
Field tmp;
|
|
||||||
try {
|
|
||||||
tmp = DataPaletteBlock.class.getDeclaredField("writeLock");
|
|
||||||
} catch (NoSuchFieldException paper) {
|
|
||||||
tmp = DataPaletteBlock.class.getDeclaredField("j");
|
|
||||||
}
|
|
||||||
Field modifiersField = Field.class.getDeclaredField("modifiers");
|
|
||||||
modifiersField.setAccessible(true);
|
|
||||||
int modifiers = modifiersField.getInt(tmp);
|
|
||||||
int newModifiers = modifiers & (~Modifier.FINAL);
|
|
||||||
if (newModifiers != modifiers) modifiersField.setInt(tmp, newModifiers);
|
|
||||||
fieldLock = tmp;
|
|
||||||
fieldLock.setAccessible(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
Unsafe unsafe = UnsafeUtils.getUNSAFE();
|
|
||||||
CHUNKSECTION_BASE = unsafe.arrayBaseOffset(ChunkSection[].class);
|
|
||||||
int scale = unsafe.arrayIndexScale(ChunkSection[].class);
|
|
||||||
if ((scale & (scale - 1)) != 0)
|
|
||||||
throw new Error("data type scale not a power of two");
|
|
||||||
CHUNKSECTION_SHIFT = 31 - Integer.numberOfLeadingZeros(scale);
|
|
||||||
} catch (RuntimeException e) {
|
|
||||||
throw e;
|
|
||||||
} catch (Throwable rethrow) {
|
|
||||||
rethrow.printStackTrace();
|
|
||||||
throw new RuntimeException(rethrow);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static boolean setSectionAtomic(ChunkSection[] sections, ChunkSection expected, ChunkSection value, int layer) {
|
|
||||||
long offset = ((long) layer << CHUNKSECTION_SHIFT) + CHUNKSECTION_BASE;
|
|
||||||
if (layer >= 0 && layer < sections.length) {
|
|
||||||
return UnsafeUtils.getUNSAFE().compareAndSwapObject(sections, offset, expected, value);
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected static DelegateLock applyLock(ChunkSection section) {
|
|
||||||
try {
|
|
||||||
synchronized (section) {
|
|
||||||
DataPaletteBlock<IBlockData> blocks = section.getBlocks();
|
|
||||||
Lock currentLock = (Lock) fieldLock.get(blocks);
|
|
||||||
if (currentLock instanceof DelegateLock) {
|
|
||||||
return (DelegateLock) currentLock;
|
|
||||||
}
|
|
||||||
DelegateLock newLock = new DelegateLock(currentLock);
|
|
||||||
fieldLock.set(blocks, newLock);
|
|
||||||
return newLock;
|
|
||||||
}
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public static Chunk ensureLoaded(net.minecraft.server.v1_14_R1.World nmsWorld, int X, int Z) {
|
|
||||||
Chunk nmsChunk = nmsWorld.getChunkIfLoaded(X, Z);
|
|
||||||
if (nmsChunk != null) {
|
|
||||||
return nmsChunk;
|
|
||||||
}
|
|
||||||
if (Fawe.isMainThread()) {
|
|
||||||
return nmsWorld.getChunkAt(X, Z);
|
|
||||||
}
|
|
||||||
if (PaperLib.isPaper()) {
|
|
||||||
CraftWorld craftWorld = nmsWorld.getWorld();
|
|
||||||
CompletableFuture<org.bukkit.Chunk> future = craftWorld.getChunkAtAsync(X, Z, true);
|
|
||||||
try {
|
|
||||||
CraftChunk chunk = (CraftChunk) future.get();
|
|
||||||
return chunk.getHandle();
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// TODO optimize
|
|
||||||
return TaskManager.IMP.sync(() -> nmsWorld.getChunkAt(X, Z));
|
|
||||||
}
|
|
||||||
|
|
||||||
public static PlayerChunk getPlayerChunk(net.minecraft.server.v1_14_R1.WorldServer nmsWorld, final int cx, final int cz) {
|
|
||||||
PlayerChunkMap chunkMap = nmsWorld.getChunkProvider().playerChunkMap;
|
|
||||||
PlayerChunk playerChunk = chunkMap.visibleChunks.get(ChunkCoordIntPair.pair(cx, cz));
|
|
||||||
if (playerChunk == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return playerChunk;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void sendChunk(net.minecraft.server.v1_14_R1.WorldServer nmsWorld, int X, int Z, int mask) {
|
|
||||||
PlayerChunk playerChunk = getPlayerChunk(nmsWorld, X, Z);
|
|
||||||
if (playerChunk == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (playerChunk.hasBeenLoaded()) {
|
|
||||||
TaskManager.IMP.sync(() -> {
|
|
||||||
try {
|
|
||||||
int dirtyBits = fieldDirtyBits.getInt(playerChunk);
|
|
||||||
if (dirtyBits == 0) {
|
|
||||||
nmsWorld.getChunkProvider().playerChunkMap.a(playerChunk);
|
|
||||||
}
|
|
||||||
if (mask == 0) {
|
|
||||||
dirtyBits = 65535;
|
|
||||||
} else {
|
|
||||||
dirtyBits |= mask;
|
|
||||||
}
|
|
||||||
|
|
||||||
fieldDirtyBits.set(playerChunk, dirtyBits);
|
|
||||||
fieldDirtyCount.set(playerChunk, 64);
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
NMS conversion
|
|
||||||
*/
|
|
||||||
public static ChunkSection newChunkSection(final int layer, final char[] blocks) {
|
|
||||||
return newChunkSection(layer, null, blocks);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static ChunkSection newChunkSection(final int layer, final Function<Integer, char[]> get, char[] set) {
|
|
||||||
if (set == null) {
|
|
||||||
return newChunkSection(layer);
|
|
||||||
}
|
|
||||||
final int[] blockToPalette = FaweCache.IMP.BLOCK_TO_PALETTE.get();
|
|
||||||
final int[] paletteToBlock = FaweCache.IMP.PALETTE_TO_BLOCK.get();
|
|
||||||
final long[] blockStates = FaweCache.IMP.BLOCK_STATES.get();
|
|
||||||
final int[] blocksCopy = FaweCache.IMP.SECTION_BLOCKS.get();
|
|
||||||
try {
|
|
||||||
int[] num_palette_buffer = new int[1];
|
|
||||||
int air;
|
|
||||||
if (get == null) {
|
|
||||||
air = createPalette(blockToPalette, paletteToBlock, blocksCopy, num_palette_buffer, set);
|
|
||||||
} else {
|
|
||||||
air = createPalette(layer, blockToPalette, paletteToBlock, blocksCopy, num_palette_buffer, get, set);
|
|
||||||
}
|
|
||||||
int num_palette = num_palette_buffer[0];
|
|
||||||
// BlockStates
|
|
||||||
int bitsPerEntry = MathMan.log2nlz(num_palette - 1);
|
|
||||||
if (Settings.IMP.PROTOCOL_SUPPORT_FIX || num_palette != 1) {
|
|
||||||
bitsPerEntry = Math.max(bitsPerEntry, 4); // Protocol support breaks <4 bits per entry
|
|
||||||
} else {
|
|
||||||
bitsPerEntry = Math.max(bitsPerEntry, 1); // For some reason minecraft needs 4096 bits to store 0 entries
|
|
||||||
}
|
|
||||||
|
|
||||||
final int blockBitArrayEnd = (bitsPerEntry * 4096) >> 6;
|
|
||||||
if (num_palette == 1) {
|
|
||||||
for (int i = 0; i < blockBitArrayEnd; i++) blockStates[i] = 0;
|
|
||||||
} else {
|
|
||||||
final BitArray4096 bitArray = new BitArray4096(blockStates, bitsPerEntry);
|
|
||||||
bitArray.fromRaw(blocksCopy);
|
|
||||||
}
|
|
||||||
|
|
||||||
ChunkSection section = newChunkSection(layer);
|
|
||||||
// set palette & data bits
|
|
||||||
final DataPaletteBlock<IBlockData> dataPaletteBlocks = section.getBlocks();
|
|
||||||
// private DataPalette<T> h;
|
|
||||||
// protected DataBits a;
|
|
||||||
final long[] bits = Arrays.copyOfRange(blockStates, 0, blockBitArrayEnd);
|
|
||||||
final DataBits nmsBits = new DataBits(bitsPerEntry, 4096, bits);
|
|
||||||
final DataPalette<IBlockData> palette;
|
|
||||||
// palette = new DataPaletteHash<>(Block.REGISTRY_ID, bitsPerEntry, dataPaletteBlocks, GameProfileSerializer::d, GameProfileSerializer::a);
|
|
||||||
palette = new DataPaletteLinear<>(Block.REGISTRY_ID, bitsPerEntry, dataPaletteBlocks, GameProfileSerializer::d);
|
|
||||||
|
|
||||||
// set palette
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
final int ordinal = paletteToBlock[i];
|
|
||||||
blockToPalette[ordinal] = Integer.MAX_VALUE;
|
|
||||||
final BlockState state = BlockTypesCache.states[ordinal];
|
|
||||||
final IBlockData ibd = ((BlockMaterial_1_14) state.getMaterial()).getState();
|
|
||||||
palette.a(ibd);
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
fieldBits.set(dataPaletteBlocks, nmsBits);
|
|
||||||
fieldPalette.set(dataPaletteBlocks, palette);
|
|
||||||
fieldSize.set(dataPaletteBlocks, bitsPerEntry);
|
|
||||||
setCount(0, 4096 - air, section);
|
|
||||||
} catch (final IllegalAccessException | NoSuchFieldException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
|
|
||||||
return section;
|
|
||||||
} catch (final Throwable e){
|
|
||||||
Arrays.fill(blockToPalette, Integer.MAX_VALUE);
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private static ChunkSection newChunkSection(int layer) {
|
|
||||||
return new ChunkSection(layer << 4);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void setCount(final int tickingBlockCount, final int nonEmptyBlockCount, final ChunkSection section) throws NoSuchFieldException, IllegalAccessException {
|
|
||||||
fieldFluidCount.setShort(section, (short) 0); // TODO FIXME
|
|
||||||
fieldTickingBlockCount.setShort(section, (short) tickingBlockCount);
|
|
||||||
fieldNonEmptyBlockCount.setShort(section, (short) nonEmptyBlockCount);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,659 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_14;
|
|
||||||
|
|
||||||
import static com.google.common.base.Preconditions.checkNotNull;
|
|
||||||
import static org.slf4j.LoggerFactory.getLogger;
|
|
||||||
|
|
||||||
import com.bekvon.bukkit.residence.commands.set;
|
|
||||||
import com.boydti.fawe.Fawe;
|
|
||||||
import com.boydti.fawe.FaweCache;
|
|
||||||
import com.boydti.fawe.beta.IChunkSet;
|
|
||||||
import com.boydti.fawe.beta.implementation.blocks.CharGetBlocks;
|
|
||||||
import com.boydti.fawe.beta.implementation.queue.QueueHandler;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.DelegateLock;
|
|
||||||
import com.boydti.fawe.bukkit.adapter.mc1_14.nbt.LazyCompoundTag_1_14;
|
|
||||||
import com.boydti.fawe.object.collection.AdaptedMap;
|
|
||||||
import com.boydti.fawe.object.collection.BitArray4096;
|
|
||||||
import com.boydti.fawe.util.ReflectionUtils;
|
|
||||||
import com.boydti.fawe.util.TaskManager;
|
|
||||||
import com.google.common.base.Suppliers;
|
|
||||||
import com.google.common.collect.Iterables;
|
|
||||||
import com.sk89q.jnbt.CompoundTag;
|
|
||||||
import com.sk89q.jnbt.ListTag;
|
|
||||||
import com.sk89q.jnbt.LongTag;
|
|
||||||
import com.sk89q.jnbt.StringTag;
|
|
||||||
import com.sk89q.jnbt.Tag;
|
|
||||||
import com.sk89q.worldedit.bukkit.BukkitAdapter;
|
|
||||||
import com.sk89q.worldedit.bukkit.WorldEditPlugin;
|
|
||||||
import com.sk89q.worldedit.bukkit.adapter.BukkitImplAdapter;
|
|
||||||
import com.sk89q.worldedit.bukkit.adapter.impl.FAWE_Spigot_v1_14_R4;
|
|
||||||
import com.sk89q.worldedit.internal.Constants;
|
|
||||||
import com.sk89q.worldedit.math.BlockVector3;
|
|
||||||
import com.sk89q.worldedit.world.biome.BiomeType;
|
|
||||||
import com.sk89q.worldedit.world.block.BlockTypes;
|
|
||||||
import java.util.AbstractSet;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.Iterator;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Set;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.concurrent.Callable;
|
|
||||||
import java.util.concurrent.Future;
|
|
||||||
import java.util.function.Function;
|
|
||||||
import java.util.function.Supplier;
|
|
||||||
import javax.annotation.Nullable;
|
|
||||||
import net.minecraft.server.v1_14_R1.BiomeBase;
|
|
||||||
import net.minecraft.server.v1_14_R1.BlockPosition;
|
|
||||||
import net.minecraft.server.v1_14_R1.Chunk;
|
|
||||||
import net.minecraft.server.v1_14_R1.ChunkSection;
|
|
||||||
import net.minecraft.server.v1_14_R1.ChunkStatus;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataBits;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPalette;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPaletteBlock;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPaletteHash;
|
|
||||||
import net.minecraft.server.v1_14_R1.DataPaletteLinear;
|
|
||||||
import net.minecraft.server.v1_14_R1.Entity;
|
|
||||||
import net.minecraft.server.v1_14_R1.EntityTypes;
|
|
||||||
import net.minecraft.server.v1_14_R1.IBlockData;
|
|
||||||
import net.minecraft.server.v1_14_R1.LightEngine;
|
|
||||||
import net.minecraft.server.v1_14_R1.LightEngineThreaded;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTTagCompound;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTTagInt;
|
|
||||||
import net.minecraft.server.v1_14_R1.TileEntity;
|
|
||||||
import net.minecraft.server.v1_14_R1.WorldServer;
|
|
||||||
import org.bukkit.World;
|
|
||||||
import org.bukkit.block.Biome;
|
|
||||||
import org.bukkit.craftbukkit.v1_14_R1.CraftWorld;
|
|
||||||
import org.bukkit.craftbukkit.v1_14_R1.block.CraftBlock;
|
|
||||||
import org.bukkit.event.entity.CreatureSpawnEvent;
|
|
||||||
import org.jetbrains.annotations.NotNull;
|
|
||||||
|
|
||||||
public class BukkitGetBlocks_1_14 extends CharGetBlocks {
|
|
||||||
public ChunkSection[] sections;
|
|
||||||
public Chunk nmsChunk;
|
|
||||||
public WorldServer world;
|
|
||||||
public int X, Z;
|
|
||||||
|
|
||||||
public BukkitGetBlocks_1_14(World world, int X, int Z) {
|
|
||||||
this(((CraftWorld) world).getHandle(), X, Z);
|
|
||||||
}
|
|
||||||
|
|
||||||
public BukkitGetBlocks_1_14(WorldServer world, int X, int Z) {
|
|
||||||
this.world = world;
|
|
||||||
this.X = X;
|
|
||||||
this.Z = Z;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getX() {
|
|
||||||
return X;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getZ() {
|
|
||||||
return Z;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BiomeType getBiomeType(int x, int z) {
|
|
||||||
BiomeBase base = getChunk().getBiomeIndex()[(z << 4) + x];
|
|
||||||
return BukkitAdapter.adapt(CraftBlock.biomeBaseToBiome(base));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CompoundTag getTag(int x, int y, int z) {
|
|
||||||
TileEntity tileEntity = getChunk().getTileEntity(new BlockPosition((x & 15) + (X << 4), y, (z & 15) + (Z << 4)));
|
|
||||||
return new LazyCompoundTag_1_14(Suppliers.memoize(() -> tileEntity.save(new NBTTagCompound())));
|
|
||||||
}
|
|
||||||
|
|
||||||
private static final Function<BlockPosition, BlockVector3> posNms2We = new Function<BlockPosition, BlockVector3>() {
|
|
||||||
@Override
|
|
||||||
public BlockVector3 apply(BlockPosition v) {
|
|
||||||
return BlockVector3.at(v.getX(), v.getY(), v.getZ());
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
private final static Function<TileEntity, CompoundTag> nmsTile2We = new Function<TileEntity, CompoundTag>() {
|
|
||||||
@Override
|
|
||||||
public CompoundTag apply(TileEntity tileEntity) {
|
|
||||||
return new LazyCompoundTag_1_14(Suppliers.memoize(() -> tileEntity.save(new NBTTagCompound())));
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Map<BlockVector3, CompoundTag> getTiles() {
|
|
||||||
Map<BlockPosition, TileEntity> nmsTiles = getChunk().getTileEntities();
|
|
||||||
if (nmsTiles.isEmpty()) {
|
|
||||||
return Collections.emptyMap();
|
|
||||||
}
|
|
||||||
return AdaptedMap.immutable(nmsTiles, posNms2We, nmsTile2We);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CompoundTag getEntity(UUID uuid) {
|
|
||||||
Entity entity = world.getEntity(uuid);
|
|
||||||
if (entity != null) {
|
|
||||||
org.bukkit.entity.Entity bukkitEnt = entity.getBukkitEntity();
|
|
||||||
return BukkitAdapter.adapt(bukkitEnt).getState().getNbtData();
|
|
||||||
}
|
|
||||||
for (List<Entity> entry : getChunk().getEntitySlices()) {
|
|
||||||
if (entry != null) {
|
|
||||||
for (Entity ent : entry) {
|
|
||||||
if (uuid.equals(ent.getUniqueID())) {
|
|
||||||
org.bukkit.entity.Entity bukkitEnt = ent.getBukkitEntity();
|
|
||||||
return BukkitAdapter.adapt(bukkitEnt).getState().getNbtData();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Set<CompoundTag> getEntities() {
|
|
||||||
List<Entity>[] slices = getChunk().getEntitySlices();
|
|
||||||
int size = 0;
|
|
||||||
for (List<Entity> slice : slices) {
|
|
||||||
if (slice != null) size += slice.size();
|
|
||||||
}
|
|
||||||
if (slices.length == 0) {
|
|
||||||
return Collections.emptySet();
|
|
||||||
}
|
|
||||||
int finalSize = size;
|
|
||||||
return new AbstractSet<CompoundTag>() {
|
|
||||||
@Override
|
|
||||||
public int size() {
|
|
||||||
return finalSize;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isEmpty() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean contains(Object get) {
|
|
||||||
if (!(get instanceof CompoundTag)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
CompoundTag getTag = (CompoundTag) get;
|
|
||||||
Map<String, Tag> value = getTag.getValue();
|
|
||||||
CompoundTag getParts = (CompoundTag) value.get("UUID");
|
|
||||||
UUID getUUID = new UUID(getParts.getLong("Most"), getParts.getLong("Least"));
|
|
||||||
for (List<Entity> slice : slices) {
|
|
||||||
if (slice != null) {
|
|
||||||
for (Entity entity : slice) {
|
|
||||||
UUID uuid = entity.getUniqueID();
|
|
||||||
if (uuid.equals(getUUID)) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@NotNull
|
|
||||||
@Override
|
|
||||||
public Iterator<CompoundTag> iterator() {
|
|
||||||
Iterable<CompoundTag> result = Iterables.transform(Iterables.concat(slices), new com.google.common.base.Function<Entity, CompoundTag>() {
|
|
||||||
@Nullable
|
|
||||||
@Override
|
|
||||||
public CompoundTag apply(@Nullable Entity input) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
NBTTagCompound tag = new NBTTagCompound();
|
|
||||||
return (CompoundTag) adapter.toNative(input.save(tag));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
return result.iterator();
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
private void updateGet(BukkitGetBlocks_1_14 get, Chunk nmsChunk, ChunkSection[] sections, ChunkSection section, char[] arr, int layer) {
|
|
||||||
synchronized (get) {
|
|
||||||
if (this.nmsChunk != nmsChunk) {
|
|
||||||
this.nmsChunk = nmsChunk;
|
|
||||||
this.sections = sections.clone();
|
|
||||||
this.reset();
|
|
||||||
}
|
|
||||||
if (this.sections == null) {
|
|
||||||
this.sections = sections.clone();
|
|
||||||
}
|
|
||||||
if (this.sections[layer] != section) {
|
|
||||||
this.sections[layer] = section;
|
|
||||||
}
|
|
||||||
this.blocks[layer] = arr;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void removeEntity(Entity entity) {
|
|
||||||
entity.die();
|
|
||||||
entity.valid = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Chunk ensureLoaded(net.minecraft.server.v1_14_R1.World nmsWorld, int X, int Z) {
|
|
||||||
return BukkitAdapter_1_14.ensureLoaded(nmsWorld, X, Z);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T extends Future<T>> T call(IChunkSet set, Runnable finalizer) {
|
|
||||||
try {
|
|
||||||
WorldServer nmsWorld = world;
|
|
||||||
Chunk nmsChunk = ensureLoaded(nmsWorld, X, Z);
|
|
||||||
|
|
||||||
// Remove existing tiles
|
|
||||||
{
|
|
||||||
Map<BlockPosition, TileEntity> tiles = nmsChunk.getTileEntities();
|
|
||||||
if (!tiles.isEmpty()) {
|
|
||||||
final Iterator<Map.Entry<BlockPosition, TileEntity>> iterator = tiles.entrySet().iterator();
|
|
||||||
while (iterator.hasNext()) {
|
|
||||||
final Map.Entry<BlockPosition, TileEntity> entry = iterator.next();
|
|
||||||
final BlockPosition pos = entry.getKey();
|
|
||||||
final int lx = pos.getX() & 15;
|
|
||||||
final int ly = pos.getY();
|
|
||||||
final int lz = pos.getZ() & 15;
|
|
||||||
final int layer = ly >> 4;
|
|
||||||
if (!set.hasSection(layer)) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
if (set.getBlock(lx, ly, lz).getOrdinal() != 0) {
|
|
||||||
TileEntity tile = entry.getValue();
|
|
||||||
tile.n();
|
|
||||||
tile.invalidateBlockCache();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
int bitMask = 0;
|
|
||||||
synchronized (nmsChunk) {
|
|
||||||
ChunkSection[] sections = nmsChunk.getSections();
|
|
||||||
|
|
||||||
for (int layer = 0; layer < 16; layer++) {
|
|
||||||
if (!set.hasSection(layer)) continue;
|
|
||||||
|
|
||||||
bitMask |= 1 << layer;
|
|
||||||
|
|
||||||
char[] setArr = set.load(layer);
|
|
||||||
ChunkSection newSection;
|
|
||||||
ChunkSection existingSection = sections[layer];
|
|
||||||
if (existingSection == null) {
|
|
||||||
newSection = BukkitAdapter_1_14.newChunkSection(layer, setArr);
|
|
||||||
if (BukkitAdapter_1_14.setSectionAtomic(sections, null, newSection, layer)) {
|
|
||||||
updateGet(this, nmsChunk, sections, newSection, setArr, layer);
|
|
||||||
continue;
|
|
||||||
} else {
|
|
||||||
existingSection = sections[layer];
|
|
||||||
if (existingSection == null) {
|
|
||||||
System.out.println("Skipping invalid null section. chunk:" + X + "," + Z + " layer: " + layer);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
DelegateLock lock = BukkitAdapter_1_14.applyLock(existingSection);
|
|
||||||
synchronized (this) {
|
|
||||||
synchronized (lock) {
|
|
||||||
lock.untilFree();
|
|
||||||
ChunkSection getSection;
|
|
||||||
if (this.nmsChunk != nmsChunk) {
|
|
||||||
this.nmsChunk = nmsChunk;
|
|
||||||
this.sections = null;
|
|
||||||
this.reset();
|
|
||||||
} else {
|
|
||||||
getSection = this.getSections()[layer];
|
|
||||||
if (getSection != existingSection) {
|
|
||||||
this.sections[layer] = existingSection;
|
|
||||||
this.reset();
|
|
||||||
} else if (lock.isModified()) {
|
|
||||||
this.reset(layer);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
newSection = BukkitAdapter_1_14.newChunkSection(layer, this::load, setArr);
|
|
||||||
if (!BukkitAdapter_1_14.setSectionAtomic(sections, existingSection, newSection, layer)) {
|
|
||||||
System.out.println("Failed to set chunk section:" + X + "," + Z + " layer: " + layer);
|
|
||||||
continue;
|
|
||||||
} else {
|
|
||||||
updateGet(this, nmsChunk, sections, newSection, setArr, layer);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Biomes
|
|
||||||
BiomeType[] biomes = set.getBiomes();
|
|
||||||
if (biomes != null) {
|
|
||||||
// set biomes
|
|
||||||
final BiomeBase[] currentBiomes = nmsChunk.getBiomeIndex();
|
|
||||||
for (int i = 0; i < biomes.length; i++) {
|
|
||||||
final BiomeType biome = biomes[i];
|
|
||||||
if (biome != null) {
|
|
||||||
final Biome craftBiome = BukkitAdapter.adapt(biome);
|
|
||||||
currentBiomes[i] = CraftBlock.biomeToBiomeBase(craftBiome);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Runnable[] syncTasks = null;
|
|
||||||
|
|
||||||
int bx = X << 4;
|
|
||||||
int bz = Z << 4;
|
|
||||||
|
|
||||||
Set<UUID> entityRemoves = set.getEntityRemoves();
|
|
||||||
if (entityRemoves != null && !entityRemoves.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[3];
|
|
||||||
|
|
||||||
syncTasks[2] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
final List<Entity>[] entities = nmsChunk.getEntitySlices();
|
|
||||||
|
|
||||||
for (int i = 0; i < entities.length; i++) {
|
|
||||||
final Collection<Entity> ents = entities[i];
|
|
||||||
if (!ents.isEmpty()) {
|
|
||||||
final Iterator<Entity> iter = ents.iterator();
|
|
||||||
while (iter.hasNext()) {
|
|
||||||
final Entity entity = iter.next();
|
|
||||||
if (entityRemoves.contains(entity.getUniqueID())) {
|
|
||||||
iter.remove();
|
|
||||||
removeEntity(entity);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
Set<CompoundTag> entities = set.getEntities();
|
|
||||||
if (entities != null && !entities.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[2];
|
|
||||||
|
|
||||||
syncTasks[1] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
for (final CompoundTag nativeTag : entities) {
|
|
||||||
final Map<String, Tag> entityTagMap = ReflectionUtils.getMap(nativeTag.getValue());
|
|
||||||
final StringTag idTag = (StringTag) entityTagMap.get("Id");
|
|
||||||
final ListTag posTag = (ListTag) entityTagMap.get("Pos");
|
|
||||||
final ListTag rotTag = (ListTag) entityTagMap.get("Rotation");
|
|
||||||
if (idTag == null || posTag == null || rotTag == null) {
|
|
||||||
getLogger(BukkitGetBlocks_1_14.class).debug("Unknown entity tag: " + nativeTag);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
final double x = posTag.getDouble(0);
|
|
||||||
final double y = posTag.getDouble(1);
|
|
||||||
final double z = posTag.getDouble(2);
|
|
||||||
final float yaw = rotTag.getFloat(0);
|
|
||||||
final float pitch = rotTag.getFloat(1);
|
|
||||||
final String id = idTag.getValue();
|
|
||||||
|
|
||||||
EntityTypes<?> type = EntityTypes.a(id).orElse(null);
|
|
||||||
if (type != null) {
|
|
||||||
Entity entity = type.a(nmsWorld);
|
|
||||||
if (entity != null) {
|
|
||||||
UUID uuid = entity.getUniqueID();
|
|
||||||
entityTagMap.put("UUIDMost", new LongTag(uuid.getMostSignificantBits()));
|
|
||||||
entityTagMap.put("UUIDLeast", new LongTag(uuid.getLeastSignificantBits()));
|
|
||||||
if (nativeTag != null) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
final NBTTagCompound tag = (NBTTagCompound) adapter.fromNative(nativeTag);
|
|
||||||
for (final String name : Constants.NO_COPY_ENTITY_NBT_FIELDS) {
|
|
||||||
tag.remove(name);
|
|
||||||
}
|
|
||||||
entity.f(tag);
|
|
||||||
}
|
|
||||||
entity.setLocation(x, y, z, yaw, pitch);
|
|
||||||
nmsWorld.addEntity(entity, CreatureSpawnEvent.SpawnReason.CUSTOM);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// set tiles
|
|
||||||
Map<BlockVector3, CompoundTag> tiles = set.getTiles();
|
|
||||||
if (tiles != null && !tiles.isEmpty()) {
|
|
||||||
if (syncTasks == null) syncTasks = new Runnable[1];
|
|
||||||
|
|
||||||
syncTasks[0] = new Runnable() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
for (final Map.Entry<BlockVector3, CompoundTag> entry : tiles.entrySet()) {
|
|
||||||
final CompoundTag nativeTag = entry.getValue();
|
|
||||||
final BlockVector3 blockHash = entry.getKey();
|
|
||||||
final int x = blockHash.getX() + bx;
|
|
||||||
final int y = blockHash.getY();
|
|
||||||
final int z = blockHash.getZ() + bz;
|
|
||||||
final BlockPosition pos = new BlockPosition(x, y, z);
|
|
||||||
|
|
||||||
synchronized (nmsWorld) {
|
|
||||||
TileEntity tileEntity = nmsWorld.getTileEntity(pos);
|
|
||||||
if (tileEntity == null || tileEntity.isRemoved()) {
|
|
||||||
nmsWorld.removeTileEntity(pos);
|
|
||||||
tileEntity = nmsWorld.getTileEntity(pos);
|
|
||||||
}
|
|
||||||
if (tileEntity != null) {
|
|
||||||
BukkitImplAdapter adapter = WorldEditPlugin.getInstance().getBukkitImplAdapter();
|
|
||||||
final NBTTagCompound tag = (NBTTagCompound) adapter.fromNative(nativeTag);
|
|
||||||
tag.set("x", new NBTTagInt(x));
|
|
||||||
tag.set("y", new NBTTagInt(y));
|
|
||||||
tag.set("z", new NBTTagInt(z));
|
|
||||||
tileEntity.load(tag);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
{//Lighting
|
|
||||||
// TODO optimize, cause this is really slow
|
|
||||||
LightEngineThreaded engine = (LightEngineThreaded) nmsChunk.e();
|
|
||||||
engine.a(nmsChunk, false);
|
|
||||||
}
|
|
||||||
|
|
||||||
Runnable callback;
|
|
||||||
if (bitMask == 0 && biomes == null) {
|
|
||||||
callback = null;
|
|
||||||
} else {
|
|
||||||
int finalMask = bitMask;
|
|
||||||
callback = () -> {
|
|
||||||
// Set Modified
|
|
||||||
nmsChunk.d(true); // Set Modified
|
|
||||||
nmsChunk.mustNotSave = false;
|
|
||||||
nmsChunk.markDirty();
|
|
||||||
// send to player
|
|
||||||
BukkitAdapter_1_14.sendChunk(nmsWorld, X, Z, finalMask);
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
};
|
|
||||||
}
|
|
||||||
if (syncTasks != null) {
|
|
||||||
QueueHandler queueHandler = Fawe.get().getQueueHandler();
|
|
||||||
Runnable[] finalSyncTasks = syncTasks;
|
|
||||||
|
|
||||||
// Chain the sync tasks and the callback
|
|
||||||
Callable<Future> chain = new Callable<Future>() {
|
|
||||||
@Override
|
|
||||||
public Future call() {
|
|
||||||
try {
|
|
||||||
// Run the sync tasks
|
|
||||||
for (int i = 0; i < finalSyncTasks.length; i++) {
|
|
||||||
Runnable task = finalSyncTasks[i];
|
|
||||||
if (task != null) {
|
|
||||||
task.run();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (callback == null) {
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
return null;
|
|
||||||
} else {
|
|
||||||
return queueHandler.async(callback, null);
|
|
||||||
}
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
return (T) (Future) queueHandler.sync(chain);
|
|
||||||
} else {
|
|
||||||
if (callback == null) {
|
|
||||||
if (finalizer != null) finalizer.run();
|
|
||||||
} else {
|
|
||||||
callback.run();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public synchronized char[] update(int layer, char[] data) {
|
|
||||||
ChunkSection section = getSections()[layer];
|
|
||||||
// Section is null, return empty array
|
|
||||||
if (section == null) {
|
|
||||||
return FaweCache.IMP.EMPTY_CHAR_4096;
|
|
||||||
}
|
|
||||||
if (data == null || data == FaweCache.IMP.EMPTY_CHAR_4096) {
|
|
||||||
data = new char[4096];
|
|
||||||
}
|
|
||||||
DelegateLock lock = BukkitAdapter_1_14.applyLock(section);
|
|
||||||
synchronized (lock) {
|
|
||||||
lock.untilFree();
|
|
||||||
lock.setModified(false);
|
|
||||||
// Efficiently convert ChunkSection to raw data
|
|
||||||
try {
|
|
||||||
FAWE_Spigot_v1_14_R4 adapter = ((FAWE_Spigot_v1_14_R4) WorldEditPlugin.getInstance().getBukkitImplAdapter());
|
|
||||||
|
|
||||||
final DataPaletteBlock<IBlockData> blocks = section.getBlocks();
|
|
||||||
final DataBits bits = (DataBits) BukkitAdapter_1_14.fieldBits.get(blocks);
|
|
||||||
final DataPalette<IBlockData> palette = (DataPalette<IBlockData>) BukkitAdapter_1_14.fieldPalette.get(blocks);
|
|
||||||
|
|
||||||
final int bitsPerEntry = bits.c();
|
|
||||||
final long[] blockStates = bits.a();
|
|
||||||
|
|
||||||
new BitArray4096(blockStates, bitsPerEntry).toRaw(data);
|
|
||||||
|
|
||||||
int num_palette;
|
|
||||||
if (palette instanceof DataPaletteLinear) {
|
|
||||||
num_palette = ((DataPaletteLinear<IBlockData>) palette).b();
|
|
||||||
} else if (palette instanceof DataPaletteHash) {
|
|
||||||
num_palette = ((DataPaletteHash<IBlockData>) palette).b();
|
|
||||||
} else {
|
|
||||||
num_palette = 0;
|
|
||||||
int[] paletteToBlockInts = FaweCache.IMP.PALETTE_TO_BLOCK.get();
|
|
||||||
char[] paletteToBlockChars = FaweCache.IMP.PALETTE_TO_BLOCK_CHAR.get();
|
|
||||||
try {
|
|
||||||
for (int i = 0; i < 4096; i++) {
|
|
||||||
char paletteVal = data[i];
|
|
||||||
char ordinal = paletteToBlockChars[paletteVal];
|
|
||||||
if (ordinal == Character.MAX_VALUE) {
|
|
||||||
paletteToBlockInts[num_palette++] = paletteVal;
|
|
||||||
IBlockData ibd = palette.a(data[i]);
|
|
||||||
if (ibd == null) {
|
|
||||||
ordinal = BlockTypes.AIR.getDefaultState().getOrdinalChar();
|
|
||||||
} else {
|
|
||||||
ordinal = adapter.adaptToChar(ibd);
|
|
||||||
}
|
|
||||||
paletteToBlockChars[paletteVal] = ordinal;
|
|
||||||
}
|
|
||||||
data[i] = ordinal;
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
int paletteVal = paletteToBlockInts[i];
|
|
||||||
paletteToBlockChars[paletteVal] = Character.MAX_VALUE;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return data;
|
|
||||||
}
|
|
||||||
|
|
||||||
char[] paletteToOrdinal = FaweCache.IMP.PALETTE_TO_BLOCK_CHAR.get();
|
|
||||||
try {
|
|
||||||
if (num_palette != 1) {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
char ordinal = ordinal(palette.a(i), adapter);
|
|
||||||
paletteToOrdinal[i] = ordinal;
|
|
||||||
}
|
|
||||||
for (int i = 0; i < 4096; i++) {
|
|
||||||
char paletteVal = data[i];
|
|
||||||
char val = paletteToOrdinal[paletteVal];
|
|
||||||
if (val == Character.MAX_VALUE) {
|
|
||||||
val = ordinal(palette.a(i), adapter);
|
|
||||||
paletteToOrdinal[i] = val;
|
|
||||||
}
|
|
||||||
data[i] = val;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
char ordinal = ordinal(palette.a(0), adapter);
|
|
||||||
Arrays.fill(data, ordinal);
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
for (int i = 0; i < num_palette; i++) {
|
|
||||||
paletteToOrdinal[i] = Character.MAX_VALUE;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return data;
|
|
||||||
} catch (IllegalAccessException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private final char ordinal(IBlockData ibd, FAWE_Spigot_v1_14_R4 adapter) {
|
|
||||||
if (ibd == null) {
|
|
||||||
return BlockTypes.AIR.getDefaultState().getOrdinalChar();
|
|
||||||
} else {
|
|
||||||
return adapter.adaptToChar(ibd);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public ChunkSection[] getSections() {
|
|
||||||
ChunkSection[] tmp = sections;
|
|
||||||
if (tmp == null) {
|
|
||||||
synchronized (this) {
|
|
||||||
tmp = sections;
|
|
||||||
if (tmp == null) {
|
|
||||||
Chunk chunk = getChunk();
|
|
||||||
sections = tmp = chunk.getSections().clone();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Chunk getChunk() {
|
|
||||||
Chunk tmp = nmsChunk;
|
|
||||||
if (tmp == null) {
|
|
||||||
synchronized (this) {
|
|
||||||
tmp = nmsChunk;
|
|
||||||
if (tmp == null) {
|
|
||||||
nmsChunk = tmp = ensureLoaded(this.world, X, Z);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return tmp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean hasSection(int layer) {
|
|
||||||
return getSections()[layer] != null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean trim(boolean aggressive) {
|
|
||||||
if (aggressive) {
|
|
||||||
sections = null;
|
|
||||||
nmsChunk = null;
|
|
||||||
}
|
|
||||||
return super.trim(aggressive);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,28 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_14;
|
|
||||||
|
|
||||||
import com.boydti.fawe.bukkit.adapter.MapChunkUtil;
|
|
||||||
import net.minecraft.server.v1_14_R1.PacketPlayOutMapChunk;
|
|
||||||
|
|
||||||
public class MapChunkUtil_1_14 extends MapChunkUtil<PacketPlayOutMapChunk> {
|
|
||||||
public MapChunkUtil_1_14() throws NoSuchFieldException {
|
|
||||||
fieldX = PacketPlayOutMapChunk.class.getDeclaredField("a");
|
|
||||||
fieldZ = PacketPlayOutMapChunk.class.getDeclaredField("b");
|
|
||||||
fieldBitMask = PacketPlayOutMapChunk.class.getDeclaredField("c");
|
|
||||||
fieldHeightMap = PacketPlayOutMapChunk.class.getDeclaredField("d");
|
|
||||||
fieldChunkData = PacketPlayOutMapChunk.class.getDeclaredField("e");
|
|
||||||
fieldBlockEntities = PacketPlayOutMapChunk.class.getDeclaredField("f");
|
|
||||||
fieldFull = PacketPlayOutMapChunk.class.getDeclaredField("g");
|
|
||||||
fieldX.setAccessible(true);
|
|
||||||
fieldZ.setAccessible(true);
|
|
||||||
fieldBitMask.setAccessible(true);
|
|
||||||
fieldHeightMap.setAccessible(true);
|
|
||||||
fieldChunkData.setAccessible(true);
|
|
||||||
fieldBlockEntities.setAccessible(true);
|
|
||||||
fieldFull.setAccessible(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PacketPlayOutMapChunk createPacket() {
|
|
||||||
return new PacketPlayOutMapChunk();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,153 +0,0 @@
|
|||||||
package com.boydti.fawe.bukkit.adapter.mc1_14.nbt;
|
|
||||||
|
|
||||||
import com.google.common.base.Suppliers;
|
|
||||||
import com.sk89q.jnbt.CompoundTag;
|
|
||||||
import com.sk89q.jnbt.ListTag;
|
|
||||||
import com.sk89q.jnbt.StringTag;
|
|
||||||
import com.sk89q.jnbt.Tag;
|
|
||||||
import com.sk89q.worldedit.bukkit.WorldEditPlugin;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTBase;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTNumber;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTTagCompound;
|
|
||||||
import net.minecraft.server.v1_14_R1.NBTTagList;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.function.Supplier;
|
|
||||||
|
|
||||||
public class LazyCompoundTag_1_14 extends CompoundTag {
|
|
||||||
private final Supplier<NBTTagCompound> nmsTag;
|
|
||||||
|
|
||||||
public LazyCompoundTag_1_14(Supplier<NBTTagCompound> tag) {
|
|
||||||
super(null);
|
|
||||||
this.nmsTag = tag;
|
|
||||||
}
|
|
||||||
|
|
||||||
public LazyCompoundTag_1_14(NBTTagCompound tag) {
|
|
||||||
this(() -> tag);
|
|
||||||
}
|
|
||||||
|
|
||||||
public NBTTagCompound get() {
|
|
||||||
return nmsTag.get();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Map<String, Tag> getValue() {
|
|
||||||
Map<String, Tag> value = super.getValue();
|
|
||||||
if (value == null) {
|
|
||||||
Tag tag = WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(nmsTag.get());
|
|
||||||
setValue(((CompoundTag) tag).getValue());
|
|
||||||
}
|
|
||||||
return super.getValue();
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean containsKey(String key) {
|
|
||||||
return nmsTag.get().hasKey(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public byte[] getByteArray(String key) {
|
|
||||||
return nmsTag.get().getByteArray(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public byte getByte(String key) {
|
|
||||||
return nmsTag.get().getByte(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public double getDouble(String key) {
|
|
||||||
return nmsTag.get().getDouble(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public double asDouble(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asDouble();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public float getFloat(String key) {
|
|
||||||
return nmsTag.get().getFloat(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int[] getIntArray(String key) {
|
|
||||||
return nmsTag.get().getIntArray(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getInt(String key) {
|
|
||||||
return nmsTag.get().getInt(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public int asInt(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asInt();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<Tag> getList(String key) {
|
|
||||||
NBTBase tag = nmsTag.get().get(key);
|
|
||||||
if (tag instanceof NBTTagList) {
|
|
||||||
ArrayList<Tag> list = new ArrayList<>();
|
|
||||||
NBTTagList nbtList = (NBTTagList) tag;
|
|
||||||
for (NBTBase elem : nbtList) {
|
|
||||||
if (elem instanceof NBTTagCompound) {
|
|
||||||
list.add(new LazyCompoundTag_1_14((NBTTagCompound) elem));
|
|
||||||
} else {
|
|
||||||
list.add(WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(elem));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return list;
|
|
||||||
}
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
|
|
||||||
public ListTag getListTag(String key) {
|
|
||||||
NBTBase tag = nmsTag.get().get(key);
|
|
||||||
if (tag instanceof NBTTagList) {
|
|
||||||
return (ListTag) WorldEditPlugin.getInstance().getBukkitImplAdapter().toNative(tag);
|
|
||||||
}
|
|
||||||
return new ListTag(StringTag.class, Collections.<Tag>emptyList());
|
|
||||||
}
|
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public <T extends Tag> List<T> getList(String key, Class<T> listType) {
|
|
||||||
ListTag listTag = getListTag(key);
|
|
||||||
if (listTag.getType().equals(listType)) {
|
|
||||||
return (List<T>) listTag.getValue();
|
|
||||||
} else {
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public long[] getLongArray(String key) {
|
|
||||||
return nmsTag.get().getLongArray(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public long getLong(String key) {
|
|
||||||
return nmsTag.get().getLong(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public long asLong(String key) {
|
|
||||||
NBTBase value = nmsTag.get().get(key);
|
|
||||||
if (value instanceof NBTNumber) {
|
|
||||||
return ((NBTNumber) value).asLong();
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
public short getShort(String key) {
|
|
||||||
return nmsTag.get().getShort(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getString(String key) {
|
|
||||||
return nmsTag.get().getString(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String toString() {
|
|
||||||
return nmsTag.get().toString();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren