examples cleanup

This commit is contained in:
Avi Zimmerman
2021-01-20 15:52:16 +02:00
parent e6ad9ab977
commit dad32ff7cf
5 changed files with 13 additions and 6 deletions

View File

@@ -85,6 +85,7 @@ func (m *minioSrc) GetSize(self *base.GstBaseSrc) (bool, int64) {
func (m *minioSrc) Start(self *base.GstBaseSrc) bool {
m.state.mux.Lock()
defer m.state.mux.Unlock()
if m.state.started {
self.ErrorMessage(gst.DomainResource, gst.ResourceErrorFailed, "MinIOSrc is already started", "")
@@ -137,8 +138,6 @@ func (m *minioSrc) Start(self *base.GstBaseSrc) bool {
m.state.started = true
m.state.mux.Unlock()
self.StartComplete(gst.FlowOK)
self.Log(srcCAT, gst.LevelInfo, "MinIOSrc has started")