From 8c3c8994b14864b662f6e082ff5f6497237a5641 Mon Sep 17 00:00:00 2001
From: Alfonso Acosta <fons@weave.works>
Date: Mon, 8 Feb 2016 12:00:10 +0000
Subject: [PATCH] Use levelled logging

---
 .../endpoint/procspy/background_reader_linux.go | 17 +++++++++--------
 prog/probe.go                                   |  1 +
 2 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/probe/endpoint/procspy/background_reader_linux.go b/probe/endpoint/procspy/background_reader_linux.go
index f565662dd..f21218551 100644
--- a/probe/endpoint/procspy/background_reader_linux.go
+++ b/probe/endpoint/procspy/background_reader_linux.go
@@ -3,11 +3,12 @@ package procspy
 import (
 	"bytes"
 	"fmt"
-	"log"
 	"math"
 	"sync"
 	"time"
 
+	log "github.com/Sirupsen/logrus"
+
 	"github.com/weaveworks/scope/probe/process"
 )
 
@@ -28,8 +29,6 @@ type backgroundReader struct {
 	readySockets map[uint64]*Proc
 }
 
-// starts a rate-limited background goroutine to read the expensive files from
-// proc.
 func newBackgroundReader(walker process.Walker) *backgroundReader {
 	br := &backgroundReader{
 		walker:     walker,
@@ -39,6 +38,8 @@ func newBackgroundReader(walker process.Walker) *backgroundReader {
 	return br
 }
 
+// starts a rate-limited background goroutine to read the expensive files from
+// proc.
 func (br *backgroundReader) start() error {
 	br.mtx.Lock()
 	defer br.mtx.Unlock()
@@ -72,7 +73,7 @@ func (br *backgroundReader) loop() {
 		start := time.Now()
 		sockets, err := walkProcPid(br.walkingBuf, br.walker, ticker.C, fdBlockSize)
 		if err != nil {
-			log.Printf("background reader: error walking /proc: %s\n", err)
+			log.Errorf("background /proc reader: error walking /proc: %s", err)
 			continue
 		}
 
@@ -96,10 +97,10 @@ func (br *backgroundReader) loop() {
 		walkTime := time.Now().Sub(start)
 		walkTimeF := float64(walkTime)
 
-		log.Printf("debug: background reader: full pass took %s\n", walkTime)
+		log.Debugf("background /proc reader: full pass took %s", walkTime)
 		if walkTimeF/targetWalkTimeF > 1.5 {
-			log.Printf(
-				"warn: background reader: full pass took %s: 50%% more than expected (%s)\n",
+			log.Warnf(
+				"background /proc reader: full pass took %s: 50%% more than expected (%s)",
 				walkTime,
 				targetWalkTime,
 			)
@@ -108,7 +109,7 @@ func (br *backgroundReader) loop() {
 		// Adjust rate limit to more-accurately meet the target walk time in next iteration
 		scaledRateLimit := targetWalkTimeF / walkTimeF * float64(rateLimit)
 		rateLimit = time.Duration(math.Min(scaledRateLimit, maxRateLimitF))
-		log.Printf("debug: background reader: new rate limit %s\n", rateLimit)
+		log.Debugf("background /proc reader: new rate limit %s", rateLimit)
 
 		ticker.Stop()
 		ticker = time.NewTicker(rateLimit)
diff --git a/prog/probe.go b/prog/probe.go
index a7a3d6866..8a2054d26 100644
--- a/prog/probe.go
+++ b/prog/probe.go
@@ -24,6 +24,7 @@ import (
 	"github.com/weaveworks/scope/probe/controls"
 	"github.com/weaveworks/scope/probe/docker"
 	"github.com/weaveworks/scope/probe/endpoint"
+	"github.com/weaveworks/scope/probe/endpoint/procspy"
 	"github.com/weaveworks/scope/probe/host"
 	"github.com/weaveworks/scope/probe/kubernetes"
 	"github.com/weaveworks/scope/probe/overlay"