Merge pull request #42 from 30x/XAPID-862
XAPID-862: make sure we log things properly
diff --git a/changes.go b/changes.go
index 11fdc3a..69e26db 100644
--- a/changes.go
+++ b/changes.go
@@ -51,8 +51,7 @@
}
// not launched
if atomic.LoadInt32(c.isLaunched) == int32(0) {
- log.Debug("pollChangeManager: close() called when pollChangeWithBackoff unlaunched! Will wait until pollChangeWithBackoff is launched and then kill it and tokenManager!")
- log.Warn("Attempt to close unstarted change manager")
+ log.Warn("pollChangeManager: close() called when pollChangeWithBackoff unlaunched! Will wait until pollChangeWithBackoff is launched and then kill it and tokenManager!")
go func() {
c.quitChan <- true
tokenManager.close()
diff --git a/listener.go b/listener.go
index 6c4b1ef..49e3d6b 100644
--- a/listener.go
+++ b/listener.go
@@ -24,7 +24,7 @@
} else if snapShot, ok := e.(*common.Snapshot); ok {
processSnapshot(snapShot)
} else {
- log.Errorf("Received invalid event. Ignoring. %v", e)
+ log.Debugf("Received invalid event. Ignoring. %v", e)
}
}
diff --git a/snapshot.go b/snapshot.go
index 7a3c102..3287c4c 100644
--- a/snapshot.go
+++ b/snapshot.go
@@ -252,7 +252,7 @@
req.Header.Set("Authorization", "Bearer "+tokenManager.getBearerToken())
return nil
},
- Timeout: httpTimeout,
+ Timeout: httpTimeout,
}
//pollWithBackoff only accepts function that accept a single quit channel
@@ -300,7 +300,7 @@
// Decode the Snapshot server response
err = processSnapshotResponse(r, snapshot)
if err != nil {
- log.Errorf("Response Data not parsable: %v", err)
+ log.Errorf("Snapshot server response Data not parsable: %v", err)
return err
}