From 3149203f36f5a19d569cb9add5cb8882aebfab90 Mon Sep 17 00:00:00 2001 From: aler9 <46489434+aler9@users.noreply.github.com> Date: Sun, 3 Oct 2021 15:22:42 +0200 Subject: [PATCH] print log messages about custom commands closing after they are closed --- internal/core/path.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/core/path.go b/internal/core/path.go index 52640716..ddaa4ea6 100644 --- a/internal/core/path.go +++ b/internal/core/path.go @@ -419,8 +419,8 @@ outer: pa.onDemandCloseTimer.Stop() if onInitCmd != nil { - pa.Log(logger.Info, "runOnInit command stopped") onInitCmd.Close() + pa.Log(logger.Info, "runOnInit command stopped") } for _, req := range pa.describeRequests { @@ -439,8 +439,8 @@ outer: } if pa.onDemandCmd != nil { - pa.Log(logger.Info, "runOnDemand command stopped") pa.onDemandCmd.Close() + pa.Log(logger.Info, "runOnDemand command stopped") } if pa.stream != nil { @@ -521,9 +521,9 @@ func (pa *path) onDemandCloseSource() { pa.source = nil } else { if pa.onDemandCmd != nil { - pa.Log(logger.Info, "runOnDemand command stopped") pa.onDemandCmd.Close() pa.onDemandCmd = nil + pa.Log(logger.Info, "runOnDemand command stopped") } if pa.source != nil { @@ -565,9 +565,9 @@ func (pa *path) sourceSetReady(tracks gortsplib.Tracks) { func (pa *path) sourceSetNotReady() { if pa.onPublishCmd != nil { - pa.Log(logger.Info, "runOnPublish command stopped") pa.onPublishCmd.Close() pa.onPublishCmd = nil + pa.Log(logger.Info, "runOnPublish command stopped") } for r := range pa.readers {