concurrent partitioning function renamed

Author: zilder

init.sql

@@ -167,7 +167,7 @@ RETURNS TABLE (
 CREATE OR REPLACE VIEW @extschema@.pathman_active_workers
 AS SELECT * FROM @extschema@.active_workers();
 
-CREATE OR REPLACE FUNCTION @extschema@.partition_data_worker(relation regclass)
+CREATE OR REPLACE FUNCTION @extschema@.partition_data_concurrent(relation regclass)
 RETURNS VOID AS 'pg_pathman' LANGUAGE C STRICT;
 
 CREATE OR REPLACE FUNCTION @extschema@.stop_worker(relation regclass)

src/worker.c

@@ -37,7 +37,7 @@ static void create_partitions_bg_worker_main(Datum main_arg);
 static void partition_data_bg_worker_main(Datum main_arg);
 static void handle_sigterm(SIGNAL_ARGS);
 
-PG_FUNCTION_INFO_V1( partition_data_worker );
+PG_FUNCTION_INFO_V1( partition_data_concurrent );
 PG_FUNCTION_INFO_V1( active_workers );
 PG_FUNCTION_INFO_V1( stop_worker );
 
@@ -374,7 +374,7 @@ create_partitions_bg_worker_main(Datum main_arg)
  * immediately
  */
 Datum
-partition_data_worker( PG_FUNCTION_ARGS )
+partition_data_concurrent( PG_FUNCTION_ARGS )
 {
 	Oid		relid = PG_GETARG_OID(0);
 	int		empty_slot_idx = -1;

tests/concurrent_partitioning_test.py renamed to tests/partitioning_test.py

@@ -13,7 +13,7 @@
 import time
 
 
-class ConcurrentTest(unittest.TestCase):
+class PartitioningTests(unittest.TestCase):
 
 	def setUp(self):
 		self.setup_cmd = [
@@ -48,7 +48,7 @@ def test_concurrent(self):
 		node.start()
 		self.init_test_data(node)
 
-		node.psql('postgres', 'select partition_data_worker(\'abc\')')
+		node.psql('postgres', 'select partition_data_concurrent(\'abc\')')
 
 		while True:
 			# update some rows to check for deadlocks