compiles and lists hypervisors

Signed-off-by: Jeff Carr <[email protected]>

1 files changed, 23 insertions, 5 deletions

diff --git a/main.go b/main.go
index 7fd9f38..e09de05 100644
--- a/main.go
+++ b/main.go
@@ -41,7 +41,8 @@ func main() {
 	me.unstable = time.Now()   // initialize the grid as unstable
 	me.delay = 5 * time.Second // how often to poll the hypervisors
 	me.changed = false
-	me.dmap = make(map[*pb.Droplet]*DropletT)
+	// me.dmap = make(map[*pb.Droplet]*DropletT)
+	me.hmap = make(map[*pb.Hypervisor]*HyperT)
 
 	// read in the config file
 	me.cluster = new(pb.Cluster)
@@ -100,11 +101,10 @@ func main() {
 		log.Info(i, "Event:", e.Droplet, e.FieldName, "orig:", e.OrigVal, "new:", e.NewVal)
 		me.changed = true
 	}
-	if err := me.cluster.ConfigSave(); err != nil {
-		log.Info("configsave error", err)
-	}
+	//	if err := me.cluster.ConfigSave(); err != nil {
+	//		log.Info("configsave error", err)
+	//	}
 
-	os.Exit(0)
 	if me.changed {
 		if argv.Save {
 			if err := me.cluster.ConfigSave(); err != nil {
@@ -129,6 +129,24 @@ func main() {
 		newStart(argv.Start)
 		os.Exit(0)
 	}
+	// initialize each hypervisor
+	for _, pbh := range me.cluster.Hypervisors {
+		/*
+			h := findHypervisor(pbh.Hostname)
+			if h != nil {
+				continue
+			}
+		*/
+		// this is a new unknown droplet (not in the config file)
+		h := new(HyperT)
+		h.pb = pbh
+
+		h.lastpoll = time.Now()
+
+		me.hmap[pbh] = h
+		// me.hypers = append(me.hypers, h)
+		log.Log(EVENT, "config new hypervisors", h.pb.Hostname)
+	}
 
 	// start the watchdog polling for each hypervisor
 	for _, h := range me.hypers {