rob/octoplex
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix(mediaserver): avoid spurious reset of LiveChangedAt

Browse Source
This commit is contained in:
Rob Watson 2025-03-16 13:27:25 +01:00
parent 85fd91d37c
commit 7664d14207
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/mediaserver/actor.go
View File

@ -202,11 +202,19 @@ func (s *Actor) actorLoop(containerStateC <-chan domain.Container, errC <-chan e
s.logger.Error("Error fetching server state", "err", err) s.logger.Error("Error fetching server state", "err", err)
continue continue
} }
if ingressState.ready != s.state.Live || ingressState.listeners != s.state.Listeners {
var shouldSendState bool
if ingressState.ready != s.state.Live {
s.state.Live = ingressState.ready s.state.Live = ingressState.ready
s.state.LiveChangedAt = time.Now() s.state.LiveChangedAt = time.Now()
s.state.Listeners = ingressState.listeners
resetFetchTracksT(time.Second) resetFetchTracksT(time.Second)
shouldSendState = true
}
if ingressState.listeners != s.state.Listeners {
s.state.Listeners = ingressState.listeners
shouldSendState = true
}
if shouldSendState {
sendState() sendState()
} }
case <-fetchTracksT.C: case <-fetchTracksT.C: