aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/comms/ipc.go
diff options
context:
space:
mode:
authorBas van Kervel <bas@ethdev.com>2015-08-24 18:22:12 +0800
committerBas van Kervel <bas@ethdev.com>2015-08-24 18:41:34 +0800
commitd910148a96cca05bc40ac5b5773effa9b92702f8 (patch)
tree8d7d177b1d4ef721c7036076c533402308f5fe86 /rpc/comms/ipc.go
parentd51d0022cee91d6588186455afbe6e54fae2cbf7 (diff)
downloadgo-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.go12
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
}