don't close replies twice

This commit is contained in:
Jeremy Latt 2014-02-13 20:56:15 -08:00
parent be01a412d9
commit 7cef494d28
1 changed files with 7 additions and 2 deletions

View File

@ -128,11 +128,15 @@ func (client *Client) writeReplies() {
} }
if client.socket.Write(reply.Format(client)) != nil { if client.socket.Write(reply.Format(client)) != nil {
break
}
}
if client.replies != nil {
close(client.replies) close(client.replies)
}
}
client.replies = nil client.replies = nil
} }
}
func (client *Client) Destroy() { func (client *Client) Destroy() {
if client.destroyed { if client.destroyed {
@ -147,6 +151,7 @@ func (client *Client) Destroy() {
if client.replies != nil { if client.replies != nil {
close(client.replies) close(client.replies)
client.replies = nil
} }
client.socket.Close() client.socket.Close()