From 4da0e9a93cfd262f9041cfc481db3ba4961f49e1 Mon Sep 17 00:00:00 2001
From: Cory LaNou <cory@lanou.com>
Date: Wed, 27 May 2015 10:06:04 -0600
Subject: [PATCH] close client pool

---
 cluster/client_pool.go | 3 +--
 cluster/writer.go      | 1 +
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/cluster/client_pool.go b/cluster/client_pool.go
index 659d171762..a4b5fc895f 100644
--- a/cluster/client_pool.go
+++ b/cluster/client_pool.go
@@ -49,11 +49,10 @@ func (c *clientPool) conn(n *meta.NodeInfo) (net.Conn, error) {
 	return conn, err
 }
 
-func (c *clientPool) close() error {
+func (c *clientPool) close() {
 	c.mu.Lock()
 	for _, p := range c.pool {
 		p.Close()
 	}
 	c.mu.Unlock()
-	return nil
 }
diff --git a/cluster/writer.go b/cluster/writer.go
index 24b02ec9ff..db87481ff0 100644
--- a/cluster/writer.go
+++ b/cluster/writer.go
@@ -139,6 +139,7 @@ func (w *Writer) Close() error {
 	if w.pool == nil {
 		return fmt.Errorf("client already closed")
 	}
+	w.pool.close()
 	w.pool = nil
 	return nil
 }