postgresql/contrib/test_decoding/expected/parallel_session_origin.out

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 s1_reset s0_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 s1_reset: SELECT pg_replication_origin_session_reset();
pg_replication_origin_session_reset
-----------------------------------
                                   
(1 row)

step s0_reset: SELECT pg_replication_origin_session_reset();
pg_replication_origin_session_reset
-----------------------------------
                                   
(1 row)


starting permutation: s0_setup s0_is_setup s1_setup s1_is_setup s0_reset s1_reset s0_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_reset: SELECT pg_replication_origin_session_reset();
ERROR:  cannot reset replication origin with ID 1 because it is still in use by other processes
step s1_reset: SELECT pg_replication_origin_session_reset();
pg_replication_origin_session_reset
-----------------------------------
                                   
(1 row)

step s0_reset: SELECT pg_replication_origin_session_reset();
pg_replication_origin_session_reset
-----------------------------------
                                   
(1 row)