Compare commits
3 Commits
9e5e86eb7e
...
c11b074048
Author | SHA1 | Date |
---|---|---|
Maurice Eisenblätter | c11b074048 | |
Dan Mulloy | 6f057b361b | |
Maurice Eisenblätter | 55a32b5c0f |
|
@ -5,7 +5,7 @@ plugins {
|
|||
}
|
||||
|
||||
group = 'com.comphenix.protocol'
|
||||
version = '5.2.0-SNAPSHOT'
|
||||
version = '5.2.0'
|
||||
description = 'Provides access to the Minecraft protocol'
|
||||
|
||||
def isSnapshot = version.endsWith('-SNAPSHOT')
|
||||
|
|
|
@ -428,7 +428,7 @@ public class AsyncFilterManager implements AsynchronousManager {
|
|||
}
|
||||
|
||||
// There are no more listeners - queue the packet for transmission
|
||||
signalFreeProcessingSlot(packet);
|
||||
signalFreeProcessingSlot(packet, onMainThread);
|
||||
|
||||
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 onMainThread whether or not this method was run by the main thread.
|
||||
*/
|
||||
public void signalFreeProcessingSlot(PacketEvent packet) {
|
||||
getProcessingQueue(packet).signalProcessingDone();
|
||||
public void signalFreeProcessingSlot(PacketEvent packet, boolean onMainThread) {
|
||||
PacketProcessingQueue queue = getProcessingQueue(packet);
|
||||
// mark slot as done
|
||||
queue.signalProcessingDone();
|
||||
|
||||
// start processing next slot if possible
|
||||
queue.signalBeginProcessing(onMainThread);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
Loading…
Reference in New Issue