diff options
| author | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:06:19 +0800 |
|---|---|---|
| committer | Jeffrey Wilcke <jeffrey@ethereum.org> | 2015-06-25 23:06:19 +0800 |
| commit | e64625aa8215985c85f97f914a98db081e07714f (patch) | |
| tree | d452551dccb6728ab96d849cd485b7220268c388 /rpc/comms/ipc_unix.go | |
| parent | 6b2a03faa2473d38093adbeee62935af2fe2da59 (diff) | |
| parent | 662285074e55a3915f7236a04fec355c3f416eb8 (diff) | |
| download | dexon-e64625aa8215985c85f97f914a98db081e07714f.tar dexon-e64625aa8215985c85f97f914a98db081e07714f.tar.gz dexon-e64625aa8215985c85f97f914a98db081e07714f.tar.bz2 dexon-e64625aa8215985c85f97f914a98db081e07714f.tar.lz dexon-e64625aa8215985c85f97f914a98db081e07714f.tar.xz dexon-e64625aa8215985c85f97f914a98db081e07714f.tar.zst dexon-e64625aa8215985c85f97f914a98db081e07714f.zip | |
Merge pull request #1332 from bas-vk/ipcbatch
IPC interface improvements
Diffstat (limited to 'rpc/comms/ipc_unix.go')
| -rw-r--r-- | rpc/comms/ipc_unix.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/rpc/comms/ipc_unix.go b/rpc/comms/ipc_unix.go index 295eb916b..3e71c7d32 100644 --- a/rpc/comms/ipc_unix.go +++ b/rpc/comms/ipc_unix.go @@ -18,7 +18,7 @@ func newIpcClient(cfg IpcConfig, codec codec.Codec) (*ipcClient, error) { return nil, err } - return &ipcClient{cfg.Endpoint, codec, codec.New(c)}, nil + return &ipcClient{cfg.Endpoint, c, codec, codec.New(c)}, nil } func (self *ipcClient) reconnect() error { @@ -48,7 +48,10 @@ func startIpc(cfg IpcConfig, codec codec.Codec, api shared.EthereumApi) error { continue } - go handle(conn, api, codec) + id := newIpcConnId() + glog.V(logger.Debug).Infof("New IPC connection with id %06d started\n", id) + + go handle(id, conn, api, codec) } os.Remove(cfg.Endpoint) |