diff --git a/examples/server-tls/main.go b/examples/server-tls/main.go index 5271bbd7..d473635e 100644 --- a/examples/server-tls/main.go +++ b/examples/server-tls/main.go @@ -119,15 +119,6 @@ func (sh *serverHandler) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Re func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) { log.Printf("record request") - sh.mutex.Lock() - defer sh.mutex.Unlock() - - if ctx.Session != sh.publisher { - return &base.Response{ - StatusCode: base.StatusBadRequest, - }, fmt.Errorf("someone is already publishing") - } - return &base.Response{ StatusCode: base.StatusOK, }, nil diff --git a/examples/server/main.go b/examples/server/main.go index e5990101..8ac176ac 100644 --- a/examples/server/main.go +++ b/examples/server/main.go @@ -118,15 +118,6 @@ func (sh *serverHandler) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Re func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) { log.Printf("record request") - sh.mutex.Lock() - defer sh.mutex.Unlock() - - if ctx.Session != sh.publisher { - return &base.Response{ - StatusCode: base.StatusBadRequest, - }, fmt.Errorf("someone is already publishing") - } - return &base.Response{ StatusCode: base.StatusOK, }, nil diff --git a/server_test.go b/server_test.go index 81cb1ced..1a65a8ad 100644 --- a/server_test.go +++ b/server_test.go @@ -360,15 +360,6 @@ func TestServerHighLevelPublishRead(t *testing.T) { }, fmt.Errorf("invalid path (%s)", ctx.Req.URL) } - mutex.Lock() - defer mutex.Unlock() - - if ctx.Session != publisher { - return &base.Response{ - StatusCode: base.StatusBadRequest, - }, fmt.Errorf("someone is already publishing") - } - return &base.Response{ StatusCode: base.StatusOK, }, nil