diff options
| author | Bas van Kervel <bas@ethdev.com> | 2015-08-13 21:30:17 +0800 |
|---|---|---|
| committer | Bas van Kervel <bas@ethdev.com> | 2015-08-20 03:48:56 +0800 |
| commit | 9bf17eb05a4591d8dec9779a9efddc5c2276699a (patch) | |
| tree | ed786ecc2ac635a24aea21f5f43e4bf5ccaa7b93 /rpc/comms | |
| parent | 382d35bf403ab5dd9b0d2fe3a87c3960902d6e57 (diff) | |
| download | dexon-9bf17eb05a4591d8dec9779a9efddc5c2276699a.tar.gz dexon-9bf17eb05a4591d8dec9779a9efddc5c2276699a.tar.zst dexon-9bf17eb05a4591d8dec9779a9efddc5c2276699a.zip | |
rpc/comms reconnect ipc client after write error
Diffstat (limited to 'rpc/comms')
| -rw-r--r-- | rpc/comms/ipc.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/rpc/comms/ipc.go b/rpc/comms/ipc.go index e982ada13..d897bf313 100644 --- a/rpc/comms/ipc.go +++ b/rpc/comms/ipc.go @@ -44,12 +44,14 @@ func (self *ipcClient) Close() { func (self *ipcClient) Send(req interface{}) error { var err error - if err = self.coder.WriteResponse(req); err != nil { - if _, ok := err.(*net.OpError); ok { // connection lost, retry once + if r, ok := req.(*shared.Request); ok { + if err = self.coder.WriteResponse(r); err != nil { if err = self.reconnect(); err == nil { - err = self.coder.WriteResponse(req) + err = self.coder.WriteResponse(r) } } + + return err } return err } |