Make nameserver logging more consistent.
This commit is contained in:
1 parent
7fa568872c
commit
6a5044fc70
2 files changed
+11
-10
No files matched your search
+9
-10
@@ -8,13 +8,12 @@ import (
|
||||
"github.com/gorilla/mux"
|
||||
"github.com/miekg/dns"
|
||||
|
||||
"github.com/weaveworks/weave/common"
|
||||
"github.com/weaveworks/weave/net/address"
|
||||
)
|
||||
|
||||
func badRequest(w http.ResponseWriter, err error) {
|
||||
func (n *Nameserver) badRequest(w http.ResponseWriter, err error) {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
common.Log.Warningf("[gossipdns]: %v", err)
|
||||
n.infof("%v", err)
|
||||
}
|
||||
|
||||
func (n *Nameserver) HandleHTTP(router *mux.Router) {
|
||||
@@ -31,19 +30,19 @@ func (n *Nameserver) HandleHTTP(router *mux.Router) {
|
||||
ip, err = address.ParseIP(ipStr)
|
||||
)
|
||||
if err != nil {
|
||||
badRequest(w, err)
|
||||
n.badRequest(w, err)
|
||||
return
|
||||
}
|
||||
|
||||
if err := n.AddEntry(hostname, container, n.ourName, ip); err != nil {
|
||||
badRequest(w, fmt.Errorf("Unable to add entry: %v", err))
|
||||
n.badRequest(w, fmt.Errorf("Unable to add entry: %v", err))
|
||||
return
|
||||
}
|
||||
|
||||
if r.FormValue("check-alive") == "true" && n.docker.IsContainerNotRunning(container) {
|
||||
common.Log.Infof("[gossipdns] '%s' is not running: removing", container)
|
||||
n.infof("container '%s' is not running: removing", container)
|
||||
if err := n.Delete(hostname, container, ipStr, ip); err != nil {
|
||||
common.Log.Infof("[gossipdns] failed to remove: %v", err)
|
||||
n.infof("failed to remove: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -68,14 +67,14 @@ func (n *Nameserver) HandleHTTP(router *mux.Router) {
|
||||
ipStr, ok := vars["ip"]
|
||||
ip, err := address.ParseIP(ipStr)
|
||||
if ok && err != nil {
|
||||
badRequest(w, err)
|
||||
n.badRequest(w, err)
|
||||
return
|
||||
} else if !ok {
|
||||
ipStr = "*"
|
||||
}
|
||||
|
||||
if err := n.Delete(hostname, container, ipStr, ip); err != nil {
|
||||
badRequest(w, fmt.Errorf("Unable to delete entries: %v", err))
|
||||
n.badRequest(w, fmt.Errorf("Unable to delete entries: %v", err))
|
||||
return
|
||||
}
|
||||
w.WriteHeader(204)
|
||||
@@ -88,7 +87,7 @@ func (n *Nameserver) HandleHTTP(router *mux.Router) {
|
||||
n.RLock()
|
||||
defer n.RUnlock()
|
||||
if err := json.NewEncoder(w).Encode(n.entries); err != nil {
|
||||
badRequest(w, fmt.Errorf("Error marshalling response: %v", err))
|
||||
n.badRequest(w, fmt.Errorf("Error marshalling response: %v", err))
|
||||
}
|
||||
})
|
||||
}
|
||||
@@ -170,6 +170,8 @@ func (n *Nameserver) Delete(hostname, containerid, ipStr string, ip address.Addr
|
||||
if ipStr != "*" && e.Addr != ip {
|
||||
return false
|
||||
}
|
||||
|
||||
n.infof("tombstoning entry %v", e)
|
||||
return true
|
||||
})
|
||||
n.Unlock()
|
||||
|
||||
Reference in new issue
Block a user