diff options
| author | Bas van Kervel <bas@ethdev.com> | 2015-06-17 22:22:35 +0800 |
|---|---|---|
| committer | Bas van Kervel <bas@ethdev.com> | 2015-06-22 15:17:09 +0800 |
| commit | a4a4e9fcf824189d8d06940492a01effe6e6cf92 (patch) | |
| tree | 5e7b9cea12d319e4ab1d6ca746102e080259297f /rpc/comms/ipc.go | |
| parent | 3e1d635f8d40815ef2262e017a969ed6f5eb2a5d (diff) | |
| download | go-tangerine-a4a4e9fcf824189d8d06940492a01effe6e6cf92.tar.gz go-tangerine-a4a4e9fcf824189d8d06940492a01effe6e6cf92.tar.zst go-tangerine-a4a4e9fcf824189d8d06940492a01effe6e6cf92.zip | |
removed old rpc structure and added new inproc api client
Diffstat (limited to 'rpc/comms/ipc.go')
| -rw-r--r-- | rpc/comms/ipc.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/rpc/comms/ipc.go b/rpc/comms/ipc.go index a75039d17..a07203803 100644 --- a/rpc/comms/ipc.go +++ b/rpc/comms/ipc.go @@ -10,19 +10,19 @@ type IpcConfig struct { } type ipcClient struct { - c codec.ApiCoder + codec codec.ApiCoder } func (self *ipcClient) Close() { - self.c.Close() + self.codec.Close() } func (self *ipcClient) Send(req interface{}) error { - return self.c.WriteResponse(req) + return self.codec.WriteResponse(req) } func (self *ipcClient) Recv() (interface{}, error) { - return self.c.ReadResponse() + return self.codec.ReadResponse() } // Create a new IPC client, UNIX domain socket on posix, named pipe on Windows |