From 26b64288fc2f092e9100a396ad9910b2336be8ca Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Mon, 23 Jun 2014 15:46:21 -0500 Subject: [PATCH] turned autocreate back on --- core/etcd.go | 14 ++++++-------- index/fragment_container.go | 2 +- 2 files changed, 7 insertions(+), 9 deletions(-) diff --git a/core/etcd.go b/core/etcd.go index 903862375..eb808580f 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -105,15 +105,13 @@ func getLightestProcess(m map[string]int) (Pair, error) { } func (self *TopologyMapper) MakeFragments(db string, slice_int int) error { - /* - frames_to_create := config.GetStringArrayDefault("supported_frames", []string{"b.n", "l.n", "t.t", "d"}) - for _, frame := range frames_to_create { - err := self.AllocateFragment(db, frame, slice_int) - if err != nil { - log.Println(err) - } + frames_to_create := config.GetStringArrayDefault("supported_frames", []string{"b.n", "l.n", "t.t", "d"}) + for _, frame := range frames_to_create { + err := self.AllocateFragment(db, frame, slice_int) + if err != nil { + log.Println(err) } - */ + } return nil } diff --git a/index/fragment_container.go b/index/fragment_container.go index 1d8974f54..771ef0546 100644 --- a/index/fragment_container.go +++ b/index/fragment_container.go @@ -202,9 +202,9 @@ func (self *FragmentContainer) Clear(frag_id util.SUUID) (bool, error) { } func (self *FragmentContainer) AddFragment(db string, frame string, slice int, id util.SUUID) { - log.Println("ADD FRAGMENT", frame, db, slice, util.SUUID_to_Hex(id)) _, ok := self.fragments[id] if !ok { + log.Println("ADD FRAGMENT", frame, db, slice, util.SUUID_to_Hex(id)) f := NewFragment(id, db, slice, frame) self.fragments[id] = f go f.ServeFragment()