Function TestStoreRemote

onecache/onecache_rpc_test.go:11–45

(t *testing.T)

)

func TestStoreRemote(t *testing.T) {
	nodes, err := connectedTestNodes(2, 1)
	defer tearDownNodes(nodes)
	if err != nil {
		t.Fatalf("connectedTestNodes(2, 1) failed: %v", err)
	}

	n1 := nodes[0]
	n2 := nodes[1]

	expV := []byte("bar")
	args := StorageArgs{
		Key:          "foo",
		Value:        expV,
		Flags:        0,
		Exp:          0,
		ExplicitPeer: n2.name,
	}

	var resp struct{}
	if err := n1.server.Set(args, &resp); err != nil {
		t.Errorf("Set(%+v) returned an error: %v", args, err)
	}

	// Check the key is actually stored.
	data, err := n2.data.Get(args.Key)
	if err != nil {
		t.Errorf("n2.data.Get(%v) returned error: %v", args.Key, err)
		t.FailNow()
	}

	if !reflect.DeepEqual(data.Data, expV) {
		t.Errorf("Stored incorrect value: want %v; got %v", expV, data.Data)
	}
}

func TestCasRemoteInvalidRemote(t *testing.T) {
	nodes, err := connectedTestNodes(2, 1)