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

more trying

Browse source
This commit is contained in:
Todd Gruben 2014-06-23 18:58:46 -05:00
parent 039687bfa0
commit 515f6ce181
3 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
commands/pilosa-cruncher/cruncher.go
View file

@ -28,4 +28,5 @@ func main() {
}
cruncher := cruncher.NewCruncher()
cruncher.Run()
log.Println("STOP")
}

14
core/etcd.go
View file

@ -105,13 +105,15 @@ 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
}

1
core/service.go
View file

@ -127,6 +127,7 @@ func (service *Service) Run() {
return
}
}
log.Println("Service stopping")
}
type Message interface {