close connection after disconnect

rpc-pool.go

@@ -3,7 +3,6 @@ package main
 import (
 	"fmt"
 	"io"
-	"log"
 	"net"
 	"strings"
 	"sync"
@@ -46,7 +45,6 @@ func (g *RemoteGrain) Connect() error {
 		if !strings.Contains(addr, ":") {
 			addr = fmt.Sprintf("%s:1337", addr)
 		}
-		log.Printf("Connecting to %s %s", addr, g.Address)
 		client, err := net.Dial("tcp", addr)
 		if err != nil {
 			return err

synced-pool.go

@@ -198,11 +198,13 @@ type PacketQueue struct {
 }
 
 func NewPacketQueue(connection net.Conn) *PacketQueue {
+
 	queue := &PacketQueue{
 		Packets:    make([]PacketWithData, 0),
 		connection: connection,
 	}
 	go func() {
+		defer connection.Close()
 		for {
 			messageType, data, err := ReceivePacket(queue.connection)
 			ts := time.Now()