move_part fix: making replica read-only

Author: arssher

bin/common.sh

@@ -67,13 +67,13 @@ function run_demo()
     psql -p 5433 -c "INSERT INTO pt SELECT generate_series(1, 10), random();"
     psql -c "select shardman.add_node('port=5433');"
     psql -c "select shardman.add_node('port=5434');"
-    # psql -c "select shardman.add_node('port=5435');"
-    # psql -c "select shardman.add_node('port=5436');"
+    psql -c "select shardman.add_node('port=5435');"
+    psql -c "select shardman.add_node('port=5436');"
 
     psql -p 5433 -c "drop table if exists pt_0;" # drop replica
     psql -c "select shardman.create_hash_partitions(2, 'pt', 'id', 2);"
 
-    # psql -c "select shardman.create_replica('pt_0', 3);"
-    # psql -c "select shardman.create_replica('pt_0', 5);"
-    # psql -c "select shardman.move_part('pt_0', 4, 3);"
+    psql -c "select shardman.create_replica('pt_0', 3);"
+    psql -c "select shardman.create_replica('pt_0', 5);"
+    psql -c "select shardman.move_part('pt_0', 4, 3);"
 }

postgresql.conf.master.template

@@ -2,5 +2,5 @@
 shardman.master = on
 shardman.master_dbname = ars
 shardman.master_connstring = 'port=5432'
-shardman.cmd_retry_naptime = 3000
-shardman.poll_interval = 3000
+shardman.cmd_retry_naptime = 500
+shardman.poll_interval = 500

shard.sql

@@ -157,6 +157,8 @@ BEGIN
 			'CREATE SUBSCRIPTION %I connection %L
 		PUBLICATION %I with (create_slot = false, slot_name = %L, copy_data = false, synchronous_commit = on);',
 		prev_lname, prev_connstr, prev_lname, prev_lname);
+		-- If we have prev, we are replica
+		PERFORM shardman.readonly_replica_on(p_name::regclass);
 	END IF;
 END $$ LANGUAGE plpgsql STRICT;