Minecraft/mc-core
Archived
0
Fork 0
Code Activity

бросать исключение при неудачной записи пакета в сеть

Browse Source
This commit is contained in:
DmitriyMX
2018-10-28 21:16:15 +03:00
parent c6431dbe43
commit 385d62f8c6
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/PacketEncoder.java
View File

@@ -13,8 +13,10 @@ import mc.core.network.SCPacket;
import mc.core.network.proto_1_12_2.ByteArrayOutputNetStream; import mc.core.network.proto_1_12_2.ByteArrayOutputNetStream;
import mc.core.network.proto_1_12_2.State; import mc.core.network.proto_1_12_2.State;
import mc.core.network.proto_1_12_2.netty.wrappers.WrapperNetOutputStream; import mc.core.network.proto_1_12_2.netty.wrappers.WrapperNetOutputStream;
import org.slf4j.helpers.MessageFormatter;
import static mc.core.network.proto_1_12_2.netty.NettyServer.ATTR_STATE; import static mc.core.network.proto_1_12_2.netty.NettyServer.ATTR_STATE;
import static org.slf4j.helpers.MessageFormatter.format;
@Slf4j @Slf4j
public class PacketEncoder extends MessageToByteEncoder<SCPacket> { public class PacketEncoder extends MessageToByteEncoder<SCPacket> {
@@ -41,13 +43,17 @@ public class PacketEncoder extends MessageToByteEncoder<SCPacket> {
log.debug("Send {}:{}", state, packet); log.debug("Send {}:{}", state, packet);
NetOutputStream netStream = new ByteArrayOutputNetStream(); try {
packet.writeSelf(netStream); NetOutputStream netStream = new ByteArrayOutputNetStream();
byte[] bytes = ((ByteArrayOutputNetStream) netStream).toByteArray(); packet.writeSelf(netStream);
netStream = new WrapperNetOutputStream(out); byte[] bytes = ((ByteArrayOutputNetStream) netStream).toByteArray();
netStream = new WrapperNetOutputStream(out);
netStream.writeVarInt(bytes.length + sizeVarInt(id)); netStream.writeVarInt(bytes.length + sizeVarInt(id));
netStream.writeVarInt(id); netStream.writeVarInt(id);
netStream.writeBytes(bytes); netStream.writeBytes(bytes);
} catch (Throwable t) {
log.error(format("Error encoding packet {}:{}", state, packet).getMessage(), t);
}
} }
} }