From c8f4a0b0d3eed89429ca8269691b77c8438fe539 Mon Sep 17 00:00:00 2001 From: Alessandro Ros Date: Sun, 23 Mar 2025 16:20:54 +0100 Subject: [PATCH] examples: add missing mutex in OnSetup (#729) --- examples/server-auth/main.go | 3 +++ examples/server-tls/main.go | 3 +++ examples/server/main.go | 3 +++ 3 files changed, 9 insertions(+) diff --git a/examples/server-auth/main.go b/examples/server-auth/main.go index b15901c9..1104b580 100644 --- a/examples/server-auth/main.go +++ b/examples/server-auth/main.go @@ -147,6 +147,9 @@ func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base. } } + sh.mutex.Lock() + defer sh.mutex.Unlock() + // no one is publishing yet if sh.stream == nil { return &base.Response{ diff --git a/examples/server-tls/main.go b/examples/server-tls/main.go index 751f1d83..03a899ec 100644 --- a/examples/server-tls/main.go +++ b/examples/server-tls/main.go @@ -108,6 +108,9 @@ func (sh *serverHandler) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) ( func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) { log.Printf("setup request") + sh.mutex.Lock() + defer sh.mutex.Unlock() + // no one is publishing yet if sh.stream == nil { return &base.Response{ diff --git a/examples/server/main.go b/examples/server/main.go index 2ecca102..5c875cc3 100644 --- a/examples/server/main.go +++ b/examples/server/main.go @@ -107,6 +107,9 @@ func (sh *serverHandler) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) ( func (sh *serverHandler) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error) { log.Printf("setup request") + sh.mutex.Lock() + defer sh.mutex.Unlock() + // no one is publishing yet if sh.stream == nil { return &base.Response{