From ee0a67ae368daea6c1669895d735a7fd9234b369 Mon Sep 17 00:00:00 2001 From: Cory LaNou Date: Tue, 26 May 2015 15:04:54 -0600 Subject: [PATCH] fix package naming --- tcp/client.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/tcp/client.go b/tcp/client.go index e58fecac9a..dfa0bc3771 100644 --- a/tcp/client.go +++ b/tcp/client.go @@ -80,7 +80,10 @@ func (c *Client) dial(addr string) (net.Conn, error) { c.pool[addr] = p c.mu.Unlock() } - return c.pool[addr].Get() + c.mu.Lock() + conn, err := c.pool[addr].Get() + c.mu.Unlock() + return conn, err } func (c *Client) WriteShard(addr string, shardID uint64, points []tsdb.Point) error {