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 {