Merge pull request #2856 from ipfs/fix/send-msg-race

pass reference to reader instead of using the one on the object
ipfs · Jun 15, 2016 · 87d0526 · 87d0526
2 parents e5e2f2c + 63c8a9e
commit 87d0526
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/routing/dht/dht_net.go b/routing/dht/dht_net.go
@@ -228,9 +228,9 @@ func (ms *messageSender) SendRequest(ctx context.Context, pmes *pb.Message) (*pb
 
 func (ms *messageSender) ctxReadMsg(ctx context.Context, mes *pb.Message) error {
 	errc := make(chan error, 1)
-	go func() {
-		errc <- ms.r.ReadMsg(mes)
-	}()
+	go func(r ggio.ReadCloser) {
+		errc <- r.ReadMsg(mes)
+	}(ms.r)
 
 	select {
 	case err := <-errc: