fix #1.

conn.go

@@ -52,6 +52,15 @@ func (self *pooledConn) Write(b []byte) (n int, err error) {
 }
 
 func (self *pooledConn) Close() error {
+	defer func() {
+		if r := recover(); r != nil {
+			// this will be true if
+			// self.pool.freeChan
+			// is closed.
+			// i.e. the pool is closed
+			self.conn.Close()
+		}
+	}()
 	req := &freeRequest{self}
 	self.n++
 	self.pool.freeChan <- req

pool.go

@@ -257,6 +257,7 @@ func (self *Pool) Close() {
 
 // Get a connection. The function will block the goroutine until there is
 // a connection available or an error occured.
+// Calling Get() on a closed pool will lead to panic.
 func (self *Pool) Get() (conn net.Conn, err error) {
 	connCh := make(chan *pooledConn)
 	errCh := make(chan error)

pool_test.go

@@ -365,3 +365,22 @@ func TestConcurrentAccess(t *testing.T) {
 	}
 	wg.Wait()
 }
+
+func TestCloseConnAfterClosingPool(t *testing.T) {
+	max := 10
+	manager := &fakeConnManager{nil, nil}
+	pool := NewPool(max, max, manager)
+	c, err := pool.Get()
+	if err != nil {
+		t.Errorf("Error: %v", err)
+	}
+
+	if c == nil {
+		t.Errorf("nil conn")
+	}
+	// Close the pool first.
+	pool.Close()
+
+	// Then close the connection
+	c.Close()
+}