(session *rtsp.SubSession)
| 89 | } |
| 90 | |
| 91 | func (group *Group) HandleNewRtspSubSessionPlay(session *rtsp.SubSession) { |
| 92 | Log.Debugf("[%s] [%s] rtsp sub play.", group.UniqueKey, session.UniqueKey()) |
| 93 | |
| 94 | group.mutex.Lock() |
| 95 | defer group.mutex.Unlock() |
| 96 | |
| 97 | if group.stat.VideoCodec == "" { |
| 98 | session.ShouldWaitVideoKeyFrame = false |
| 99 | } |
| 100 | |
| 101 | group.addSub() |
| 102 | } |
| 103 | |
| 104 | func (group *Group) DelRtmpSubSession(session *rtmp.ServerSession) { |
| 105 | group.mutex.Lock() |
no test coverage detected