diff --git a/src/recipient/recipient.go b/src/recipient/recipient.go index 42b5833..1b2124c 100644 --- a/src/recipient/recipient.go +++ b/src/recipient/recipient.go @@ -329,6 +329,7 @@ func connectToTCPServer(room string, address string) (com comm.Comm, err error) if err != nil { return } + defer connection.Close() connection.SetReadDeadline(time.Now().Add(3 * time.Hour)) connection.SetDeadline(time.Now().Add(3 * time.Hour)) connection.SetWriteDeadline(time.Now().Add(3 * time.Hour)) diff --git a/src/sender/sender.go b/src/sender/sender.go index 6977e71..d8960da 100644 --- a/src/sender/sender.go +++ b/src/sender/sender.go @@ -306,10 +306,11 @@ func connectToTCPServer(room string, address string) (com comm.Comm, err error) if err != nil { return } + defer connection.Close() connection.SetReadDeadline(time.Now().Add(3 * time.Hour)) connection.SetDeadline(time.Now().Add(3 * time.Hour)) connection.SetWriteDeadline(time.Now().Add(3 * time.Hour)) - + com = comm.New(connection) ok, err := com.Receive() if err != nil {