mirror of https://github.com/postgres/postgres
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
79 lines
2.0 KiB
79 lines
2.0 KiB
Parsed test spec with 2 sessions
|
|
|
|
starting permutation: s0_setup s0_is_setup s1_setup s1_is_setup s0_add_message s0_store_lsn s1_add_message s1_store_lsn s0_compare s0_reset s1_reset
|
|
step s0_setup: SELECT pg_replication_origin_session_setup('origin');
|
|
pg_replication_origin_session_setup
|
|
-----------------------------------
|
|
|
|
(1 row)
|
|
|
|
step s0_is_setup: SELECT pg_replication_origin_session_is_setup();
|
|
pg_replication_origin_session_is_setup
|
|
--------------------------------------
|
|
t
|
|
(1 row)
|
|
|
|
step s1_setup:
|
|
SELECT pg_replication_origin_session_setup('origin', pid)
|
|
FROM pg_stat_activity
|
|
WHERE application_name = 'isolation/parallel_session_origin/s0';
|
|
|
|
pg_replication_origin_session_setup
|
|
-----------------------------------
|
|
|
|
(1 row)
|
|
|
|
step s1_is_setup: SELECT pg_replication_origin_session_is_setup();
|
|
pg_replication_origin_session_is_setup
|
|
--------------------------------------
|
|
t
|
|
(1 row)
|
|
|
|
step s0_add_message:
|
|
SELECT 1
|
|
FROM pg_logical_emit_message(true, 'prefix', 'message on s0');
|
|
|
|
?column?
|
|
--------
|
|
1
|
|
(1 row)
|
|
|
|
step s0_store_lsn:
|
|
INSERT INTO local_lsn_store
|
|
SELECT 0, local_lsn FROM pg_replication_origin_status;
|
|
|
|
step s1_add_message:
|
|
SELECT 1
|
|
FROM pg_logical_emit_message(true, 'prefix', 'message on s1');
|
|
|
|
?column?
|
|
--------
|
|
1
|
|
(1 row)
|
|
|
|
step s1_store_lsn:
|
|
INSERT INTO local_lsn_store
|
|
SELECT 1, local_lsn FROM pg_replication_origin_status;
|
|
|
|
step s0_compare:
|
|
SELECT s0.lsn < s1.lsn
|
|
FROM local_lsn_store as s0, local_lsn_store as s1
|
|
WHERE s0.session = 0 AND s1.session = 1;
|
|
|
|
?column?
|
|
--------
|
|
t
|
|
(1 row)
|
|
|
|
step s0_reset: SELECT pg_replication_origin_session_reset();
|
|
pg_replication_origin_session_reset
|
|
-----------------------------------
|
|
|
|
(1 row)
|
|
|
|
step s1_reset: SELECT pg_replication_origin_session_reset();
|
|
pg_replication_origin_session_reset
|
|
-----------------------------------
|
|
|
|
(1 row)
|
|
|
|
|