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

added some more logging on fragment creation

Browse source
This commit is contained in:
Todd Gruben 2015-03-16 20:39:38 +00:00
parent 42381892cb
commit 9cc003683e
1 changed files with 13 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
core/etcd.go
View file

@ -116,15 +116,17 @@ func (self *TopologyMapper) GetProcessFragmentCounts() map[string]int {
m[id_string] = 0 //at least have one process if none created
for _, dbs := range self.service.Cluster.GetDatabases() {
for _, fsi := range dbs.GetFrameSliceIntersects() {
fragment := fsi.GetFragment()
if fragment != nil {
p := fragment.GetProcess()
if p != nil {
process := p.Id().String()
if len(process) > 1 {
i := m[process]
i++
m[process] = i
if fsi != nil {
fragment := fsi.GetFragment()
if fragment != nil {
p := fragment.GetProcess()
if p != nil {
process := p.Id().String()
if len(process) > 1 {
i := m[process]
i++
m[process] = i
}
}
}
}
@ -141,9 +143,11 @@ func (self *TopologyMapper) MakeFragments(db string, slice_int int) error {
if err == nil {
if response.StatusCode == 201 { //key created
log.Warn("MakeFragments:", db, slice_int)
m := self.GetProcessFragmentCounts()
p, err := getLightestProcess(m)
if err != nil {
log.Warn("MakeFragments: error finding process", db, slice_int, err)
return err
}