mirror of
https://github.com/PaperMC/Paper.git
synced 2025-08-01 20:52:12 -07:00
Did not double-flush the file io thread if async = false
This commit is contained in:
@@ -1886,7 +1886,7 @@ index 000000000..1dfa8abfd
|
|||||||
+}
|
+}
|
||||||
diff --git a/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java b/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java
|
diff --git a/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java b/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java
|
||||||
new file mode 100644
|
new file mode 100644
|
||||||
index 000000000..98a9744a0
|
index 000000000..695e9909f
|
||||||
--- /dev/null
|
--- /dev/null
|
||||||
+++ b/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java
|
+++ b/src/main/java/com/destroystokyo/paper/io/chunk/ChunkTaskManager.java
|
||||||
@@ -0,0 +0,0 @@
|
@@ -0,0 +0,0 @@
|
||||||
@@ -2239,12 +2239,11 @@ index 000000000..98a9744a0
|
|||||||
+ });
|
+ });
|
||||||
+ wait.join();
|
+ wait.join();
|
||||||
+ }
|
+ }
|
||||||
+ return;
|
+ } else {
|
||||||
+ }
|
|
||||||
+
|
|
||||||
+ for (final QueueExecutorThread<ChunkTask> worker : this.workers) {
|
+ for (final QueueExecutorThread<ChunkTask> worker : this.workers) {
|
||||||
+ worker.flush();
|
+ worker.flush();
|
||||||
+ }
|
+ }
|
||||||
|
+ }
|
||||||
+
|
+
|
||||||
+ // flush again since tasks we execute async saves
|
+ // flush again since tasks we execute async saves
|
||||||
+ drainChunkWaitQueue();
|
+ drainChunkWaitQueue();
|
||||||
|
Reference in New Issue
Block a user