vbatts/registry
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Address possible goroutine leak in notification library

Browse source 
Signed-off-by: Stephen J Day <stephen.day@docker.com>
This commit is contained in:
Stephen J Day 2015-04-29 18:31:01 -07:00 committed by Richard
parent f132ff7702
commit 269286192d
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
notifications/http.go
View file

@ -53,6 +53,7 @@ type httpStatusListener interface {
func (hs *httpSink) Write(events ...Event) error { func (hs *httpSink) Write(events ...Event) error {
hs.mu.Lock() hs.mu.Lock()
defer hs.mu.Unlock() defer hs.mu.Unlock()
defer hs.client.Transport.(*headerRoundTripper).CloseIdleConnections()
if hs.closed { if hs.closed {
return ErrSinkClosed return ErrSinkClosed
@ -83,6 +84,7 @@ func (hs *httpSink) Write(events ...Event) error {
return fmt.Errorf("%v: error posting: %v", hs, err) return fmt.Errorf("%v: error posting: %v", hs, err)
} }
defer resp.Body.Close()
// The notifier will treat any 2xx or 3xx response as accepted by the // The notifier will treat any 2xx or 3xx response as accepted by the
// endpoint. // endpoint.