From f17a5b13d15c1204b19eac70b8cac6b65a67a8f6 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Tue, 4 Sep 2012 18:33:33 +0300 Subject: [PATCH] finished local testing --- mediator/mediator.go | 4 ++-- timespans/calldesc.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/mediator/mediator.go b/mediator/mediator.go index 87304e8fe..a65f7bfcd 100644 --- a/mediator/mediator.go +++ b/mediator/mediator.go @@ -114,7 +114,7 @@ func (m *Mediator) TrackCDRFiles(cdrPath string) (err error) { for { select { case ev := <-watcher.Event: - if ev.Mask&inotify.IN_MOVE != 0 { + if ev.Mask&inotify.IN_MOVED_TO != 0 { timespans.Logger.Info(fmt.Sprintf("Started to parse %v", ev.Name)) err = m.parseCSV(cdrPath, ev.Name) if err != nil { @@ -139,7 +139,7 @@ func (m *Mediator) parseCSV(dir, cdrfn string) (err error) { csvReader := csv.NewReader(bufio.NewReader(file)) dir = path.Join(dir, OUTPUT_DIR) - os.Mkdir(dir, os.ModeDir) + os.Mkdir(dir, 0777) fout, err := os.Create(path.Join(dir, "test.out")) if err != nil { return err diff --git a/timespans/calldesc.go b/timespans/calldesc.go index 43f50bc82..ce2b22535 100644 --- a/timespans/calldesc.go +++ b/timespans/calldesc.go @@ -38,7 +38,7 @@ func init() { const ( RECURSION_MAX_DEPTH = 4 FALLBACK_SUBJECT = "*all" - VERSION = "1.0a4" + VERSION = "1.0a5" ) var (