scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 00:55:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

turned autocreate back on

Browse source
This commit is contained in:
Todd Gruben 2014-06-23 15:46:21 -05:00
parent 21596dfa1d
commit 26b64288fc
2 changed files with 7 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
core/etcd.go
View file

@ -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
}

2
index/fragment_container.go
View file

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