Method forward

onecache/onecache_rpc.go:103–118

forward forwards the rpc to the passed target node.

(target, method string, args interface{}, reply interface{})

// forward forwards the rpc to the passed target node.
func (r *rpcServer) forward(target, method string, args interface{}, reply interface{}) error {
	r.n.lock.Lock()
	p, ok := r.n.nodes[target]
	r.n.lock.Unlock()
	if !ok {
		return fmt.Errorf("could not dial unknown peer %v", target)
	}

	addr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf("%s:%d", p.addr, p.port))
	if err != nil {
		return fmt.Errorf("Failed to resolve tcp address of peer %v: %v", target, err)
	}

	err = r.connPool.RPC(addr, method, args, reply)
	return err
}

// StorageArgs is the struct used to make data related RPC calls.
type StorageArgs struct {