Function TestMarkTouched

onecache/replicator_test.go:311–347

(t *testing.T)

}

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

	// Store a key on both nodes but with different experations.
	k := "foo"
	owner, followers := getOwner(k, nodes)
	follower := followers[0]
	exp := time.Now().Add(1 * time.Hour).Unix()
	if err := owner.data.Set(k, []byte("bar"), exp, 0); err != nil {
		t.Fatalf("Set(%v) failed: %v", k, err)
	}

	if err := follower.data.Set(k, []byte("bar"), 0, 0); err != nil {
		t.Fatalf("Set(%v) failed: %v", k, err)
	}

	owner.replicator.MarkTouched(k)

	// Check the key expiration is updated.
	waitForResult(func() (bool, error) {
		data, err := follower.data.Get(k)
		if err != nil {
			return false, nil
		}

		if data.Exp != exp {
			return false, nil
		}
		return true, nil
	}, func(e error) {
		t.Errorf("Replication failed: %v", e)
	})
}

func TestCollapseLogValueTouch(t *testing.T) {
	in := []replicationTask{task_DIRTY_VALUE, task_TOUCH}