revert packet concatenation

ZeruLight · Nov 9, 2024 · ab7bb0d · ab7bb0d
1 parent 7bf2fd5
commit ab7bb0d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/server/channelserver/sys_session.go b/server/channelserver/sys_session.go
@@ -158,9 +158,12 @@ func (s *Session) sendLoop() {
 		if s.closed {
 			return
 		}
-		err := s.cryptConn.SendPacket(append(pkt.data, []byte{0x00, 0x10}...))
-		if err != nil {
-			s.logger.Warn("Failed to send packet")
+		for len(s.sendPackets) > 0 {
+			pkt = <-s.sendPackets
+			err := s.cryptConn.SendPacket(append(pkt.data, []byte{0x00, 0x10}...))
+			if err != nil {
+				s.logger.Warn("Failed to send packet")
+			}
 		}
 		time.Sleep(time.Duration(_config.ErupeConfig.LoopDelay) * time.Millisecond)
 	}