diff --git a/asink/client.go b/asink/client.go index be180ba..9854acc 100644 --- a/asink/client.go +++ b/asink/client.go @@ -141,6 +141,12 @@ func ProcessLocalEvent(globals AsinkGlobals, event *asink.Event) { defer UnlockPath(event) if latestLocal != nil { event.Predecessor = latestLocal.Hash + + if event.Timestamp < latestLocal.Timestamp { + fmt.Printf("trying to send event older than latestLocal:\n") + fmt.Printf("OLD %+v\n", latestLocal) + fmt.Printf("NEW %+v\n", event) + } } if event.IsUpdate() { diff --git a/asink/watcher.go b/asink/watcher.go index ab6cbdd..62641e7 100644 --- a/asink/watcher.go +++ b/asink/watcher.go @@ -29,7 +29,7 @@ func StartWatching(watchDir string, fileUpdates chan *asink.Event) { event := new(asink.Event) event.Path = path event.Type = asink.UPDATE - event.Timestamp = info.ModTime().UnixNano() + event.Timestamp = time.Now().UnixNano() fileUpdates <- event } return nil