resident_scheduler_test.go RawHistoryFolder

1package subagents
2
3import "testing"
4
5func TestResidentSchedulerUsesSixSlotDefault(t *testing.T) {
6	if got := NewResidentScheduler(0).limit; got != DefaultResidentConcurrency {
7		t.Fatalf("default limit = %d, want %d", got, DefaultResidentConcurrency)
8	}
9}
10
11func TestResidentSchedulerNormalizesNegativeLimit(t *testing.T) {
12	if got := NewResidentScheduler(-1).limit; got != DefaultResidentConcurrency {
13		t.Fatalf("negative limit = %d, want default %d", got, DefaultResidentConcurrency)
14	}
15}
16
17func TestResidentSchedulerSelectsOldestEligibleWithoutBlockingOtherChildren(t *testing.T) {
18	scheduler := NewResidentScheduler(2)
19	first := scheduler.Enqueue("child-a", "first")
20	second := scheduler.Enqueue("child-a", "second")
21	third := scheduler.Enqueue("child-b", "third")
22
23	if got, ok := scheduler.Admit(); !ok || got.Sequence != first.Sequence {
24		t.Fatalf("first admit = %#v, want %#v", got, first)
25	}
26	if got, ok := scheduler.Admit(); !ok || got.Sequence != third.Sequence {
27		t.Fatalf("second admit = %#v, want child-b ticket %#v", got, third)
28	}
29	scheduler.Release("child-a")
30	if got, ok := scheduler.Admit(); !ok || got.Sequence != second.Sequence {
31		t.Fatalf("third admit = %#v, want queued child-a ticket %#v", got, second)
32	}
33}