Upstream/ProtocolLib
1
0
Fork 0
mirror of https://github.com/dmulloy2/ProtocolLib.git synced 2024-11-28 05:35:28 +01:00
Code Issues Projects Releases Wiki Activity

Clear state related to a packet when its resent.

Browse Source
This commit is contained in:
Kristian S. Stangeland 2013-12-06 02:07:42 +01:00
parent d746fcbf6c
commit 8e9c9951a9
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ProtocolLib/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java
View File

@ -434,10 +434,13 @@ class ChannelInjector extends ByteToMessageDecoder {
*/ */
public void sendServerPacket(Object packet, NetworkMarker marker, boolean filtered) { public void sendServerPacket(Object packet, NetworkMarker marker, boolean filtered) {
saveMarker(packet, marker); saveMarker(packet, marker);
processedPackets.remove(packet);
// Record if this packet should be ignored by most listeners // Record if this packet should be ignored by most listeners
if (!filtered) { if (!filtered) {
ignoredPackets.add(packet); ignoredPackets.add(packet);
} else {
ignoredPackets.remove(packet);
} }
// Attempt to send the packet with NetworkMarker.handle(), or the PlayerConnection if its active // Attempt to send the packet with NetworkMarker.handle(), or the PlayerConnection if its active
@ -460,9 +463,12 @@ class ChannelInjector extends ByteToMessageDecoder {
*/ */
public void recieveClientPacket(Object packet, NetworkMarker marker, boolean filtered) { public void recieveClientPacket(Object packet, NetworkMarker marker, boolean filtered) {
saveMarker(packet, marker); saveMarker(packet, marker);
processedPackets.remove(packet);
if (!filtered) { if (!filtered) {
ignoredPackets.add(packet); ignoredPackets.add(packet);
} else {
ignoredPackets.remove(packet);
} }
try { try {