package/gortsplib
1
0
Fork 0
mirror of https://github.com/aler9/gortsplib synced 2025-10-05 15:16:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

examples: add missing mutex in OnSetup (#729)

Browse Source
This commit is contained in:
Alessandro Ros
2025-03-23 16:20:54 +01:00
committed by GitHub
parent fcb018151b
commit c8f4a0b0d3
3 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
examples/server-auth/main.go
View File

@@ -147,6 +147,9 @@ func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.
} }
} }
sh.mutex.Lock()
defer sh.mutex.Unlock()
// no one is publishing yet // no one is publishing yet
if sh.stream == nil { if sh.stream == nil {
return &base.Response{ return &base.Response{

3
examples/server-tls/main.go
View File

@@ -108,6 +108,9 @@ func (sh *serverHandler) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (
func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) { func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) {
log.Printf("setup request") log.Printf("setup request")
sh.mutex.Lock()
defer sh.mutex.Unlock()
// no one is publishing yet // no one is publishing yet
if sh.stream == nil { if sh.stream == nil {
return &base.Response{ return &base.Response{

3
examples/server/main.go
View File

@@ -107,6 +107,9 @@ func (sh *serverHandler) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (
func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) { func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) {
log.Printf("setup request") log.Printf("setup request")
sh.mutex.Lock()
defer sh.mutex.Unlock()
// no one is publishing yet // no one is publishing yet
if sh.stream == nil { if sh.stream == nil {
return &base.Response{ return &base.Response{