Rooba
/
perkeep
mirror of https://github.com/perkeep/perkeep.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

httputil: more Transport timing stats 

Change-Id: I536d8f549e6cdbc0778c44943e770e4f0665c868
This commit is contained in:
Brad Fitzpatrick 2013-01-06 09:03:47 -08:00
parent e95e6db11d
commit c408e19ec4
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/httputil/transport.go
View File

@ -61,10 +61,11 @@ func (t *StatsTransport) RoundTrip(req *http.Request) (resp *http.Response, err
}
resp, err = rt.RoundTrip(req)
if t.VerboseLog {
td := time.Since(t0)
t1 := time.Now()
td := t1.Sub(t1)
if err == nil {
log.Printf("(%d) %s %s = status %d (in %v)", n, req.Method, req.URL, resp.StatusCode, td)
resp.Body = &logBody{body: resp.Body, n: n}
resp.Body = &logBody{body: resp.Body, n: n, t0: t0, t1: t1}
} else {
log.Printf("(%d) %s %s = error: %v (in %v)", n, req.Method, req.URL, err, td)
}
@ -75,6 +76,7 @@ func (t *StatsTransport) RoundTrip(req *http.Request) (resp *http.Response, err
type logBody struct {
body io.ReadCloser
n int
t0, t1 time.Time
readOnce sync.Once
closeOnce sync.Once
}
@ -88,7 +90,8 @@ func (b *logBody) Read(p []byte) (n int, err error) {
func (b *logBody) Close() error {
b.closeOnce.Do(func() {
log.Printf("(%d) Close body", b.n)
t := time.Now()
log.Printf("(%d) Close body (%v tot, %v post-header)", b.n, t.Sub(b.t0), t.Sub(b.t1))
})
return b.body.Close()
}