SteamWar/ProtocolLib
Archiviert
13
0
Fork 0
Code Issues Pull-Requests Releases Wiki Aktivität

Properly cancel or modify packets intercepted in the channel thread.

Quellcode durchsuchen 
This fixes ticket #204 on BukkitDev.
Dieser Commit ist enthalten in:
Kristian S. Stangeland 2014-03-15 19:25:40 +01:00
Ursprung ad060b10af
Commit 5e0000d139
1 geänderte Dateien mit 7 neuen und 0 gelöschten Zeilen
Statistiken anzeigen Patch-Datei herunterladen Vergleichs-Datei herunterladen Alle Dateien ausklappen Alle Dateien einklappen

7
ProtocolLib/src/main/java/com/comphenix/protocol/injector/netty/ChannelInjector.java
Datei anzeigen

@ -43,6 +43,7 @@ import com.comphenix.protocol.utility.MinecraftMethods;
import com.comphenix.protocol.utility.MinecraftReflection; import com.comphenix.protocol.utility.MinecraftReflection;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
import com.google.common.collect.MapMaker; import com.google.common.collect.MapMaker;
import com.google.common.primitives.Bytes;
/** /**
* Represents a channel injector. * Represents a channel injector.
@ -311,6 +312,11 @@ class ChannelInjector extends ByteToMessageDecoder implements Injector {
} else { } else {
event = processSending(packet, marker); event = processSending(packet, marker);
// Handle the output
if (event != null) {
packet = !event.isCancelled() ? event.getPacket().getHandle() : null;
}
} }
} }
if (event != null) { if (event != null) {
@ -327,6 +333,7 @@ class ChannelInjector extends ByteToMessageDecoder implements Injector {
for (PacketOutputHandler handler : marker.getOutputHandlers()) { for (PacketOutputHandler handler : marker.getOutputHandlers()) {
handler.handle(event, data); handler.handle(event, data);
} }
// Write the result // Write the result
output.writeBytes(data); output.writeBytes(data);
return; return;