aboutsummaryrefslogtreecommitdiffstats
path: root/rpc
diff options
context:
space:
mode:
Diffstat (limited to 'rpc')
-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
}