neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add retry after failed connect to event source

Browse Source
This commit is contained in:
Ingo Oppermann 2025-10-21 15:44:13 +02:00
parent e077cd48a6
commit 1eac7d05c5
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cluster/node/core.go
View File

@ -96,7 +96,7 @@ type Core struct {
hasSRT bool
srtAddress *url.URL
media map[string]*Media // map[storage]map[path]lastchange
media map[string]*Media
mediaLock sync.RWMutex
logger log.Logger
@ -333,15 +333,15 @@ func (n *Core) mediaEvents(ctx context.Context, storage string) {
ch, err := n.client.MediaEvents(ctx, storage, "/**")
if err != nil {
m.available = false
m.media = nil
m.media = map[string]int64{}
n.mediaLock.Lock()
n.media[storage] = m
n.mediaLock.Unlock()
n.logger.Error().WithField("storage", storage).WithError(err).Log("Failed to connect to event source")
return
time.Sleep(5 * time.Second)
continue
}
n.logger.Info().WithField("storage", storage).Log("Connected to event source")