Engine data saving

This commit is contained in:
Daniel Mills 2021-08-01 13:36:28 -04:00
parent e79ba6117b
commit 8820b02406
6 changed files with 92 additions and 18 deletions

View File

@ -18,8 +18,10 @@
package com.volmit.iris.engine; package com.volmit.iris.engine;
import com.google.gson.Gson;
import com.volmit.iris.Iris; import com.volmit.iris.Iris;
import com.volmit.iris.core.IrisSettings; import com.volmit.iris.core.IrisSettings;
import com.volmit.iris.engine.cache.AtomicCache;
import com.volmit.iris.engine.framework.*; import com.volmit.iris.engine.framework.*;
import com.volmit.iris.engine.hunk.Hunk; import com.volmit.iris.engine.hunk.Hunk;
import com.volmit.iris.engine.object.*; import com.volmit.iris.engine.object.*;
@ -30,6 +32,7 @@ import com.volmit.iris.util.documentation.BlockCoordinates;
import com.volmit.iris.util.documentation.ChunkCoordinates; import com.volmit.iris.util.documentation.ChunkCoordinates;
import com.volmit.iris.util.format.C; import com.volmit.iris.util.format.C;
import com.volmit.iris.util.format.Form; import com.volmit.iris.util.format.Form;
import com.volmit.iris.util.io.IO;
import com.volmit.iris.util.math.RNG; import com.volmit.iris.util.math.RNG;
import com.volmit.iris.util.scheduling.J; import com.volmit.iris.util.scheduling.J;
import com.volmit.iris.util.scheduling.PrecisionStopwatch; import com.volmit.iris.util.scheduling.PrecisionStopwatch;
@ -42,6 +45,8 @@ import org.bukkit.block.data.BlockData;
import org.bukkit.generator.BlockPopulator; import org.bukkit.generator.BlockPopulator;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import java.io.File;
import java.io.IOException;
import java.util.Random; import java.util.Random;
public class IrisEngine extends BlockPopulator implements Engine { public class IrisEngine extends BlockPopulator implements Engine {
@ -87,12 +92,12 @@ public class IrisEngine extends BlockPopulator implements Engine {
@Getter @Getter
private double maxBiomeDecoratorDensity; private double maxBiomeDecoratorDensity;
private IrisEngineData engineData; private AtomicCache<IrisEngineData> engineData = new AtomicCache<>();
public IrisEngine(EngineTarget target, EngineCompound compound, int index) { public IrisEngine(EngineTarget target, EngineCompound compound, int index) {
Iris.info("Initializing Engine: " + target.getWorld().name() + "/" + target.getDimension().getLoadKey() + " (" + target.getHeight() + " height)"); Iris.info("Initializing Engine: " + target.getWorld().name() + "/" + target.getDimension().getLoadKey() + " (" + target.getHeight() + " height)");
metrics = new EngineMetrics(32); metrics = new EngineMetrics(32);
engineData = new IrisEngineData(); getEngineData();
this.target = target; this.target = target;
this.framework = new IrisEngineFramework(this); this.framework = new IrisEngineFramework(this);
worldManager = new IrisWorldManager(this); worldManager = new IrisWorldManager(this);
@ -107,6 +112,35 @@ public class IrisEngine extends BlockPopulator implements Engine {
J.a(this::computeBiomeMaxes); J.a(this::computeBiomeMaxes);
} }
@Override
public IrisEngineData getEngineData() {
return engineData.aquire(() -> {
File f = new File(getWorld().worldFolder(), "iris/engine-data/" + getDimension().getLoadKey() + "-" + getIndex() + ".json");
if(!f.exists())
{
try {
f.getParentFile().mkdirs();
IO.writeAll(f, new Gson().toJson(new IrisEngineData()));
} catch (IOException e) {
e.printStackTrace();
}
}
try
{
return new Gson().fromJson(IO.readAll(f), IrisEngineData.class);
}
catch(Throwable e)
{
e.printStackTrace();
}
return new IrisEngineData();
});
}
private void computeBiomeMaxes() { private void computeBiomeMaxes() {
for (IrisBiome i : getDimension().getAllBiomes(this)) { for (IrisBiome i : getDimension().getAllBiomes(this)) {
double density = 0; double density = 0;
@ -140,6 +174,7 @@ public class IrisEngine extends BlockPopulator implements Engine {
getWorldManager().close(); getWorldManager().close();
getFramework().close(); getFramework().close();
getTarget().close(); getTarget().close();
saveEngineData();
} }
@Override @Override
@ -167,6 +202,7 @@ public class IrisEngine extends BlockPopulator implements Engine {
@ChunkCoordinates @ChunkCoordinates
@Override @Override
public void generate(int x, int z, Hunk<BlockData> vblocks, Hunk<Biome> vbiomes, boolean multicore) { public void generate(int x, int z, Hunk<BlockData> vblocks, Hunk<Biome> vbiomes, boolean multicore) {
getEngineData().getStatistics().generatedChunk();
try { try {
PrecisionStopwatch p = PrecisionStopwatch.start(); PrecisionStopwatch p = PrecisionStopwatch.start();
Hunk<BlockData> blocks = vblocks.listen((xx, y, zz, t) -> catchBlockUpdates(x + xx, y + getMinHeight(), z + zz, t)); Hunk<BlockData> blocks = vblocks.listen((xx, y, zz, t) -> catchBlockUpdates(x + xx, y + getMinHeight(), z + zz, t));
@ -208,6 +244,17 @@ public class IrisEngine extends BlockPopulator implements Engine {
} }
} }
@Override
public void saveEngineData() {
File f = new File(getWorld().worldFolder(), "iris/engine-data/" + getDimension().getLoadKey() + "-" + getIndex() + ".json");
f.getParentFile().mkdirs();
try {
IO.writeAll(f, new Gson().toJson(getEngineData()));
} catch (IOException e) {
e.printStackTrace();
}
}
@Override @Override
public IrisBiome getFocus() { public IrisBiome getFocus() {
if (getDimension().getFocus() == null || getDimension().getFocus().trim().isEmpty()) { if (getDimension().getFocus() == null || getDimension().getFocus().trim().isEmpty()) {
@ -219,19 +266,10 @@ public class IrisEngine extends BlockPopulator implements Engine {
@Override @Override
public void hotloading() { public void hotloading() {
getEngineData().getStatistics().hotloaded();
close(); close();
} }
@Override
public void saveProperties() {
}
@Override
public IrisEngineData getEngineData() {
return engineData;
}
@ChunkCoordinates @ChunkCoordinates
@Override @Override
public void populate(@NotNull World world, @NotNull Random random, @NotNull Chunk c) { public void populate(@NotNull World world, @NotNull Random random, @NotNull Chunk c) {

View File

@ -48,17 +48,16 @@ import java.util.stream.Collectors;
import java.util.stream.Stream; import java.util.stream.Stream;
public class IrisWorldManager extends EngineAssignedWorldManager { public class IrisWorldManager extends EngineAssignedWorldManager {
private boolean spawnable;
private final int art; private final int art;
private final KMap<UUID, Long> spawnCooldowns; private final KMap<UUID, Long> spawnCooldowns;
private int entityCount = 0; private int entityCount = 0;
private ChronoLatch cl = new ChronoLatch(5000); private final ChronoLatch cl;
private int actuallySpawned = 0; private int actuallySpawned = 0;
public IrisWorldManager(Engine engine) { public IrisWorldManager(Engine engine) {
super(engine); super(engine);
cl = new ChronoLatch(5000);
spawnCooldowns = new KMap<>(); spawnCooldowns = new KMap<>();
spawnable = true;
art = J.ar(this::onAsyncTick, 7); art = J.ar(this::onAsyncTick, 7);
} }

View File

@ -99,12 +99,16 @@ public interface Engine extends DataProvider, Fallible, GeneratorAccess, LootPro
default void save() { default void save() {
getParallax().saveAll(); getParallax().saveAll();
saveEngineData();
} }
default void saveNow() { default void saveNow() {
getParallax().saveAllNOW(); getParallax().saveAllNOW();
saveEngineData();
} }
void saveEngineData();
default String getName() { default String getName() {
return getDimension().getName(); return getDimension().getName();
} }
@ -404,7 +408,5 @@ public interface Engine extends DataProvider, Fallible, GeneratorAccess, LootPro
void hotloading(); void hotloading();
void saveProperties();
IrisEngineData getEngineData(); IrisEngineData getEngineData();
} }

View File

@ -24,5 +24,6 @@ import lombok.Data;
@Data @Data
public class IrisEngineData public class IrisEngineData
{ {
private IrisEngineStatistics statistics = new IrisEngineStatistics();
private KList<IrisEngineSpawnerCooldown> spawnerCooldowns = new KList<>(); private KList<IrisEngineSpawnerCooldown> spawnerCooldowns = new KList<>();
} }

View File

@ -32,7 +32,6 @@ public class IrisEngineSpawnerCooldown
public void spawn(Engine engine) public void spawn(Engine engine)
{ {
lastSpawn = M.ms(); lastSpawn = M.ms();
engine.saveProperties();
} }
public boolean canSpawn(IrisRate s) public boolean canSpawn(IrisRate s)

View File

@ -0,0 +1,35 @@
/*
* Iris is a World Generator for Minecraft Bukkit Servers
* Copyright (c) 2021 Arcane Arts (Volmit Software)
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package com.volmit.iris.engine.object.engine;
import lombok.Data;
@Data
public class IrisEngineStatistics {
private int totalHotloads = 0;
private int chunksGenerated = 0;
public void generatedChunk() {
chunksGenerated++;
}
public void hotloaded() {
totalHotloads++;
}
}