summaryrefslogtreecommitdiff
path: root/src/daq/s5proxy/src/s5proxy/stats.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/daq/s5proxy/src/s5proxy/stats.go')
-rw-r--r--src/daq/s5proxy/src/s5proxy/stats.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/daq/s5proxy/src/s5proxy/stats.go b/src/daq/s5proxy/src/s5proxy/stats.go
index 85e848c..b4eccaa 100644
--- a/src/daq/s5proxy/src/s5proxy/stats.go
+++ b/src/daq/s5proxy/src/s5proxy/stats.go
@@ -222,14 +222,14 @@ func NewStats(conf *Config) (s *Stats, err error) {
s.updates = make(chan *UpdateFull, 1000)
s.workers = make(map[string]StatsWorker)
var content, format, quality []string
- for _, desc := range conf.SFive.Stream {
- if content, format, quality, err = parseStreamDescription(desc); err != nil {
+ for _, match := range conf.SFive.Matches {
+ if content, format, quality, err = parseStreamDescription(match.Streams); err != nil {
return
}
for _, c := range content {
for _, f := range format {
for _, q := range quality {
- name := generateStreamName(conf.SFive.Format, c, f, q)
+ name := generateStreamName(match.Format, c, f, q)
s.workers[name] = NewStatsWorker(Stream{c, f, q}, s.updates)
s5l.Printf("STATS: adding streamer '%s'", name)
}