From 0ec199b3af68ff3af8248d64e71a76b242d690d9 Mon Sep 17 00:00:00 2001 From: Kae <80987908+Novaenia@users.noreply.github.com> Date: Sat, 27 Jul 2024 18:56:16 +1000 Subject: [PATCH] Update StarNetPacketSocket.cpp --- source/game/StarNetPacketSocket.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/source/game/StarNetPacketSocket.cpp b/source/game/StarNetPacketSocket.cpp index 436726a..890f788 100644 --- a/source/game/StarNetPacketSocket.cpp +++ b/source/game/StarNetPacketSocket.cpp @@ -371,14 +371,14 @@ void P2PPacketSocket::sendPackets(List packets) { if (compressionStreamEnabled()) { DataStreamBuffer outBuffer; while (it.hasNext()) { - PacketPtr& packet = it.next(); - auto packetType = packet->type(); + PacketType currentType = it.peekNext()->type(); DataStreamBuffer packetBuffer; - packet->write(packetBuffer); - outBuffer.write(packetType); - outBuffer.writeVlqI((int)packetBuffer.size()); + while (it.hasNext() && it.peekNext()->type() == currentType) + it.next()->write(packetBuffer); + outBuffer.write(currentType); + outBuffer.write(false); outBuffer.writeData(packetBuffer.ptr(), packetBuffer.size()); - m_outgoingStats.mix(packetType, packetBuffer.size(), false); + m_outgoingStats.mix(currentType, packetBuffer.size(), false); } m_outputMessages.append(m_compressionStream.compress(outBuffer.data())); } else {