From 692d80fc3eafe2d210d56ace061e1b3b7345b85e Mon Sep 17 00:00:00 2001 From: Sergey Petrov Date: Mon, 7 Apr 2025 10:14:17 +0500 Subject: [PATCH] Added DirData field. --- writer/internal/ingest/rtsp/rtsp.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/writer/internal/ingest/rtsp/rtsp.go b/writer/internal/ingest/rtsp/rtsp.go index b91299d..9b87ac1 100644 --- a/writer/internal/ingest/rtsp/rtsp.go +++ b/writer/internal/ingest/rtsp/rtsp.go @@ -54,11 +54,11 @@ func rtsp(dir string, period int, link string, number int) error { defer metrics.ActiveCameras.Dec() // Create data folder in the directory. - dirData := log2.DirCreator(dir, "vod") + config.DirData = log2.DirCreator(dir, "vod") // Create cam logger. cutURI := LastPartURI(link) - cam := log2.CamLogging(fmt.Sprintf("%s/%s/log/writer-cam_%s.log", dirData, cutURI, strconv.FormatInt(time.Now().Unix(), 10))) + cam := log2.CamLogging(fmt.Sprintf("%s/%s/log/writer-cam_%s.log", config.DirData, cutURI, strconv.FormatInt(time.Now().Unix(), 10))) // Connect to the server. c := gortsplib.Client{ @@ -99,7 +99,7 @@ func rtsp(dir string, period int, link string, number int) error { } } - fn := storage.CreateFileName(dirData, resolutions, cutURI, period, number) + fn := storage.CreateFileName(config.DirData, resolutions, cutURI, period, number) err = os.MkdirAll(fmt.Sprintf("%s", fn.Path), 0755) if err != nil {