Update to MC 1.12-pre2
This commit is contained in:
@@ -5,7 +5,7 @@ Subject: [PATCH] Optimise NetworkManager
|
||||
|
||||
|
||||
diff --git a/src/main/java/net/minecraft/server/NetworkManager.java b/src/main/java/net/minecraft/server/NetworkManager.java
|
||||
index 184ef32a8..be14c0b25 100644
|
||||
index 58011bb2f..fb118e90b 100644
|
||||
--- a/src/main/java/net/minecraft/server/NetworkManager.java
|
||||
+++ b/src/main/java/net/minecraft/server/NetworkManager.java
|
||||
@@ -0,0 +0,0 @@ public class NetworkManager extends SimpleChannelInboundHandler<Packet<?>> {
|
||||
@@ -27,23 +27,12 @@ index 184ef32a8..be14c0b25 100644
|
||||
- this.j.writeLock().lock();
|
||||
-
|
||||
- try {
|
||||
- this.i.add(new NetworkManager.QueuedPacket(packet, (GenericFutureListener[]) null));
|
||||
- this.i.add(new NetworkManager.QueuedPacket(packet, new GenericFutureListener[0]));
|
||||
- } finally {
|
||||
- this.j.writeLock().unlock();
|
||||
- }
|
||||
}
|
||||
-
|
||||
+ // Paper start - Remove but force a conflict
|
||||
+// else {
|
||||
+// this.j.writeLock().lock();
|
||||
+//
|
||||
+// try {
|
||||
+// this.i.add(new NetworkManager.QueuedPacket(packet, (GenericFutureListener[]) null));
|
||||
+// } finally {
|
||||
+// this.j.writeLock().unlock();
|
||||
+// }
|
||||
+// }
|
||||
+ // Paper end
|
||||
}
|
||||
|
||||
public void sendPacket(Packet<?> packet, GenericFutureListener<? extends Future<? super Void>> genericfuturelistener, GenericFutureListener<? extends Future<? super Void>>... agenericfuturelistener) {
|
||||
@@ -60,17 +49,6 @@ index 184ef32a8..be14c0b25 100644
|
||||
- }
|
||||
}
|
||||
-
|
||||
+ // Paper start - Remove but force a conflict
|
||||
+// else {
|
||||
+// this.j.writeLock().lock();
|
||||
+//
|
||||
+// try {
|
||||
+// this.i.add(new NetworkManager.QueuedPacket(packet, (GenericFutureListener[]) ArrayUtils.add(agenericfuturelistener, 0, genericfuturelistener)));
|
||||
+// } finally {
|
||||
+// this.j.writeLock().unlock();
|
||||
+// }
|
||||
+// }
|
||||
+ // Paper end
|
||||
}
|
||||
|
||||
private void a(final Packet<?> packet, @Nullable final GenericFutureListener<? extends Future<? super Void>>[] agenericfuturelistener) {
|
||||
@@ -92,22 +70,7 @@ index 184ef32a8..be14c0b25 100644
|
||||
- }
|
||||
-
|
||||
- }
|
||||
+ // Paper start - Remove but force a conflict
|
||||
+// if (this.channel != null && this.channel.isOpen()) {
|
||||
+// this.j.readLock().lock();
|
||||
+//
|
||||
+// try {
|
||||
+// while (!this.i.isEmpty()) {
|
||||
+// NetworkManager.QueuedPacket networkmanager_queuedpacket = (NetworkManager.QueuedPacket) this.i.poll();
|
||||
+//
|
||||
+// this.a(networkmanager_queuedpacket.a, networkmanager_queuedpacket.b);
|
||||
+// }
|
||||
+// } finally {
|
||||
+// this.j.readLock().unlock();
|
||||
+// }
|
||||
+//
|
||||
+// }
|
||||
+ // Paper end
|
||||
+ // Paper - Contents removed
|
||||
}
|
||||
|
||||
public void a() {
|
||||
|
||||
Reference in New Issue
Block a user