aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/comms
diff options
context:
space:
mode:
authorBas van Kervel <bas@ethdev.com>2015-08-13 21:30:17 +0800
committerBas van Kervel <bas@ethdev.com>2015-08-20 03:48:56 +0800
commit9bf17eb05a4591d8dec9779a9efddc5c2276699a (patch)
treeed786ecc2ac635a24aea21f5f43e4bf5ccaa7b93 /rpc/comms
parent382d35bf403ab5dd9b0d2fe3a87c3960902d6e57 (diff)
downloaddexon-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.go8
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
}