Commit0084ae6

committed

concurrent partitioning function renamed

1 parent5992123 commit0084ae6Copy full SHA for 0084ae6

File tree

-5

lines changed

-5

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,7 @@ RETURNS TABLE (`
`167`	`167`	`CREATEOR REPLACE VIEW @extschema@.pathman_active_workers`
`168`	`168`	`ASSELECT*FROM @extschema@.active_workers();`
`169`	`169`
`170`		`-CREATEOR REPLACE FUNCTION @extschema@.partition_data_worker(relation regclass)`
	`170`	`+CREATEOR REPLACE FUNCTION @extschema@.partition_data_concurrent(relation regclass)`
`171`	`171`	`RETURNS VOIDAS'pg_pathman' LANGUAGE C STRICT;`
`172`	`172`
`173`	`173`	`CREATEOR REPLACE FUNCTION @extschema@.stop_worker(relation regclass)`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ static void create_partitions_bg_worker_main(Datum main_arg);`
`37`	`37`	`staticvoidpartition_data_bg_worker_main(Datummain_arg);`
`38`	`38`	`staticvoidhandle_sigterm(SIGNAL_ARGS);`
`39`	`39`
`40`		`-PG_FUNCTION_INFO_V1(partition_data_worker );`
	`40`	`+PG_FUNCTION_INFO_V1(partition_data_concurrent );`
`41`	`41`	`PG_FUNCTION_INFO_V1(active_workers );`
`42`	`42`	`PG_FUNCTION_INFO_V1(stop_worker );`
`43`	`43`
`@@ -374,7 +374,7 @@ create_partitions_bg_worker_main(Datum main_arg)`
`374`	`374`	`* immediately`
`375`	`375`	`*/`
`376`	`376`	`Datum`
`377`		`-partition_data_worker(PG_FUNCTION_ARGS )`
	`377`	`+partition_data_concurrent(PG_FUNCTION_ARGS )`
`378`	`378`	`{`
`379`	`379`	`Oidrelid=PG_GETARG_OID(0);`
`380`	`380`	`intempty_slot_idx=-1;`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@`
`13`	`13`	`importtime`
`14`	`14`
`15`	`15`
`16`		`-classConcurrentTest(unittest.TestCase):`
	`16`	`+classPartitioningTests(unittest.TestCase):`
`17`	`17`
`18`	`18`	`defsetUp(self):`
`19`	`19`	`self.setup_cmd= [`
`@@ -48,7 +48,7 @@ def test_concurrent(self):`
`48`	`48`	`node.start()`
`49`	`49`	`self.init_test_data(node)`
`50`	`50`
`51`		`-node.psql('postgres','selectpartition_data_worker(\'abc\')')`
	`51`	`+node.psql('postgres','selectpartition_data_concurrent(\'abc\')')`
`52`	`52`
`53`	`53`	`whileTrue:`
`54`	`54`	`# update some rows to check for deadlocks`

Comments

(0)