summaryrefslogtreecommitdiff
path: root/poll.go
diff options
context:
space:
mode:
Diffstat (limited to 'poll.go')
-rw-r--r--poll.go14
1 files changed, 8 insertions, 6 deletions
diff --git a/poll.go b/poll.go
index b7daeb9..5e9fdb0 100644
--- a/poll.go
+++ b/poll.go
@@ -10,7 +10,7 @@ import (
func (h HyperT) pollHypervisor() {
url := "http://" + h.Hostname + ":2520/vms"
- log.Info("wget url =", url)
+ log.Log(INFO, "wget url =", url)
s := shell.Wget(url)
if s == nil {
return
@@ -29,15 +29,16 @@ func (h HyperT) pollHypervisor() {
state := fields[0]
name := fields[1]
if state == "ON" {
- log.Info("POLL", h.Hostname, "STATE:", state, "HOST:", name, "rest:", fields[2:])
+ log.Log(POLL, h.Hostname, "STATE:", state, "HOST:", name, "rest:", fields[2:])
var found = false
for _, d := range me.droplets {
if d.Hostname == name {
- log.Info("ALREADY RECORDED", d.Hostname)
+ log.Log(INFO, "ALREADY RECORDED", d.Hostname)
found = true
d.lastpoll = time.Now()
+ // log.Info("ALREADY RECORDED", d.Hostname, d.lastpoll)
if d.hname != h.Hostname {
- log.Info("DROPLET", d.Hostname, "MOVED FROM", d.hname, "TO", d.Hostname)
+ log.Log(EVENT, "DROPLET", d.Hostname, "MOVED FROM", d.hname, "TO", d.Hostname)
}
d.hname = h.Hostname
@@ -46,11 +47,12 @@ func (h HyperT) pollHypervisor() {
if found {
continue
}
- var d DropletT
+ var d = new(DropletT)
d.Hostname = name
d.hname = h.Hostname
+ d.lastpoll = time.Now()
me.droplets = append(me.droplets, d)
- log.Info(name, "IS NEW. ADDED ON", h.Hostname)
+ log.Log(EVENT, name, "IS NEW. ADDED ON", h.Hostname)
}
}
// log.Info("i, s =", hostname, i, s)