zgaetano/datarhei-dragonfork-core
1
0
Fork 0
Code Issues 2 Pull requests Projects Releases 4 Packages Wiki Activity Actions

Set a default of 20ms for internal SRT latency

Browse source
This commit is contained in:
Ingo Oppermann 2022-12-27 13:46:02 +01:00
parent ee2a188be8
commit 8a1dc59a81
No known key found for this signature in database
GPG key ID: 2AB32426E9DD229E
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
app/api/api.go
View file

@ -445,8 +445,8 @@ func (a *api) start() error {
a.replacer = replace.New() a.replacer = replace.New()
{ {
a.replacer.RegisterTemplate("diskfs", a.diskfs.Base()) a.replacer.RegisterTemplate("diskfs", a.diskfs.Base(), nil)
a.replacer.RegisterTemplate("memfs", a.memfs.Base()) a.replacer.RegisterTemplate("memfs", a.memfs.Base(), nil)
host, port, _ := gonet.SplitHostPort(cfg.RTMP.Address) host, port, _ := gonet.SplitHostPort(cfg.RTMP.Address)
if len(host) == 0 { if len(host) == 0 {
@ -463,21 +463,23 @@ func (a *api) start() error {
template += "?token=" + cfg.RTMP.Token template += "?token=" + cfg.RTMP.Token
} }
a.replacer.RegisterTemplate("rtmp", template) a.replacer.RegisterTemplate("rtmp", template, nil)
host, port, _ = gonet.SplitHostPort(cfg.SRT.Address) host, port, _ = gonet.SplitHostPort(cfg.SRT.Address)
if len(host) == 0 { if len(host) == 0 {
host = "localhost" host = "localhost"
} }
template = "srt://" + host + ":" + port + "?mode=caller&transtype=live&streamid={name},mode:{mode}" template = "srt://" + host + ":" + port + "?mode=caller&transtype=live&latency={latency}&streamid={name},mode:{mode}"
if len(cfg.SRT.Token) != 0 { if len(cfg.SRT.Token) != 0 {
template += ",token:" + cfg.SRT.Token template += ",token:" + cfg.SRT.Token
} }
if len(cfg.SRT.Passphrase) != 0 { if len(cfg.SRT.Passphrase) != 0 {
template += "&passphrase=" + cfg.SRT.Passphrase template += "&passphrase=" + cfg.SRT.Passphrase
} }
a.replacer.RegisterTemplate("srt", template) a.replacer.RegisterTemplate("srt", template, map[string]string{
"latency": "20000", // 20 milliseconds, FFmpeg requires microseconds
})
} }
store := store.NewJSONStore(store.JSONConfig{ store := store.NewJSONStore(store.JSONConfig{