syncthing debug
This commit is contained in:
parent
715433d748
commit
de9c92d6be
2
main.go
2
main.go
@ -69,7 +69,7 @@ func main() {
|
|||||||
filteredFiles := channel.Filter(filesByGroup, Or(Not(Exists), And(SymlinkFilesOnly, VideosOnly)))
|
filteredFiles := channel.Filter(filesByGroup, Or(Not(Exists), And(SymlinkFilesOnly, VideosOnly)))
|
||||||
|
|
||||||
filteredFiles = channel.MapSuccessive(filteredFiles, func(s string) string {
|
filteredFiles = channel.MapSuccessive(filteredFiles, func(s string) string {
|
||||||
fmt.Println("DEBUG", s)
|
fmt.Println("FILTERED", s)
|
||||||
return s
|
return s
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@ -63,8 +63,6 @@ func WatchDirectory(ctx context.Context, path string, op ...fsnotify.Op) (<-chan
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println("DEBUG", "done providing existing files")
|
|
||||||
|
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case event, ok := <-watcher.Events:
|
case event, ok := <-watcher.Events:
|
||||||
|
Loading…
Reference in New Issue
Block a user