1010my ($node_publisher , $node_subscriber , $publisher_connstr , $result , $offset );
1111$offset = 0;
1212
13- sub publish_insert ($$)
13+ sub publish_insert
1414{
1515 my ($tbl , $new_i ) = @_ ;
1616 $node_publisher -> safe_psql(' postgres' , qq(
1919 ) );
2020}
2121
22- sub publish_update ($$$)
22+ sub publish_update
2323{
2424 my ($tbl , $old_i , $new_i ) = @_ ;
2525 $node_publisher -> safe_psql(' postgres' , qq(
2828 ) );
2929}
3030
31- sub publish_delete ($$)
31+ sub publish_delete
3232{
3333 my ($tbl , $old_i ) = @_ ;
3434 $node_publisher -> safe_psql(' postgres' , qq(
3737 ) );
3838}
3939
40- sub expect_replication ($$$$$)
40+ sub expect_replication
4141{
4242 my ($tbl , $cnt , $min , $max , $testname ) = @_ ;
4343 $node_publisher -> wait_for_catchup(' admin_sub' );
@@ -46,7 +46,7 @@ ($$$$$)
4646 is ($result , " $cnt |$min |$max " , $testname );
4747}
4848
49- sub expect_failure ($$$$$$)
49+ sub expect_failure
5050{
5151 my ($tbl , $cnt , $min , $max , $re , $testname ) = @_ ;
5252 $offset = $node_subscriber -> wait_for_log($re , $offset );
@@ -55,28 +55,28 @@ ($$$$$$)
5555 is ($result , " $cnt |$min |$max " , $testname );
5656}
5757
58- sub revoke_superuser ($)
58+ sub revoke_superuser
5959{
6060 my ($role ) = @_ ;
6161 $node_subscriber -> safe_psql(' postgres' , qq(
6262 ALTER ROLE $role NOSUPERUSER) );
6363}
6464
65- sub grant_superuser ($)
65+ sub grant_superuser
6666{
6767 my ($role ) = @_ ;
6868 $node_subscriber -> safe_psql(' postgres' , qq(
6969 ALTER ROLE $role SUPERUSER) );
7070}
7171
72- sub revoke_bypassrls ($)
72+ sub revoke_bypassrls
7373{
7474 my ($role ) = @_ ;
7575 $node_subscriber -> safe_psql(' postgres' , qq(
7676 ALTER ROLE $role NOBYPASSRLS) );
7777}
7878
79- sub grant_bypassrls ($)
79+ sub grant_bypassrls
8080{
8181 my ($role ) = @_ ;
8282 $node_subscriber -> safe_psql(' postgres' , qq(
0 commit comments