From 129eca0d824f266fce4ec2dfe9b40cb56202831a Mon Sep 17 00:00:00 2001
From: Juan Batiz-Benet <juan@benet.ai>
Date: Sat, 13 Dec 2014 04:56:38 -0800
Subject: [PATCH] multiconn: close fanIn + error

---
 net/conn/multiconn.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/net/conn/multiconn.go b/net/conn/multiconn.go
index f8b291546..3ef89c920 100644
--- a/net/conn/multiconn.go
+++ b/net/conn/multiconn.go
@@ -2,6 +2,7 @@ package conn
 
 import (
 	"errors"
+	"fmt"
 	"sync"
 
 	context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context"
@@ -179,6 +180,7 @@ func (c *MultiConn) close() error {
 
 	// close underlying connections
 	CloseConns(conns...)
+	close(c.fanIn)
 	return nil
 }
 
@@ -266,7 +268,10 @@ func (c *MultiConn) Write(buf []byte) (int, error) {
 
 // ReadMsg reads data, net.Conn style
 func (c *MultiConn) ReadMsg() ([]byte, error) {
-	next := <-c.fanIn
+	next, ok := <-c.fanIn
+	if !ok {
+		return nil, fmt.Errorf("multiconn closed")
+	}
 	return next, nil
 }
 
@@ -281,6 +286,7 @@ func (c *MultiConn) WriteMsg(buf []byte) error {
 
 // ReleaseMsg releases a buffer
 func (c *MultiConn) ReleaseMsg(m []byte) {
+	// here, we dont know where it came from. hm.
 	for _, c := range c.getConns() {
 		c.ReleaseMsg(m)
 	}