Repo-Mirror/AkarinMC
9
0
Fork 0
Code Issues Pull Requests Releases Activity

[ci skip] Corrects name

Browse Source
This commit is contained in:
Sotr
2018-06-09 16:08:45 +08:00
parent 87f1537342
commit f1f1d409c4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
sources/src/main/java/io/akarin/server/mixin/core/OptimisticNetworkManager.java
View File

@@ -28,7 +28,7 @@ public class OptimisticNetworkManager {
@Shadow private Queue<NetworkManager.QueuedPacket> getPacketQueue() { return null; } @Shadow private Queue<NetworkManager.QueuedPacket> getPacketQueue() { return null; }
@Shadow private void dispatchPacket(Packet<?> packet, GenericFutureListener<? extends Future<? super Void>>[] genericFutureListeners) {} @Shadow private void dispatchPacket(Packet<?> packet, GenericFutureListener<? extends Future<? super Void>>[] genericFutureListeners) {}
private static final Predicate<QueuedPacket> IS_CHUNK_READY = new Predicate<QueuedPacket>() { private static final Predicate<QueuedPacket> IS_CHUNK_NOT_READY = new Predicate<QueuedPacket>() {
@Override @Override
public boolean apply(QueuedPacket item) { public boolean apply(QueuedPacket item) {
Packet<?> packet = item.getPacket(); Packet<?> packet = item.getPacket();
@@ -48,7 +48,7 @@ public class OptimisticNetworkManager {
this.j.readLock().lock(); this.j.readLock().lock();
try { try {
while (!this.i.isEmpty()) { while (!this.i.isEmpty()) {
NetworkManager.QueuedPacket packet = ((CheckedConcurrentLinkedQueue<QueuedPacket>) getPacketQueue()).poll(IS_CHUNK_READY, SIGNAL_PACKET); NetworkManager.QueuedPacket packet = ((CheckedConcurrentLinkedQueue<QueuedPacket>) getPacketQueue()).poll(IS_CHUNK_NOT_READY, SIGNAL_PACKET);
if (packet != null) { // Fix NPE (Spigot bug caused by handleDisconnection()) if (packet != null) { // Fix NPE (Spigot bug caused by handleDisconnection())
if (packet == SIGNAL_PACKET) { if (packet == SIGNAL_PACKET) {