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

more balanced node creation

Browse source
This commit is contained in:
Todd Gruben 2015-07-23 14:58:39 +00:00
parent 98f13fecd8
commit 3d87b3bfbe
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
core/etcd.go
View file

@ -114,6 +114,11 @@ func (self *TopologyMapper) GetProcessFragmentCounts() map[string]int {
m := make(map[string]int)
id_string := self.service.Id.String()
m[id_string] = 0 //at least have one process if none created
for k, _ := range self.service.ProcessMap.nodes {
p := k.String()
m[p] = 0 //at least have one process if none created
}
for _, dbs := range self.service.Cluster.GetDatabases() {
for _, fsi := range dbs.GetFrameSliceIntersects() {
for _, fragment := range fsi.GetFragments() {

1
core/http.go
View file

@ -228,6 +228,7 @@ func (self *WebService) HandleLoad(w http.ResponseWriter, r *http.Request) {
ns, _ := database.NumSlices()
if ns <= ms {
for i := ns; i <= ms; i++ {
log.Info("Load Create Slice ", i)
self.service.TopologyMapper.MakeFragments(db, i)
}
http.Error(w, "Needed Slices", http.StatusNotFound)