Merge pull request #49 from gbarr/write-errors

Do not ignore write errors
2014-08-21 09:24:18 +08:00 · 2014-08-21 09:24:18 +08:00 · 9387a36a0b
commit 9387a36a0b
parent ccb6f4a24f 7bcc4de76f
1 changed files with 5 additions and 1 deletions
--- a/client/client.go
+++ b/client/client.go
@ -194,7 +194,11 @@ func (client *Client) do(funcname string, data []byte,
 	id := IdGen.Id()
 	req := getJob(id, []byte(funcname), data)
 	req.DataType = flag
-	client.write(req)
+	if err = client.write(req); err != nil {
+		delete(client.innerHandler, "c")
+		client.lastcall = ""
+		return
+	}
 	mutex.Lock()
 	return
 }