aboutsummaryrefslogtreecommitdiff
package clock //nolint:testpackage

import "testing"

func TestShardEvictsOldest(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](8)
	shard.add("a", "a", 4)
	shard.add("b", "b", 4)
	shard.add("c", "c", 4) // overflows, evicts

	if _, ok := shard.peek("a"); ok {
		t.Fatalf("a should have been evicted")
	}

	for _, key := range []string{"b", "c"} {
		if _, ok := shard.peek(key); !ok {
			t.Fatalf("%s should remain present", key)
		}
	}

	if got := shard.loadWeight(); got != 8 {
		t.Fatalf("weight = %d, want 8", got)
	}

	if got := shard.len(); got != 2 {
		t.Fatalf("len = %d, want 2", got)
	}
}

func TestShardGetGivesSecondChance(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](8)
	shard.add("a", "a", 4)
	shard.add("b", "b", 4)
	shard.add("c", "c", 4) // a evicted; b and c survive

	if _, ok := shard.get("b"); !ok {
		t.Fatalf("get(b) should hit")
	}

	shard.add("d", "d", 4) // b was just touched, so c is evicted instead

	if _, ok := shard.peek("c"); ok {
		t.Fatalf("c should have been evicted after b was touched")
	}

	for _, key := range []string{"b", "d"} {
		if _, ok := shard.peek(key); !ok {
			t.Fatalf("%s should remain present", key)
		}
	}
}

func TestShardPeekGivesNoSecondChance(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](8)
	shard.add("a", "a", 4)
	shard.add("b", "b", 4)
	shard.add("c", "c", 4) // a is evicted; b and c survive with cleared bits

	if _, ok := shard.peek("b"); !ok {
		t.Fatalf("peek(b) should hit")
	}

	shard.add("d", "d", 4) // peek did not refresh b, so b is evicted

	if _, ok := shard.peek("b"); ok {
		t.Fatalf("b should have been evicted; peek must not grant a second chance")
	}

	for _, key := range []string{"c", "d"} {
		if _, ok := shard.peek(key); !ok {
			t.Fatalf("%s should remain present", key)
		}
	}
}

func TestShardReplaceUpdatesWeight(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](100)
	shard.add("a", "old", 4)
	shard.add("a", "new", 6)

	if got, ok := shard.peek("a"); !ok || got != "new" {
		t.Fatalf("peek(a) = (%q, %v), want (new, true)", got, ok)
	}

	if got := shard.loadWeight(); got != 6 {
		t.Fatalf("weight = %d, want 6", got)
	}

	if got := shard.len(); got != 1 {
		t.Fatalf("len = %d, want 1", got)
	}
}

func TestShardRejectsOversized(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](5)
	shard.add("a", "x", 3)

	if shard.add("b", "big", 6) {
		t.Fatalf("oversized add should report false")
	}

	if shard.add("a", "huge", 6) {
		t.Fatalf("oversized replace should report false")
	}

	if got, ok := shard.peek("a"); !ok || got != "x" {
		t.Fatalf("peek(a) = (%q, %v), want (x, true); cache must be unchanged", got, ok)
	}

	if _, ok := shard.peek("b"); ok {
		t.Fatalf("b must not have been admitted")
	}

	if got := shard.loadWeight(); got != 3 {
		t.Fatalf("weight = %d, want 3", got)
	}
}

func TestShardClear(t *testing.T) {
	t.Parallel()

	shard := newShard[string, string](100)
	shard.add("a", "a", 4)
	shard.add("b", "b", 4)

	shard.clear()

	if got := shard.loadWeight(); got != 0 {
		t.Fatalf("weight = %d, want 0", got)
	}

	if got := shard.len(); got != 0 {
		t.Fatalf("len = %d, want 0", got)
	}

	if _, ok := shard.peek("a"); ok {
		t.Fatalf("a should be gone after clear")
	}
}