Function TestModelOverride_ConcurrentAccess

pkg/agent/agent_test.go:532–564

(t *testing.T)

}

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

	defaultModel := &mockProvider{id: modelsdev.NewID("default", "x")}
	overrideModel := &mockProvider{id: modelsdev.NewID("override", "x")}

	a := New("root", "test", WithModel(defaultModel))

	// Run concurrent reads and writes
	done := make(chan bool)

	// Writer goroutine
	go func() {
		for range 100 {
			a.SetModelOverride(overrideModel)
			a.SetModelOverride(nil)
		}
		done <- true
	}()

	// Reader goroutine
	go func() {
		for range 100 {
			_ = a.Model(t.Context())
			_ = a.HasModelOverride()
		}
		done <- true
	}()

	<-done
	<-done
	// If we got here without a race condition panic, the test passes
}

// TestAgentReProbeRecoveryDoesNotEmitNotice verifies the full retry
// lifecycle: turn 1 fails → warning emitted; turn 2 succeeds → tools