RepoMirrors/mediamtx
1
0
Fork 0
mirror of https://github.com/bluenviron/mediamtx synced 2025-03-04 19:37:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

api: improve performance by using RWMutex (#2968)

Browse Source
This commit is contained in:
Alessandro Ros 2024-01-31 22:41:37 +01:00 committed by GitHub
parent 97c58b4530
commit 320f5a7a21
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/api/api.go
View File

@ -167,7 +167,7 @@ type API struct {
Parent apiParent
httpServer *httpserv.WrappedServer
mutex sync.Mutex
mutex sync.RWMutex
}
// Initialize initializes API.
@ -281,9 +281,9 @@ func (a *API) writeError(ctx *gin.Context, status int, err error) {
}
func (a *API) onConfigGlobalGet(ctx *gin.Context) {
a.mutex.Lock()
a.mutex.RLock()
c := a.Conf
a.mutex.Unlock()
a.mutex.RUnlock()
ctx.JSON(http.StatusOK, c.Global())
}
@ -319,9 +319,9 @@ func (a *API) onConfigGlobalPatch(ctx *gin.Context) {
}
func (a *API) onConfigPathDefaultsGet(ctx *gin.Context) {
a.mutex.Lock()
a.mutex.RLock()
c := a.Conf
a.mutex.Unlock()
a.mutex.RUnlock()
ctx.JSON(http.StatusOK, c.PathDefaults)
}
@ -354,9 +354,9 @@ func (a *API) onConfigPathDefaultsPatch(ctx *gin.Context) {
}
func (a *API) onConfigPathsList(ctx *gin.Context) {
a.mutex.Lock()
a.mutex.RLock()
c := a.Conf
a.mutex.Unlock()
a.mutex.RUnlock()
data := &defs.APIPathConfList{
Items: make([]*conf.Path, len(c.Paths)),
@ -384,9 +384,9 @@ func (a *API) onConfigPathsGet(ctx *gin.Context) {
return
}
a.mutex.Lock()
a.mutex.RLock()
c := a.Conf
a.mutex.Unlock()
a.mutex.RUnlock()
p, ok := c.Paths[name]
if !ok {