diff --git a/ProtocolLib/src/com/comphenix/protocol/async/AsyncFilterManager.java b/ProtocolLib/src/com/comphenix/protocol/async/AsyncFilterManager.java index 10a46f90..c11a7b04 100644 --- a/ProtocolLib/src/com/comphenix/protocol/async/AsyncFilterManager.java +++ b/ProtocolLib/src/com/comphenix/protocol/async/AsyncFilterManager.java @@ -43,8 +43,8 @@ public class AsyncFilterManager { this.mainThread = Thread.currentThread(); } - public ListenerToken registerAsyncHandler(Plugin plugin, PacketListener listener) { - ListenerToken token = new ListenerToken(plugin, mainThread, this, listener); + public AsyncListenerHandler registerAsyncHandler(Plugin plugin, PacketListener listener) { + AsyncListenerHandler token = new AsyncListenerHandler(plugin, mainThread, this, listener); // Add listener to either or both processing queue if (hasValidWhitelist(listener.getSendingWhitelist())) @@ -63,7 +63,7 @@ public class AsyncFilterManager { * Unregisters and closes the given asynchronous handler. * @param listenerToken - asynchronous handler. */ - public void unregisterAsyncHandler(ListenerToken listenerToken) { + public void unregisterAsyncHandler(AsyncListenerHandler listenerToken) { if (listenerToken == null) throw new IllegalArgumentException("listenerToken cannot be NULL"); @@ -71,7 +71,7 @@ public class AsyncFilterManager { } // Called by ListenerToken - void unregisterAsyncHandlerInternal(ListenerToken listenerToken) { + void unregisterAsyncHandlerInternal(AsyncListenerHandler listenerToken) { PacketListener listener = listenerToken.getAsyncListener(); diff --git a/ProtocolLib/src/com/comphenix/protocol/async/ListenerToken.java b/ProtocolLib/src/com/comphenix/protocol/async/AsyncListenerHandler.java similarity index 88% rename from ProtocolLib/src/com/comphenix/protocol/async/ListenerToken.java rename to ProtocolLib/src/com/comphenix/protocol/async/AsyncListenerHandler.java index 7ada78ae..b400b8e1 100644 --- a/ProtocolLib/src/com/comphenix/protocol/async/ListenerToken.java +++ b/ProtocolLib/src/com/comphenix/protocol/async/AsyncListenerHandler.java @@ -8,7 +8,12 @@ import org.bukkit.plugin.Plugin; import com.comphenix.protocol.events.PacketEvent; import com.comphenix.protocol.events.PacketListener; -class ListenerToken { +/** + * Represents a handler for an asynchronous event. + * + * @author Kristian + */ +public class AsyncListenerHandler { /** * Signal an end to the packet processing. @@ -36,7 +41,7 @@ class ListenerToken { // Minecraft main thread private Thread mainThread; - public ListenerToken(Plugin plugin, Thread mainThread, AsyncFilterManager filterManager, PacketListener listener) { + public AsyncListenerHandler(Plugin plugin, Thread mainThread, AsyncFilterManager filterManager, PacketListener listener) { if (filterManager == null) throw new IllegalArgumentException("filterManager cannot be NULL"); if (listener == null) @@ -117,7 +122,7 @@ class ListenerToken { // Now, get the next non-cancelled listener for (; marker.getListenerTraversal().hasNext(); ) { - ListenerToken token = marker.getListenerTraversal().next().getListener(); + AsyncListenerHandler token = marker.getListenerTraversal().next().getListener(); if (!token.isCancelled()) { token.enqueuePacket(packet); diff --git a/ProtocolLib/src/com/comphenix/protocol/async/AsyncMarker.java b/ProtocolLib/src/com/comphenix/protocol/async/AsyncMarker.java index 378e9c18..51ac432d 100644 --- a/ProtocolLib/src/com/comphenix/protocol/async/AsyncMarker.java +++ b/ProtocolLib/src/com/comphenix/protocol/async/AsyncMarker.java @@ -40,7 +40,7 @@ public class AsyncMarker implements Serializable, Comparable { /** * Current list of async packet listeners. */ - private transient Iterator> listenerTraversal; + private transient Iterator> listenerTraversal; // Timeout handling private long initialTime; @@ -207,7 +207,7 @@ public class AsyncMarker implements Serializable, Comparable { * Retrieve iterator for the next listener in line. * @return Next async packet listener iterator. */ - public Iterator> getListenerTraversal() { + public Iterator> getListenerTraversal() { return listenerTraversal; } @@ -215,7 +215,7 @@ public class AsyncMarker implements Serializable, Comparable { * Set the iterator for the next listener. * @param listenerTraversal - the new async packet listener iterator. */ - void setListenerTraversal(Iterator> listenerTraversal) { + void setListenerTraversal(Iterator> listenerTraversal) { this.listenerTraversal = listenerTraversal; } diff --git a/ProtocolLib/src/com/comphenix/protocol/async/PacketProcessingQueue.java b/ProtocolLib/src/com/comphenix/protocol/async/PacketProcessingQueue.java index f703889e..c67d9d20 100644 --- a/ProtocolLib/src/com/comphenix/protocol/async/PacketProcessingQueue.java +++ b/ProtocolLib/src/com/comphenix/protocol/async/PacketProcessingQueue.java @@ -14,7 +14,7 @@ import com.comphenix.protocol.injector.PrioritizedListener; * * @author Kristian */ -class PacketProcessingQueue extends AbstractConcurrentListenerMultimap { +class PacketProcessingQueue extends AbstractConcurrentListenerMultimap { /** * Default maximum number of packets to process concurrently. @@ -76,11 +76,11 @@ class PacketProcessingQueue extends AbstractConcurrentListenerMultimap> list = getListener(packet.getPacketID()); + Collection> list = getListener(packet.getPacketID()); AsyncMarker marker = packet.getAsyncMarker(); if (list != null) { - Iterator> iterator = list.iterator(); + Iterator> iterator = list.iterator(); if (iterator.hasNext()) { marker.setListenerTraversal(iterator); @@ -117,7 +117,7 @@ class PacketProcessingQueue extends AbstractConcurrentListenerMultimap token : values()) { + for (PrioritizedListener token : values()) { if (token != null) { token.getListener().cancel(); }