From 7bcc4de76f835071363f17e3a0cb8746b4146566 Mon Sep 17 00:00:00 2001 From: Graham Barr Date: Wed, 20 Aug 2014 11:27:32 -0500 Subject: [PATCH] Do not ignore write errors --- client/client.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/client/client.go b/client/client.go index 55ca858..a99d730 100644 --- 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 }