zishuo/preview
1
0
Fork 0
forked from apps/plugin-preview
Code Pull Requests Activity

fix: lock map before read

Browse Source
This commit is contained in:
langhuihui
2023-12-14 13:26:34 +08:00
parent d0d43f80c4
commit 6e5ce878ed
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
main.go
View File

@@ -30,15 +30,18 @@ func (p *PreviewConfig) ServeHTTP(w http.ResponseWriter, r *http.Request) {
Streams.Range(func(streamPath string, stream *Stream) { Streams.Range(func(streamPath string, stream *Stream) {
s += fmt.Sprintf("<a href='%s'>%s</a> [ %s ]<br>", streamPath, streamPath, stream.GetType()) s += fmt.Sprintf("<a href='%s'>%s</a> [ %s ]<br>", streamPath, streamPath, stream.GetType())
}) })
s+= "<h2>pull stream on subscribe 订阅时才会触发拉流的流</h2>" s += "<h2>pull stream on subscribe 订阅时才会触发拉流的流</h2>"
for name, p := range Plugins { for name, p := range Plugins {
if pullcfg, ok := p.Config.(config.PullConfig); ok { if pullcfg, ok := p.Config.(config.PullConfig); ok {
if pullonsub := pullcfg.GetPullConfig().PullOnSub; pullonsub != nil { pullconf := pullcfg.GetPullConfig()
pullconf.PullOnSubLocker.RLock()
if pullconf.PullOnSub != nil {
s += fmt.Sprintf("<h3>%s</h3>", name) s += fmt.Sprintf("<h3>%s</h3>", name)
for streamPath, url := range pullonsub { for streamPath, url := range pullconf.PullOnSub {
s += fmt.Sprintf("<a href='%s'>%s</a> <-- %s<br>", streamPath, streamPath, url) s += fmt.Sprintf("<a href='%s'>%s</a> <-- %s<br>", streamPath, streamPath, url)
} }
} }
pullconf.PullOnSubLocker.RUnlock()
} }
} }
w.Write([]byte(s)) w.Write([]byte(s))