Skip to content

Commit bd3a44c

Browse files
committed
Merge pull request #1652 from bas-vk/autoreconnect
rpc/comms: reconnect ipc client after write error
2 parents 61a6911 + 9bf17eb commit bd3a44c

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

rpc/comms/ipc.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,14 @@ func (self *ipcClient) Close() {
4444

4545
func (self *ipcClient) Send(req interface{}) error {
4646
var err error
47-
if err = self.coder.WriteResponse(req); err != nil {
48-
if _, ok := err.(*net.OpError); ok { // connection lost, retry once
47+
if r, ok := req.(*shared.Request); ok {
48+
if err = self.coder.WriteResponse(r); err != nil {
4949
if err = self.reconnect(); err == nil {
50-
err = self.coder.WriteResponse(req)
50+
err = self.coder.WriteResponse(r)
5151
}
5252
}
53+
54+
return err
5355
}
5456
return err
5557
}

0 commit comments

Comments
 (0)