Browse Source

Do not ignore write errors

tags/0.2
Graham Barr 9 years ago
parent
commit
7bcc4de76f
1 changed files with 5 additions and 1 deletions
  1. +5
    -1
      client/client.go

+ 5
- 1
client/client.go View File

@@ -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
}


Loading…
Cancel
Save