diff options
author | Bas van Kervel <bas@ethdev.com> | 2015-08-24 18:22:12 +0800 |
---|---|---|
committer | Bas van Kervel <bas@ethdev.com> | 2015-08-24 18:41:34 +0800 |
commit | d910148a96cca05bc40ac5b5773effa9b92702f8 (patch) | |
tree | 8d7d177b1d4ef721c7036076c533402308f5fe86 /rpc/comms/ipc.go | |
parent | d51d0022cee91d6588186455afbe6e54fae2cbf7 (diff) | |
download | go-tangerine-d910148a96cca05bc40ac5b5773effa9b92702f8.tar.gz go-tangerine-d910148a96cca05bc40ac5b5773effa9b92702f8.tar.zst go-tangerine-d910148a96cca05bc40ac5b5773effa9b92702f8.zip |
Set ipc channel as user agent client
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 } |