diff --git a/srt/protocol.go b/srt/protocol.go index 0857a1b..c0f2913 100644 --- a/srt/protocol.go +++ b/srt/protocol.go @@ -146,11 +146,12 @@ func (agent *SRTManager) create_conclusion_resp() (*Packet) { func (agent *SRTManager) process_conclusion(packet *Packet) (*Packet) { resp_packet := agent.create_conclusion_resp() if packet.packet_type == HANDSHAKE { + hs_cif := packet.cif.(*HandshakeCIF) + // allow previous shotgunned induction requests to dissipate if hs_cif.hs_type != 0xffffffff { return nil } - hs_cif := packet.cif.(*HandshakeCIF) if hs_cif.syn_cookie == agent.syn_cookie { for _, v := range hs_cif.hs_extensions { // force client to add a stream_id for output location