aboutsummaryrefslogtreecommitdiffhomepage
path: root/patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch
diff options
context:
space:
mode:
Diffstat (limited to 'patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch')
-rw-r--r--patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch86
1 files changed, 86 insertions, 0 deletions
diff --git a/patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch b/patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch
new file mode 100644
index 0000000000..670063cc65
--- /dev/null
+++ b/patches/server/0664-Synchronize-PalettedContainer-instead-of-ReentrantLo.patch
@@ -0,0 +1,86 @@
+From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
+From: Aikar <[email protected]>
+Date: Fri, 29 May 2020 20:29:02 -0400
+Subject: [PATCH] Synchronize PalettedContainer instead of ReentrantLock
+
+Mojang has flaws in their logic about chunks being concurrently
+wrote to. So we constantly see crashes around multiple threads writing.
+
+Additionally, java has optimized synchronization so well that its
+in many times faster than trying to manage read wrote locks for low
+contention situations.
+
+And this is extremely a low contention situation.
+
+diff --git a/src/main/java/net/minecraft/world/level/chunk/PalettedContainer.java b/src/main/java/net/minecraft/world/level/chunk/PalettedContainer.java
+index 45a969f97b26e328e34f3d576557999c32b954a2..83dc9550f4ed2a138d4ece2765273e555cda994a 100644
+--- a/src/main/java/net/minecraft/world/level/chunk/PalettedContainer.java
++++ b/src/main/java/net/minecraft/world/level/chunk/PalettedContainer.java
+@@ -35,11 +35,11 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+ private final ThreadingDetector threadingDetector = new ThreadingDetector("PalettedContainer");
+
+ public void acquire() {
+- this.threadingDetector.checkAndLock();
++ // this.threadingDetector.checkAndLock(); // Paper - disable this - use proper synchronization
+ }
+
+ public void release() {
+- this.threadingDetector.checkAndUnlock();
++ // this.threadingDetector.checkAndUnlock(); // Paper - disable this
+ }
+
+ // Paper start - Anti-Xray - Add preset values
+@@ -143,7 +143,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+ }
+ // Paper end
+
+- public T getAndSet(int x, int y, int z, T value) {
++ public synchronized T getAndSet(int x, int y, int z, T value) { // Paper - synchronize
+ this.acquire();
+
+ Object var5;
+@@ -166,7 +166,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+ return this.data.palette.valueFor(j);
+ }
+
+- public void set(int x, int y, int z, T value) {
++ public synchronized void set(int x, int y, int z, T value) { // Paper - synchronize
+ this.acquire();
+
+ try {
+@@ -200,7 +200,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+ });
+ }
+
+- public void read(FriendlyByteBuf buf) {
++ public synchronized void read(FriendlyByteBuf buf) { // Paper - synchronize
+ this.acquire();
+
+ try {
+@@ -218,7 +218,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+
+ // Paper start - Anti-Xray - Add chunk packet info
+ @Deprecated public void write(FriendlyByteBuf buf) { this.write(buf, null, 0); } // Notice for updates: Please make sure this method isn't used anywhere
+- public void write(FriendlyByteBuf buf, @Nullable com.destroystokyo.paper.antixray.ChunkPacketInfo<T> chunkPacketInfo, int bottomBlockY) {
++ public synchronized void write(FriendlyByteBuf buf, @Nullable com.destroystokyo.paper.antixray.ChunkPacketInfo<T> chunkPacketInfo, int bottomBlockY) { // Paper - synchronize
+ this.acquire();
+
+ try {
+@@ -236,7 +236,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+
+ }
+
+- private static <T> DataResult<PalettedContainer<T>> read(IdMap<T> idList, PalettedContainer.Strategy provider, PalettedContainer.DiscData<T> serialized, T defaultValue, T @org.jetbrains.annotations.Nullable [] presetValues) { // Paper - Anti-Xray - Add preset values
++ private synchronized static <T> DataResult<PalettedContainer<T>> read(IdMap<T> idList, PalettedContainer.Strategy provider, PalettedContainer.DiscData<T> serialized, T defaultValue, T @org.jetbrains.annotations.Nullable [] presetValues) { // Paper - Anti-Xray - Add preset values // Paper - synchronize
+ List<T> list = serialized.paletteEntries();
+ int i = provider.size();
+ int j = provider.calculateBitsForSerialization(idList, list.size());
+@@ -275,7 +275,7 @@ public class PalettedContainer<T> implements PaletteResize<T> {
+ return DataResult.success(new PalettedContainer<>(idList, provider, configuration, bitStorage, list, defaultValue, presetValues)); // Paper - Anti-Xray - Add preset values
+ }
+
+- private PalettedContainer.DiscData<T> write(IdMap<T> idList, PalettedContainer.Strategy provider) {
++ private synchronized PalettedContainer.DiscData<T> write(IdMap<T> idList, PalettedContainer.Strategy provider) { // Paper - synchronize
+ this.acquire();
+
+ PalettedContainer.DiscData var12;