add: [filerwatcher] fix error messages

pull/19/head
Jean-Louis Huynen 2021-02-16 10:43:01 +01:00
parent afc9526219
commit 7fc1a1b0c0
No known key found for this signature in database
GPG Key ID: 64799157F4BD6B93
1 changed files with 3 additions and 3 deletions

View File

@ -10,7 +10,6 @@ import (
"encoding/json"
"flag"
"fmt"
"github.com/rjeczalik/notify"
"io"
"io/ioutil"
"log"
@ -513,10 +512,11 @@ func setReaderWriters(d4 *d4S, force bool) bool {
return false
}
case "folder":
var err error
// Create a notification channel to recursively watch file event on folder
(*d4).src, err = inputreader.NewRecursiveWatcherReader(&(*d4).folderfd)
(*d4).src, err = inputreader.NewFileWatcherReader(&(*d4).folderfd)
if err != nil {
log.Printf("Could not create d4 Redis Descriptor %q \n", err)
log.Printf("Could not create File Watcher %q \n", err)
return false
}
}