Merge pull request #599 from aurorasmiles/fixnms

Only send PacketPlayOutChunkMap for chunk updates

worldedit-bukkit/src/main/java/com/boydti/fawe/bukkit/adapter/mc1_16_2/BukkitAdapter_1_16_2.java

@@ -9,6 +9,7 @@ import com.boydti.fawe.object.collection.BitArrayUnstretched;
 import com.boydti.fawe.util.MathMan;
 import com.boydti.fawe.util.ReflectionUtils;
 import com.boydti.fawe.util.TaskManager;
+import com.mojang.datafixers.util.Either;
 import com.sk89q.worldedit.math.BlockVector3;
 import com.sk89q.worldedit.world.block.BlockState;
 import com.sk89q.worldedit.world.block.BlockTypesCache;
@@ -25,6 +26,7 @@ import net.minecraft.server.v1_16_R2.DataPaletteLinear;
 import net.minecraft.server.v1_16_R2.GameProfileSerializer;
 import net.minecraft.server.v1_16_R2.IBlockData;
 import net.minecraft.server.v1_16_R2.PacketPlayOutLightUpdate;
+import net.minecraft.server.v1_16_R2.PacketPlayOutMapChunk;
 import net.minecraft.server.v1_16_R2.PlayerChunk;
 import net.minecraft.server.v1_16_R2.PlayerChunkMap;
 import net.minecraft.server.v1_16_R2.World;
@@ -35,13 +37,12 @@ import sun.misc.Unsafe;
 
 import java.lang.invoke.MethodHandle;
 import java.lang.invoke.MethodHandles;
-import java.lang.reflect.Constructor;
 import java.lang.reflect.Field;
 import java.lang.reflect.Method;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.Set;
+import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.locks.ReentrantLock;
 import java.util.function.Function;
@@ -70,9 +71,6 @@ public final class BukkitAdapter_1_16_2 extends NMSAdapter {
 
     private static final Field fieldLock;
 
-    private static final short[] FULL_CHUNK_SECTION_CHANGE_SET;
-    private static final Constructor shortArraySetFromShortArrayConstructor;
-
     static {
         try {
             fieldSize = DataPaletteBlock.class.getDeclaredField("i");
@@ -119,17 +117,6 @@ public final class BukkitAdapter_1_16_2 extends NMSAdapter {
             } catch (Throwable t) {// still using spigot boooo
                 clsShortArraySet = Class.forName(new String(new char[]{'o', 'r', 'g', '.', 'b', 'u', 'k', 'k', 'i', 't', '.', 'c', 'r', 'a', 'f', 't', 'b', 'u', 'k', 'k', 'i', 't', '.', 'l', 'i', 'b', 's', '.', 'i', 't', '.', 'u', 'n', 'i', 'm', 'i', '.', 'd', 's', 'i', '.', 'f', 'a', 's', 't', 'u', 't', 'i', 'l', '.', 's', 'h', 'o', 'r', 't', 's', '.', 'S', 'h', 'o', 'r', 't', 'A', 'r', 'r', 'a', 'y', 'S', 'e', 't'}));
             }
-            shortArraySetFromShortArrayConstructor = clsShortArraySet.getConstructor(short[].class);
-        
-            FULL_CHUNK_SECTION_CHANGE_SET = new short[16 * 16 * 16];
-            for (int x = 0; x < 16; x++) {
-                for (int y = 0; y < 16; y++) {
-                    for (int z = 0; z < 16; z++) {
-                        short i = (short) ((x << 8) | (z << 4) | y);
-                        FULL_CHUNK_SECTION_CHANGE_SET[i] = i;
-                    }
-                }
-            }
         } catch (RuntimeException e) {
             throw e;
         } catch (Throwable rethrow) {
@@ -203,29 +190,23 @@ public final class BukkitAdapter_1_16_2 extends NMSAdapter {
         }
         if (playerChunk.hasBeenLoaded()) {
             TaskManager.IMP.sync(() -> {
-                try {
+                ChunkCoordIntPair chunkCoordIntPair = new ChunkCoordIntPair(chunkX, chunkZ);
-                    Set<Short>[] dirtyblocks = (Set<Short>[]) fieldDirtyBlocks.get(playerChunk);
+                Optional<Chunk> optional = ((Either) playerChunk.a().getNow(PlayerChunk.UNLOADED_CHUNK)).left();
-                    if (Arrays.stream(dirtyblocks).allMatch(e -> e == null || e.isEmpty())) {
+                if (optional.isPresent()) {
-                        nmsWorld.getChunkProvider().playerChunkMap.a(playerChunk);
+                    PacketPlayOutMapChunk chunkpacket = new PacketPlayOutMapChunk(optional.get(), 65535);
+                    playerChunk.players.a(chunkCoordIntPair, false).forEach(p -> {
+                        p.playerConnection.sendPacket(chunkpacket);
+                    });
                 }
-                    for (int i = 0; i < 16; i++) {
-                        dirtyblocks[i] = getFullChunkSliceChangeSet();
-                    }
-
-                    fieldDirtyBlocks.set(playerChunk, dirtyblocks);
-                    fieldDirty.setBoolean(playerChunk, true);
 
                 if (lighting) {
-                        ChunkCoordIntPair chunkCoordIntPair = new ChunkCoordIntPair(chunkX, chunkZ);
+//                    ChunkCoordIntPair chunkCoordIntPair = new ChunkCoordIntPair(chunkX, chunkZ);
                     boolean trustEdges = false; //Added in 1.16.1 Not sure what it does.
                     PacketPlayOutLightUpdate packet = new PacketPlayOutLightUpdate(chunkCoordIntPair, nmsWorld.getChunkProvider().getLightEngine(), trustEdges);
                     playerChunk.players.a(chunkCoordIntPair, false).forEach(p -> {
                         p.playerConnection.sendPacket(packet);
                     });
                 }
-                } catch (IllegalAccessException e) {
-                    e.printStackTrace();
-                }
                 return null;
             });
         }
@@ -325,14 +306,4 @@ public final class BukkitAdapter_1_16_2 extends NMSAdapter {
         fieldTickingBlockCount.setShort(section, (short) tickingBlockCount);
         fieldNonEmptyBlockCount.setShort(section, (short) nonEmptyBlockCount);
     }
-   
-    private static Set<Short> getFullChunkSliceChangeSet() {
-        try {
-            short[] data = new short[16 * 16 * 16];
-            System.arraycopy(FULL_CHUNK_SECTION_CHANGE_SET, 0, data, 0, FULL_CHUNK_SECTION_CHANGE_SET.length);
-            return (Set<Short>) shortArraySetFromShortArrayConstructor.newInstance((Object) data);
-        } catch (Throwable e) {
-            return null;
-        }
-    }
 }