diff --git a/pkg/logic/gop_cache.go b/pkg/logic/gop_cache.go index 8353cca..647f68d 100644 --- a/pkg/logic/gop_cache.go +++ b/pkg/logic/gop_cache.go @@ -139,7 +139,6 @@ type gopCircularQueue struct { } func NewGopCircularQueue(cap int) *gopCircularQueue { - if cap < 0 { panic("negative cap argument in NewGopCircularQueue") } diff --git a/pkg/logic/group.go b/pkg/logic/group.go index e513f9e..99252a9 100644 --- a/pkg/logic/group.go +++ b/pkg/logic/group.go @@ -218,7 +218,6 @@ func (group *Group) broadcastRTMP(msg rtmp.AVMsg) { if group.httpflvGopCache.AACSeqHeader != nil { session.WriteRawPacket(group.httpflvGopCache.AACSeqHeader) } - for i := 0; i < group.httpflvGopCache.GetGopLen(); i++ { for _, item := range group.httpflvGopCache.GetGopAt(i).data { session.WriteRawPacket(item)