|
@@ -29,12 +29,12 @@ func (srv *Server) ServeListener(l net.Listener) error {
|
|
|
for {
|
|
for {
|
|
|
conn, err := l.Accept()
|
|
conn, err := l.Accept()
|
|
|
if netutil.IsTemporaryError(err) {
|
|
if netutil.IsTemporaryError(err) {
|
|
|
- log.Warn("RPC accept error", "err", err)
|
|
|
|
|
|
|
+ log.Warn("IPC accept error", "err", err)
|
|
|
continue
|
|
continue
|
|
|
} else if err != nil {
|
|
} else if err != nil {
|
|
|
return err
|
|
return err
|
|
|
}
|
|
}
|
|
|
- log.Trace("Accepted connection", "addr", conn.RemoteAddr())
|
|
|
|
|
|
|
+ log.Trace("IPC accepted connection")
|
|
|
go srv.ServeCodec(NewJSONCodec(conn), OptionMethodInvocation|OptionSubscriptions)
|
|
go srv.ServeCodec(NewJSONCodec(conn), OptionMethodInvocation|OptionSubscriptions)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|