mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-04-04 21:17:37 +03:00
Code Issues Projects Releases Packages Wiki Activity

Process changed folders as they are discovered

Browse source
This commit is contained in:
Deluan 2020-10-29 23:47:43 -04:00
parent 2f394623c8
commit 00ec6cf042
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
scanner/tag_scanner.go
View file

@ -90,9 +90,10 @@ func (s *TagScanner) Scan(ctx context.Context, lastModifiedSince time.Time) erro
if s.isChangedDirs(ctx, folderStats, allDBDirs, lastModifiedSince) { if s.isChangedDirs(ctx, folderStats, allDBDirs, lastModifiedSince) {
changedDirs = append(changedDirs, folderStats.Path) changedDirs = append(changedDirs, folderStats.Path)
log.Debug("Processing changed folder", "dir", folderStats.Path)
err := s.processChangedDir(ctx, folderStats.Path) err := s.processChangedDir(ctx, folderStats.Path)
if err != nil { if err != nil {
log.Error("Error updating folder in the DB", "path", folderStats.Path, err) log.Error("Error updating folder in the DB", "dir", folderStats.Path, err)
} }
} }
} }
@ -106,7 +107,7 @@ func (s *TagScanner) Scan(ctx context.Context, lastModifiedSince time.Time) erro
for _, dir := range deletedDirs { for _, dir := range deletedDirs {
err := s.processDeletedDir(ctx, dir) err := s.processDeletedDir(ctx, dir)
if err != nil { if err != nil {
log.Error("Error removing deleted folder from DB", "path", dir, err) log.Error("Error removing deleted folder from DB", "dir", dir, err)
} }
} }
@ -144,7 +145,7 @@ func (s *TagScanner) getRootFolderWalker(ctx context.Context) walkResults {
if err := walkDirTree(ctx, s.rootFolder, results); err != nil { if err := walkDirTree(ctx, s.rootFolder, results); err != nil {
log.Error("Scan was interrupted by error", err) log.Error("Scan was interrupted by error", err)
} }
log.Debug("Finished reading directories from filesystem", "total", "elapsed", time.Since(start)) log.Debug("Finished reading directories from filesystem", "elapsed", time.Since(start))
}() }()
return results return results
} }
@ -210,7 +211,7 @@ func (s *TagScanner) processDeletedDir(ctx context.Context, dir string) error {
} }
err = buffer.flush() err = buffer.flush()
log.Info(ctx, "Finished processing deleted folder", "path", dir, "purged", len(mfs), "elapsed", time.Since(start)) log.Info(ctx, "Finished processing deleted folder", "dir", dir, "purged", len(mfs), "elapsed", time.Since(start))
return err return err
} }