Compare commits
3 Commits
c11b074048
...
2579fb837d
Author | SHA1 | Date |
---|---|---|
Maurice Eisenblätter | 2579fb837d | |
Dan Mulloy | e1255edb32 | |
Maurice Eisenblätter | 55a32b5c0f |
|
@ -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);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -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 {
|
||||||
|
|
Loading…
Reference in New Issue