Compare commits

...

3 Commits

Author SHA1 Message Date
Maurice Eisenblätter 2579fb837d
Merge 55a32b5c0f into e1255edb32 2024-04-07 19:44:56 +02:00
Dan Mulloy e1255edb32
Fix build 2024-04-07 11:18:58 -05:00
Maurice Eisenblätter 55a32b5c0f
fix: start processing further packets if a packet is done 2023-09-27 20:32:27 +02:00
2 changed files with 21 additions and 4 deletions

View File

@ -428,7 +428,7 @@ public class AsyncFilterManager implements AsynchronousManager {
} }
// There are no more listeners - queue the packet for transmission // There are no more listeners - queue the packet for transmission
signalFreeProcessingSlot(packet); signalFreeProcessingSlot(packet, onMainThread);
PacketSendingQueue queue = getSendingQueue(packet, false); PacketSendingQueue queue = getSendingQueue(packet, false);
@ -467,11 +467,18 @@ public class AsyncFilterManager implements AsynchronousManager {
} }
/** /**
* Signal that a packet has finished processing. * Signal that a packet has finished processing. Tries to process further packets
* if a processing slot is still free.
* @param packet - packet to signal. * @param packet - packet to signal.
* @param onMainThread whether or not this method was run by the main thread.
*/ */
public void signalFreeProcessingSlot(PacketEvent packet) { public void signalFreeProcessingSlot(PacketEvent packet, boolean onMainThread) {
getProcessingQueue(packet).signalProcessingDone(); PacketProcessingQueue queue = getProcessingQueue(packet);
// mark slot as done
queue.signalProcessingDone();
// start processing next slot if possible
queue.signalBeginProcessing(onMainThread);
} }
/** /**

View File

@ -145,6 +145,16 @@ class SerializedOfflinePlayer implements OfflinePlayer, Serializable {
return lastSeen; return lastSeen;
} }
@Override
public Location getRespawnLocation() {
return null;
}
@Override
public Location getLocation() {
return null;
}
// TODO do we need to implement this? // TODO do we need to implement this?
public void incrementStatistic(Statistic statistic) throws IllegalArgumentException { public void incrementStatistic(Statistic statistic) throws IllegalArgumentException {