rpc: reset write deadline

This commit is contained in:
Gísli Kristjánsson 2018-08-29 22:35:37 +00:00
parent 62e94895da
commit 34f0d6ae06

View file

@ -487,6 +487,7 @@ func (c *Client) write(ctx context.Context, msg interface{}) error {
} }
c.writeConn.SetWriteDeadline(deadline) c.writeConn.SetWriteDeadline(deadline)
err := json.NewEncoder(c.writeConn).Encode(msg) err := json.NewEncoder(c.writeConn).Encode(msg)
c.writeConn.SetWriteDeadline(time.Time{})
if err != nil { if err != nil {
c.writeConn = nil c.writeConn = nil
} }