Function TestSetAbortError_ThreadSafe

go/base/context_test.go:234–272

(t *testing.T)

}

func TestSetAbortError_ThreadSafe(t *testing.T) {
	ctx := NewMigrationContext()

	var wg sync.WaitGroup
	errs := []error{
		errors.New("error 1"),
		errors.New("error 2"),
		errors.New("error 3"),
	}

	// Launch 3 goroutines trying to set error concurrently
	for _, err := range errs {
		wg.Add(1)
		go func(e error) {
			defer wg.Done()
			ctx.SetAbortError(e)
		}(err)
	}

	wg.Wait()

	// Should store exactly one of the errors
	got := ctx.GetAbortError()
	if got == nil {
		t.Fatal("Expected error to be stored, got nil")
	}

	// Verify it's one of the errors we sent
	found := false
	for _, err := range errs {
		if got == err { //nolint:errorlint // Testing pointer equality for sentinel error
			found = true
			break
		}
	}
	if !found {
		t.Errorf("Stored error %v not in list of sent errors", got)
	}
}