Emulation/nex-go
1
0
Fork 0
mirror of https://github.com/PretendoNetwork/nex-go.git synced 2025-04-02 11:02:14 -04:00
Code Issues Projects Releases Packages Wiki Activity

fix: prevent multi-fragment messages being lost

Browse source
This commit is contained in:
Michael Wolfendale 2024-05-25 20:42:54 +01:00
parent 8e0b1a2be4
commit 363cc7b5bf
No known key found for this signature in database
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
prudp_endpoint.go
View file

@ -531,10 +531,10 @@ func (pep *PRUDPEndPoint) handleReliable(packet PRUDPPacketInterface) {
defer slidingWindow.Unlock()
for _, pendingPacket := range slidingWindow.Update(packet) {
if packet.Type() == constants.DataPacket {
if pendingPacket.Type() == constants.DataPacket {
var decryptedPayload []byte
if packet.Version() != 2 {
if pendingPacket.Version() != 2 {
decryptedPayload = pendingPacket.decryptPayload()
} else {
// * PRUDPLite does not encrypt payloads
@ -548,7 +548,7 @@ func (pep *PRUDPEndPoint) handleReliable(packet PRUDPPacketInterface) {
payload := slidingWindow.AddFragment(decompressedPayload)
if packet.getFragmentID() == 0 {
if pendingPacket.getFragmentID() == 0 {
message := NewRMCMessage(pep)
err := message.FromBytes(payload)
if err != nil {
@ -558,9 +558,9 @@ func (pep *PRUDPEndPoint) handleReliable(packet PRUDPPacketInterface) {
slidingWindow.ResetFragmentedPayload()
packet.SetRMCMessage(message)
pendingPacket.SetRMCMessage(message)
pep.emit("data", packet)
pep.emit("data", pendingPacket)
}
}
}