Skip to content

Commit

Permalink
feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
thiakil committed Feb 11, 2025
1 parent 5b3cc7d commit 5bcc0a6
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 7 deletions.
4 changes: 1 addition & 3 deletions patches/net/minecraft/server/level/ServerLevel.java.patch
Original file line number Diff line number Diff line change
Expand Up @@ -112,15 +112,13 @@
this.getProfiler().pop();

for (Entity entity : p_8648_.getPassengers()) {
@@ -807,6 +_,12 @@
@@ -807,6 +_,10 @@
} else {
this.entityManager.autoSave();
}
+ net.neoforged.neoforge.common.NeoForge.EVENT_BUS.post(new net.neoforged.neoforge.event.level.LevelEvent.Save(this));
+ if (p_8645_) {
+ net.neoforged.neoforge.common.IOUtilities.waitUntilIOWorkerComplete();
+ } else {
+ net.neoforged.neoforge.common.IOUtilities.clearWorkerWhenDone();
+ }
}
}
Expand Down
4 changes: 0 additions & 4 deletions src/main/java/net/neoforged/neoforge/common/IOUtilities.java
Original file line number Diff line number Diff line change
Expand Up @@ -160,10 +160,6 @@ public static void withIOWorker(Runnable task) {
saveDataTasks = saveDataTasks.thenRunAsync(task, Util.ioPool());
}

public static void clearWorkerWhenDone() {
withIOWorker(() -> saveDataTasks = CompletableFuture.completedFuture(null));
}

public static void waitUntilIOWorkerComplete() {
saveDataTasks.join();
saveDataTasks = CompletableFuture.completedFuture(null);
Expand Down

0 comments on commit 5bcc0a6

Please sign in to comment.