fix package naming

2015-05-26 15:04:54 -06:00 · 2015-05-26 15:04:54 -06:00 · ee0a67ae36
parent 6346ab55e7
commit ee0a67ae36
1 changed files with 4 additions and 1 deletions
--- 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 {