From 9e8fa05d3412d6adea453a8ec24d9a794498f4cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro=20Herrera?= Date: Thu, 27 Nov 2025 13:10:56 +0100 Subject: [PATCH] Fix new test for CATCACHE_FORCE_RELEASE builds MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Two of the isolation tests introduce by commit bc32a12e0db2 had a problem under CATCACHE_FORCE_RELEASE, as evidenced by buildfarm member prion. An injection point is hit ahead of what the test spec expects, so a session goes to sleep and there's no one there to wait it up. Fix in the simplest possible way, which is to conditionally wake the process up if it's waiting. An alternative output file is necessary to cover both cases. This suggests a couple of possible improvements to the injection points infrastructure: a conditional wakeup (doing nothing if no one is sleeping, as opposed to throwing an error), as well as a way to attach to a point in "deactivated" mode, activated later. Author: Álvaro Herrera Reviewed-by: Mihail Nikalayeu Discussion: https://postgr.es/m/202511261817.fyixgtt3hqdr@alvherre.pgsql --- .../index-concurrently-upsert-predicate.out | 23 +++- .../index-concurrently-upsert-predicate_1.out | 116 ++++++++++++++++++ .../expected/index-concurrently-upsert.out | 23 +++- .../expected/index-concurrently-upsert_1.out | 116 ++++++++++++++++++ .../index-concurrently-upsert-predicate.spec | 18 +++ .../specs/index-concurrently-upsert.spec | 18 +++ 6 files changed, 312 insertions(+), 2 deletions(-) create mode 100644 src/test/modules/injection_points/expected/index-concurrently-upsert-predicate_1.out create mode 100644 src/test/modules/injection_points/expected/index-concurrently-upsert_1.out diff --git a/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate.out b/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate.out index 3d9512c8fc7..5a57cd5fa40 100644 --- a/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate.out +++ b/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate.out @@ -1,6 +1,6 @@ Parsed test spec with 5 sessions -starting permutation: s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 +starting permutation: s1_attach_invalidate_catalog_snapshot s4_wakeup_s1_setup s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 injection_points_attach ----------------------- @@ -16,6 +16,27 @@ injection_points_attach (1 row) +step s1_attach_invalidate_catalog_snapshot: + SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); + +injection_points_attach +----------------------- + +(1 row) + +step s4_wakeup_s1_setup: + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; + +case +---- + +(1 row) + step s5_noop: step s3_start_create_index: diff --git a/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate_1.out b/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate_1.out new file mode 100644 index 00000000000..d453dd62617 --- /dev/null +++ b/src/test/modules/injection_points/expected/index-concurrently-upsert-predicate_1.out @@ -0,0 +1,116 @@ +Parsed test spec with 5 sessions + +starting permutation: s1_attach_invalidate_catalog_snapshot s4_wakeup_s1_setup s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +injection_points_attach +----------------------- + +(1 row) + +injection_points_attach +----------------------- + +(1 row) + +injection_points_attach +----------------------- + +(1 row) + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_attach_invalidate_catalog_snapshot: + SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); + +step s4_wakeup_s1_setup: + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; + +case +---- + +(1 row) + +step s1_attach_invalidate_catalog_snapshot: <... completed> +injection_points_attach +----------------------- + +(1 row) + +step s5_noop: + +step s3_start_create_index: + CREATE UNIQUE INDEX CONCURRENTLY tbl_pkey_special_duplicate ON test.tbl(abs(i)) WHERE i < 10000; + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_start_upsert: + INSERT INTO test.tbl VALUES(13,now()) ON CONFLICT (abs(i)) WHERE i < 100 DO UPDATE SET updated_at = now(); + +step s5_noop: <... completed> +step s4_wakeup_define_index_before_set_valid: + SELECT injection_points_detach('define-index-before-set-valid'); + SELECT injection_points_wakeup('define-index-before-set-valid'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s2_start_upsert: + INSERT INTO test.tbl VALUES(13,now()) ON CONFLICT (abs(i)) WHERE i < 100 DO UPDATE SET updated_at = now(); + +step s5_wakeup_s1_from_invalidate_catalog_snapshot: + SELECT injection_points_detach('invalidate-catalog-snapshot-end'); + SELECT injection_points_wakeup('invalidate-catalog-snapshot-end'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s4_wakeup_s2: + SELECT injection_points_detach('exec-insert-before-insert-speculative'); + SELECT injection_points_wakeup('exec-insert-before-insert-speculative'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s4_wakeup_s1: + SELECT injection_points_detach('check-exclusion-or-unique-constraint-no-conflict'); + SELECT injection_points_wakeup('check-exclusion-or-unique-constraint-no-conflict'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_start_upsert: <... completed> +step s2_start_upsert: <... completed> +step s3_start_create_index: <... completed> diff --git a/src/test/modules/injection_points/expected/index-concurrently-upsert.out b/src/test/modules/injection_points/expected/index-concurrently-upsert.out index a9e8bb5d00e..97386a35bed 100644 --- a/src/test/modules/injection_points/expected/index-concurrently-upsert.out +++ b/src/test/modules/injection_points/expected/index-concurrently-upsert.out @@ -1,6 +1,6 @@ Parsed test spec with 5 sessions -starting permutation: s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 +starting permutation: s1_attach_invalidate_catalog_snapshot s4_wakeup_s1_setup s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 injection_points_attach ----------------------- @@ -16,6 +16,27 @@ injection_points_attach (1 row) +step s1_attach_invalidate_catalog_snapshot: + SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); + +injection_points_attach +----------------------- + +(1 row) + +step s4_wakeup_s1_setup: + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; + +case +---- + +(1 row) + step s5_noop: step s3_start_create_index: diff --git a/src/test/modules/injection_points/expected/index-concurrently-upsert_1.out b/src/test/modules/injection_points/expected/index-concurrently-upsert_1.out new file mode 100644 index 00000000000..4bd51b2b511 --- /dev/null +++ b/src/test/modules/injection_points/expected/index-concurrently-upsert_1.out @@ -0,0 +1,116 @@ +Parsed test spec with 5 sessions + +starting permutation: s1_attach_invalidate_catalog_snapshot s4_wakeup_s1_setup s5_noop s3_start_create_index s1_start_upsert s4_wakeup_define_index_before_set_valid s2_start_upsert s5_wakeup_s1_from_invalidate_catalog_snapshot s4_wakeup_s2 s4_wakeup_s1 +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +injection_points_attach +----------------------- + +(1 row) + +injection_points_attach +----------------------- + +(1 row) + +injection_points_attach +----------------------- + +(1 row) + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_attach_invalidate_catalog_snapshot: + SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); + +step s4_wakeup_s1_setup: + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; + +case +---- + +(1 row) + +step s1_attach_invalidate_catalog_snapshot: <... completed> +injection_points_attach +----------------------- + +(1 row) + +step s5_noop: + +step s3_start_create_index: + CREATE UNIQUE INDEX CONCURRENTLY tbl_pkey_duplicate ON test.tbl(i); + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_start_upsert: + INSERT INTO test.tbl VALUES (13,now()) ON CONFLICT (i) DO UPDATE SET updated_at = now(); + +step s5_noop: <... completed> +step s4_wakeup_define_index_before_set_valid: + SELECT injection_points_detach('define-index-before-set-valid'); + SELECT injection_points_wakeup('define-index-before-set-valid'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s2_start_upsert: + INSERT INTO test.tbl VALUES (13,now()) ON CONFLICT (i) DO UPDATE SET updated_at = now(); + +step s5_wakeup_s1_from_invalidate_catalog_snapshot: + SELECT injection_points_detach('invalidate-catalog-snapshot-end'); + SELECT injection_points_wakeup('invalidate-catalog-snapshot-end'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s4_wakeup_s2: + SELECT injection_points_detach('exec-insert-before-insert-speculative'); + SELECT injection_points_wakeup('exec-insert-before-insert-speculative'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +step s4_wakeup_s1: + SELECT injection_points_detach('check-exclusion-or-unique-constraint-no-conflict'); + SELECT injection_points_wakeup('check-exclusion-or-unique-constraint-no-conflict'); + +injection_points_detach +----------------------- + +(1 row) + +injection_points_wakeup +----------------------- + +(1 row) + +s1: NOTICE: notice triggered for injection point pre-invalidate-catalog-snapshot-end +step s1_start_upsert: <... completed> +step s2_start_upsert: <... completed> +step s3_start_create_index: <... completed> diff --git a/src/test/modules/injection_points/specs/index-concurrently-upsert-predicate.spec b/src/test/modules/injection_points/specs/index-concurrently-upsert-predicate.spec index 725f6f22295..1cbcaa6963f 100644 --- a/src/test/modules/injection_points/specs/index-concurrently-upsert-predicate.spec +++ b/src/test/modules/injection_points/specs/index-concurrently-upsert-predicate.spec @@ -28,6 +28,9 @@ setup SELECT injection_points_set_local(); SELECT injection_points_attach('check-exclusion-or-unique-constraint-no-conflict', 'wait'); SELECT injection_points_attach('pre-invalidate-catalog-snapshot-end', 'notice'); +} +step s1_attach_invalidate_catalog_snapshot +{ SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); } step s1_start_upsert @@ -58,6 +61,19 @@ step s3_start_create_index } session s4 +# Step s1_attach_invalidate_catalog_snapshot sleeps or not depending on +# build conditions (CATCACHE_FORCE_RELEASE). Here we send a wakeup signal if +# it's sleeping or do nothing otherwise, and print a null value in either +# case. +step s4_wakeup_s1_setup +{ + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; +} step s4_wakeup_s1 { SELECT injection_points_detach('check-exclusion-or-unique-constraint-no-conflict'); @@ -85,6 +101,8 @@ step s5_wakeup_s1_from_invalidate_catalog_snapshot } permutation + s1_attach_invalidate_catalog_snapshot + s4_wakeup_s1_setup s5_noop(s1_start_upsert notices 1) s3_start_create_index(s1_start_upsert, s2_start_upsert) s1_start_upsert diff --git a/src/test/modules/injection_points/specs/index-concurrently-upsert.spec b/src/test/modules/injection_points/specs/index-concurrently-upsert.spec index 4487834aa8e..2a6d888dcea 100644 --- a/src/test/modules/injection_points/specs/index-concurrently-upsert.spec +++ b/src/test/modules/injection_points/specs/index-concurrently-upsert.spec @@ -27,6 +27,9 @@ setup SELECT injection_points_set_local(); SELECT injection_points_attach('check-exclusion-or-unique-constraint-no-conflict', 'wait'); SELECT injection_points_attach('pre-invalidate-catalog-snapshot-end', 'notice'); +} +step s1_attach_invalidate_catalog_snapshot +{ SELECT injection_points_attach('invalidate-catalog-snapshot-end', 'wait'); } step s1_start_upsert @@ -57,6 +60,19 @@ step s3_start_create_index } session s4 +# Step s1_attach_invalidate_catalog_snapshot sleeps or not depending on +# build conditions (CATCACHE_FORCE_RELEASE). Here we send a wakeup signal if +# it's sleeping or do nothing otherwise, and print a null value in either +# case. +step s4_wakeup_s1_setup +{ + SELECT CASE WHEN + (SELECT pid FROM pg_stat_activity + WHERE wait_event_type = 'InjectionPoint' AND + wait_event = 'invalidate-catalog-snapshot-end') IS NOT NULL + THEN injection_points_wakeup('invalidate-catalog-snapshot-end') + END; +} step s4_wakeup_s1 { SELECT injection_points_detach('check-exclusion-or-unique-constraint-no-conflict'); @@ -84,6 +100,8 @@ step s5_wakeup_s1_from_invalidate_catalog_snapshot } permutation + s1_attach_invalidate_catalog_snapshot + s4_wakeup_s1_setup s5_noop(s1_start_upsert notices 1) s3_start_create_index(s1_start_upsert, s2_start_upsert) s1_start_upsert