diff --git a/core/etcd.go b/core/etcd.go index 78f01e1aa..66f14ae1a 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -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() { diff --git a/core/http.go b/core/http.go index 2ddba6b35..e9e740684 100644 --- a/core/http.go +++ b/core/http.go @@ -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)