Method initRpcServer

onecache/rpc_dispatch.go:20–30

initRpcServer intializes the listener for rpc requests on the passed port.

(port int)

// initRpcServer intializes the listener for rpc requests on the passed port.
func (n *Node) initRpcServer(port int) error {
	l, err := net.Listen("tcp", ":"+strconv.Itoa(port))
	if err != nil {
		return fmt.Errorf("couldn't listen on port %d: %v", port, err)
	}

	n.port = l.Addr().(*net.TCPAddr).Port
	n.listener = l
	n.shutdown = false
	return nil
}

func (n *Node) listen() {
	for {