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()