Method disposeInactiveSessions

pkg/logic/group__.go:426–500

--------------------------------------------------------------------------------------------------------------------- disposeInactiveSessions 关闭不活跃的session

(tickCount uint32)

// disposeInactiveSessions 关闭不活跃的session
func (group *Group) disposeInactiveSessions(tickCount uint32) {
	if group.psPubSession != nil {
		if group.psPubTimeoutSec == 0 {
			// noop
			// 没有超时逻辑
		} else {
			if group.psPubPrevInactiveCheckTick == -1 ||
				tickCount-uint32(group.psPubPrevInactiveCheckTick) >= group.psPubTimeoutSec {

				if readAlive, _ := group.psPubSession.IsAlive(); !readAlive {
					Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, group.psPubSession.UniqueKey())
					group.psPubSession.Dispose()
				}

				group.psPubPrevInactiveCheckTick = int64(tickCount)
			}
		}
	}

	// 以下都是以 CheckSessionAliveIntervalSec 为间隔的清理逻辑

	if tickCount%CheckSessionAliveIntervalSec != 0 {
		return
	}

	if group.rtmpPubSession != nil {
		if readAlive, _ := group.rtmpPubSession.IsAlive(); !readAlive {
			Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, group.rtmpPubSession.UniqueKey())
			group.rtmpPubSession.Dispose()
		}
	}
	if group.rtspPubSession != nil {
		if readAlive, _ := group.rtspPubSession.IsAlive(); !readAlive {
			Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, group.rtspPubSession.UniqueKey())
			group.rtspPubSession.Dispose()
		}
	}

	group.disposeInactivePullSession()

	for session := range group.rtmpSubSessionSet {
		if _, writeAlive := session.IsAlive(); !writeAlive {
			Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, session.UniqueKey())
			session.Dispose()
		}
	}
	for session := range group.rtspSubSessionSet {
		if _, writeAlive := session.IsAlive(); !writeAlive {
			Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, session.UniqueKey())
			session.Dispose()
		}
	}

	for session := range group.httpflvSubSessionSet {
		if _, writeAlive := session.IsAlive(); !writeAlive {
			Log.Warnf("[%s] session timeout. session=%s", group.UniqueKey, session.UniqueKey())
			session.Dispose()
		}