From 9cc003683e9619aba07d98c64e481964acfd1320 Mon Sep 17 00:00:00 2001
From: Todd Gruben <tgruben@umbel.com>
Date: Mon, 16 Mar 2015 20:39:38 +0000
Subject: [PATCH] added some more logging on fragment creation

---
 core/etcd.go | 22 +++++++++++++---------
 1 file changed, 13 insertions(+), 9 deletions(-)

diff --git a/core/etcd.go b/core/etcd.go
index 894edce71..71733be9c 100644
--- a/core/etcd.go
+++ b/core/etcd.go
@@ -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
 			}