From 6c0135ed30d0aa586fc7c5389aa43d470329496d Mon Sep 17 00:00:00 2001
From: Nonoo <nonoo@nonoo.hu>
Date: Sat, 7 Nov 2020 15:27:52 +0100
Subject: [PATCH] Retransmit pkts twice to make sure they are received

---
 pkt0.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/pkt0.go b/pkt0.go
index c9aa4ff..a35bf62 100644
--- a/pkt0.go
+++ b/pkt0.go
@@ -35,6 +35,9 @@ func (p *pkt0Type) retransmitRange(s *streamCommon, start, end uint16) error {
 			if err := s.send(d); err != nil {
 				return err
 			}
+			if err := s.send(d); err != nil {
+				return err
+			}
 		} else {
 			log.Debug(s.name+"/can't retransmit #", start, " - not found ")
 
@@ -42,6 +45,9 @@ func (p *pkt0Type) retransmitRange(s *streamCommon, start, end uint16) error {
 			if err := p.sendIdle(s, false, start); err != nil {
 				return err
 			}
+			if err := p.sendIdle(s, false, start); err != nil {
+				return err
+			}
 		}
 
 		if start == end {
@@ -67,6 +73,9 @@ func (p *pkt0Type) handle(s *streamCommon, r []byte) error {
 			if err := s.send(d); err != nil {
 				return err
 			}
+			if err := s.send(d); err != nil {
+				return err
+			}
 		} else {
 			log.Debug(s.name+"/can't retransmit #", seq, " - not found")
 
@@ -74,6 +83,9 @@ func (p *pkt0Type) handle(s *streamCommon, r []byte) error {
 			if err := p.sendIdle(s, false, seq); err != nil {
 				return err
 			}
+			if err := p.sendIdle(s, false, seq); err != nil {
+				return err
+			}
 		}
 	} else if bytes.Equal(r[:6], []byte{0x18, 0x00, 0x00, 0x00, 0x01, 0x00}) {
 		r = r[16:]