--- a/net/minecraft/server/ChunkRegionLoader.java +++ b/net/minecraft/server/ChunkRegionLoader.java @@ -31,7 +31,7 @@ private final File c; private final DataFixer d; private PersistentStructureLegacy e; - private boolean f; + // private boolean f; // CraftBukkit public ChunkRegionLoader(File file, DataFixer datafixer) { this.c = file; @@ -40,25 +40,64 @@ @Nullable private NBTTagCompound a(GeneratorAccess generatoraccess, int i, int j) throws IOException { - return this.a(generatoraccess.o().getDimensionManager(), generatoraccess.h(), i, j); + return this.a(generatoraccess.o().getDimensionManager(), generatoraccess.h(), i, j, generatoraccess); // CraftBukkit + } + + // CraftBukkit start + private boolean check(ChunkProviderServer cps, int x, int z) throws IOException { + if (cps != null) { + com.google.common.base.Preconditions.checkState(org.bukkit.Bukkit.isPrimaryThread(), "primary thread"); + if (cps.isLoaded(x, z)) { + return true; + } + } + + if (this.chunkExists(x, z)) { + NBTTagCompound nbt = RegionFileCache.read(this.c, x, z); + if (nbt != null) { + NBTTagCompound level = nbt.getCompound("Level"); + if (level.getBoolean("TerrainPopulated")) { + return true; + } + + ChunkStatus status = ChunkStatus.a(level.getString("Status")); + if (status != null && status.a(ChunkStatus.DECORATED)) { + return true; + } + } + } + + return false; + } + + public boolean chunkExists(int x, int z) { + return RegionFileCache.chunkExists(this.c, x, z); } @Nullable - private NBTTagCompound a(DimensionManager dimensionmanager, @Nullable PersistentCollection persistentcollection, int i, int j) throws IOException { + private NBTTagCompound a(DimensionManager dimensionmanager, @Nullable PersistentCollection persistentcollection, int i, int j, @Nullable GeneratorAccess generatoraccess) throws IOException { NBTTagCompound nbttagcompound = (NBTTagCompound) this.b.get(new ChunkCoordIntPair(i, j)); if (nbttagcompound != null) { return nbttagcompound; } else { - DataInputStream datainputstream = RegionFileCache.read(this.c, i, j); + NBTTagCompound nbttagcompound1 = RegionFileCache.read(this.c, i, j); - if (datainputstream == null) { + if (nbttagcompound1 == null) { return null; } else { - NBTTagCompound nbttagcompound1 = NBTCompressedStreamTools.a(datainputstream); - - datainputstream.close(); int k = nbttagcompound1.hasKeyOfType("DataVersion", 99) ? nbttagcompound1.getInt("DataVersion") : -1; + // CraftBukkit start + if (k < 1466) { + NBTTagCompound level = nbttagcompound1.getCompound("Level"); + if (level.getBoolean("TerrainPopulated") && !level.getBoolean("LightPopulated")) { + ChunkProviderServer cps = (generatoraccess == null) ? null : ((WorldServer) generatoraccess).getChunkProviderServer(); + if (check(cps, i - 1, j) && check(cps, i - 1, j - 1) && check(cps, i, j - 1)) { + level.setBoolean("LightPopulated", true); + } + } + } + // CraftBukkit end if (k < 1493) { nbttagcompound1 = GameProfileSerializer.a(this.d, DataFixTypes.CHUNK, nbttagcompound1, k, 1493); @@ -86,13 +125,29 @@ } + // CraftBukkit start - Add async variant, provide compatibility @Nullable public Chunk a(GeneratorAccess generatoraccess, int i, int j, Consumer consumer) throws IOException { + Object[] data = loadChunk(generatoraccess, i, j, consumer); + if (data != null) { + Chunk chunk = (Chunk) data[0]; + NBTTagCompound nbttagcompound = (NBTTagCompound) data[1]; + consumer.accept(chunk); + this.loadEntities(nbttagcompound.getCompound("Level"), chunk); + return chunk; + } + + return null; + } + + public Object[] loadChunk(GeneratorAccess generatoraccess, int i, int j, Consumer consumer) throws IOException { + // CraftBukkit end NBTTagCompound nbttagcompound = this.a(generatoraccess, i, j); if (nbttagcompound == null) { return null; } else { + /* Chunk chunk = this.a(generatoraccess, i, j, nbttagcompound); if (chunk != null) { @@ -101,6 +156,9 @@ } return chunk; + */ + + return this.a(generatoraccess, i, j, nbttagcompound); } } @@ -132,7 +190,7 @@ } @Nullable - protected Chunk a(GeneratorAccess generatoraccess, int i, int j, NBTTagCompound nbttagcompound) { + protected Object[] a(GeneratorAccess generatoraccess, int i, int j, NBTTagCompound nbttagcompound) { // CraftBukkit - return Chunk -> Object[] if (nbttagcompound.hasKeyOfType("Level", 10) && nbttagcompound.getCompound("Level").hasKeyOfType("Status", 8)) { ChunkStatus.Type chunkstatus_type = this.a(nbttagcompound); @@ -151,10 +209,28 @@ ChunkRegionLoader.a.error("Chunk file at {},{} is in the wrong location; relocating. (Expected {}, {}, got {}, {})", i, j, i, j, chunk.locX, chunk.locZ); nbttagcompound1.setInt("xPos", i); nbttagcompound1.setInt("zPos", j); + + // CraftBukkit start - Have to move tile entities since we don't load them at this stage + NBTTagList tileEntities = nbttagcompound.getCompound("Level").getList("TileEntities", 10); + if (tileEntities != null) { + for (int te = 0; te < tileEntities.size(); te++) { + NBTTagCompound tileEntity = (NBTTagCompound) tileEntities.get(te); + int x = tileEntity.getInt("x") - chunk.locX * 16; + int z = tileEntity.getInt("z") - chunk.locZ * 16; + tileEntity.setInt("x", i * 16 + x); + tileEntity.setInt("z", j * 16 + z); + } + } + // CraftBukkit end chunk = this.a(generatoraccess, nbttagcompound1); } - return chunk; + // CraftBukkit start + Object[] data = new Object[2]; + data[0] = chunk; + data[1] = nbttagcompound; + return data; + // CraftBukkit end } } } else { @@ -169,7 +245,7 @@ ChunkStatus.Type chunkstatus_type = this.a(nbttagcompound); if (chunkstatus_type == ChunkStatus.Type.LEVELCHUNK) { - return new ProtoChunkExtension(this.a(generatoraccess, i, j, nbttagcompound)); + return new ProtoChunkExtension((IChunkAccess) this.a(generatoraccess, i, j, nbttagcompound)[0]); // CraftBukkit - fix up access } else { NBTTagCompound nbttagcompound1 = nbttagcompound.getCompound("Level"); @@ -217,10 +293,14 @@ } public boolean a() { - Iterator iterator = this.b.entrySet().iterator(); + // CraftBukkit start + return this.processSaveQueueEntry(false); + } + private boolean processSaveQueueEntry(boolean logCompletion) { + Iterator iterator = this.b.entrySet().iterator(); if (!iterator.hasNext()) { - if (this.f) { + if (logCompletion) { // CraftBukkit ChunkRegionLoader.a.info("ThreadedAnvilChunkStorage ({}): All chunks are saved", this.c.getName()); } @@ -236,10 +316,14 @@ return true; } else { try { - DataOutputStream dataoutputstream = RegionFileCache.write(this.c, chunkcoordintpair.x, chunkcoordintpair.z); + // CraftBukkit start + RegionFileCache.write(this.c, chunkcoordintpair.x, chunkcoordintpair.z, nbttagcompound); + /* NBTCompressedStreamTools.a(nbttagcompound, (DataOutput) dataoutputstream); dataoutputstream.close(); + */ + // CraftBukkit end if (this.e != null) { this.e.a(chunkcoordintpair.a()); } @@ -266,15 +350,16 @@ public void b() { try { - this.f = true; + // this.f = true; // CraftBukkit while (true) { - if (this.a()) { + if (this.processSaveQueueEntry(true)) { // CraftBukkit continue; } + break; // CraftBukkit - Fix infinite loop when saving chunks } } finally { - this.f = false; + // this.f = false; // CraftBukkit } } @@ -303,7 +388,7 @@ if (abiomebase != null) { for (int k = 0; k < abiomebase.length; ++k) { - aint[k] = IRegistry.BIOME.a((Object) abiomebase[k]); + aint[k] = IRegistry.BIOME.a(abiomebase[k]); // CraftBukkit - decompile error } } @@ -385,7 +470,7 @@ int[] aint = new int[abiomebase.length]; for (int i = 0; i < abiomebase.length; ++i) { - aint[i] = IRegistry.BIOME.a((Object) abiomebase[i]); + aint[i] = IRegistry.BIOME.a(abiomebase[i]); // CraftBukkit - decompile error } nbttagcompound.setIntArray("Biomes", aint); @@ -487,27 +572,27 @@ } ChunkConverter chunkconverter = nbttagcompound.hasKeyOfType("UpgradeData", 10) ? new ChunkConverter(nbttagcompound.getCompound("UpgradeData")) : ChunkConverter.a; - Predicate predicate = (block) -> { + Predicate predicate = (block) -> { // CraftBukkit - decompile error return block.getBlockData().isAir(); }; IRegistry iregistry = IRegistry.BLOCK; IRegistry.BLOCK.getClass(); Function function = iregistry::getKey; - IRegistry iregistry1 = IRegistry.BLOCK; + IRegistry iregistry1 = IRegistry.BLOCK; // CraftBukkit - decompile error IRegistry.BLOCK.getClass(); - ProtoChunkTickList protochunkticklist = new ProtoChunkTickList(predicate, function, iregistry1::getOrDefault, new ChunkCoordIntPair(i, j)); + ProtoChunkTickList protochunkticklist = new ProtoChunkTickList<>(predicate, function, iregistry1::getOrDefault, new ChunkCoordIntPair(i, j)); // CraftBukkit - decompile error - predicate = (fluidtype) -> { + Predicate predicate1 = (fluidtype) -> { // CraftBukkit - decompile error return fluidtype == FluidTypes.a; }; iregistry = IRegistry.FLUID; IRegistry.FLUID.getClass(); function = iregistry::getKey; - iregistry1 = IRegistry.FLUID; + IRegistry iregistry2 = IRegistry.FLUID; // CraftBukkit - decompile error IRegistry.FLUID.getClass(); - ProtoChunkTickList protochunkticklist1 = new ProtoChunkTickList(predicate, function, iregistry1::getOrDefault, new ChunkCoordIntPair(i, j)); + ProtoChunkTickList protochunkticklist1 = new ProtoChunkTickList<>(predicate1, function, iregistry2::getOrDefault, new ChunkCoordIntPair(i, j)); // CraftBukkit - decompile error long i1 = nbttagcompound.getLong("InhabitedTime"); Chunk chunk = new Chunk(generatoraccess.getMinecraftWorld(), i, j, abiomebase, chunkconverter, protochunkticklist, protochunkticklist1, i1); @@ -850,17 +935,29 @@ } @Nullable + // CraftBukkit start public static Entity a(NBTTagCompound nbttagcompound, World world, double d0, double d1, double d2, boolean flag) { + return spawnEntity(nbttagcompound, world, d0, d1, d2, flag, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason.DEFAULT); + } + + public static Entity spawnEntity(NBTTagCompound nbttagcompound, World world, double d0, double d1, double d2, boolean flag, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason spawnReason) { + // CraftBukkit end return a(nbttagcompound, world, (entity) -> { entity.setPositionRotation(d0, d1, d2, entity.yaw, entity.pitch); - return flag && !world.addEntity(entity) ? null : entity; + return flag && !world.addEntity(entity, spawnReason) ? null : entity; }); } @Nullable + // CraftBukkit start public static Entity a(NBTTagCompound nbttagcompound, World world, boolean flag) { + return spawnEntity(nbttagcompound, world, flag, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason.DEFAULT); + } + + public static Entity spawnEntity(NBTTagCompound nbttagcompound, World world, boolean flag, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason spawnReason) { + // CraftBukkit end return a(nbttagcompound, world, (entity) -> { - return flag && !world.addEntity(entity) ? null : entity; + return flag && !world.addEntity(entity, spawnReason) ? null : entity; // CraftBukkit }); } @@ -874,8 +971,14 @@ } } + // CraftBukkit start public static void a(Entity entity, GeneratorAccess generatoraccess) { - if (generatoraccess.addEntity(entity) && entity.isVehicle()) { + a(entity, generatoraccess, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason.DEFAULT); + } + + public static void a(Entity entity, GeneratorAccess generatoraccess, org.bukkit.event.entity.CreatureSpawnEvent.SpawnReason reason) { + if (generatoraccess.addEntity(entity, reason) && entity.isVehicle()) { + // CraftBukkit end Iterator iterator = entity.bP().iterator(); while (iterator.hasNext()) { @@ -891,7 +994,7 @@ boolean flag = false; try { - this.a(dimensionmanager, persistentcollection, chunkcoordintpair.x, chunkcoordintpair.z); + this.a(dimensionmanager, persistentcollection, chunkcoordintpair.x, chunkcoordintpair.z, null); // CraftBukkit while (this.a()) { flag = true;