From e3bf42d5beb946b5701a6b0597b52fe98a1c0883 Mon Sep 17 00:00:00 2001 From: Pierre Wacrenier Date: Sun, 1 Feb 2015 05:48:30 +0100 Subject: [PATCH] Force connection close with token discovery Signed-off-by: Pierre Wacrenier --- discovery/token/token.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/discovery/token/token.go b/discovery/token/token.go index 4fc7c0ee5b..efd515bd3a 100644 --- a/discovery/token/token.go +++ b/discovery/token/token.go @@ -87,8 +87,11 @@ func (s *TokenDiscoveryService) Watch(callback discovery.WatchCallback) { func (s *TokenDiscoveryService) Register(addr string) error { buf := strings.NewReader(addr) - _, err := http.Post(fmt.Sprintf("%s/%s/%s", s.url, + resp, err := http.Post(fmt.Sprintf("%s/%s/%s", s.url, "clusters", s.token), "application/json", buf) + + // Force connection close + resp.Body.Close() return err } @@ -98,6 +101,8 @@ func (s *TokenDiscoveryService) CreateCluster() (string, error) { if err != nil { return "", err } + + defer resp.Body.Close() token, err := ioutil.ReadAll(resp.Body) return string(token), err }