aclindsa/go-asink
1
0
Fork 0
Code Releases Activity

Add states to Event to handle incoming events

Browse Source
This commit is contained in:
Aaron Lindsay 2013-08-07 23:43:38 -04:00
parent 49b0f75714
commit e5fabc27e3
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
client/asink.go
View File

@ -164,6 +164,7 @@ func ProcessLocalEvent(globals AsinkGlobals, event *asink.Event) {
} }
func ProcessRemoteEvent(globals AsinkGlobals, event *asink.Event) { func ProcessRemoteEvent(globals AsinkGlobals, event *asink.Event) {
//TODO check to see if event originated locally. If it did, stop processing it.
//Download event //Download event
if event.IsUpdate() { if event.IsUpdate() {
outfile, err := ioutil.TempFile(globals.tmpDir, "asink") outfile, err := ioutil.TempFile(globals.tmpDir, "asink")

5
events.go
View File

@ -12,12 +12,17 @@ const (
type EventStatus uint32 type EventStatus uint32
const ( const (
//the state of the event on the local asink instance on which it originated:
NOTICED = 1 << iota //watcher.go has been notified that a file changed NOTICED = 1 << iota //watcher.go has been notified that a file changed
COPIED_TO_TMP //temporary version saved off COPIED_TO_TMP //temporary version saved off
HASHED //hash taken of tmp file HASHED //hash taken of tmp file
CACHED //tmp file renamed to its hash CACHED //tmp file renamed to its hash
UPLOADED //tmp file has been successfully uploaded to storage UPLOADED //tmp file has been successfully uploaded to storage
ON_SERVER //server has been successfully notified of event ON_SERVER //server has been successfully notified of event
//the state of the event on the asink instance notified that it occurred elsewhere
NOTIFIED //we've been told a file has been changed remotely
DOWNLOADED //event has been downloaded and stored in the local file cache
SYNCED //everything has been done to ensure the affected file is up-to-date
) )
type Event struct { type Event struct {