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

server: remove useless check

Browse Source
This commit is contained in:
aler9
2021-06-06 13:54:41 +02:00
parent 7f3ef73b0a
commit ebe40cfc95
3 changed files with 0 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -119,15 +119,6 @@ func (sh *serverHandler) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Re
func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) { func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) {
log.Printf("record request") 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{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
}, nil }, nil

9
examples/server/main.go
View File

@@ -118,15 +118,6 @@ func (sh *serverHandler) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Re
func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) { func (sh *serverHandler) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error) {
log.Printf("record request") 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{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
}, nil }, nil

9
server_test.go
View File

@@ -360,15 +360,6 @@ func TestServerHighLevelPublishRead(t *testing.T) {
}, fmt.Errorf("invalid path (%s)", ctx.Req.URL) }, 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{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
}, nil }, nil