diff options
Diffstat (limited to 'rpc/comms/ipc.go')
| -rw-r--r-- | rpc/comms/ipc.go | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/rpc/comms/ipc.go b/rpc/comms/ipc.go index d897bf313..3de659b65 100644 --- a/rpc/comms/ipc.go +++ b/rpc/comms/ipc.go @@ -42,16 +42,12 @@ func (self *ipcClient) Close() { self.coder.Close() } -func (self *ipcClient) Send(req interface{}) error { +func (self *ipcClient) Send(msg interface{}) error { var err error - 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(r) - } + if err = self.coder.WriteResponse(msg); err != nil { + if err = self.reconnect(); err == nil { + err = self.coder.WriteResponse(msg) } - - return err } return err } |