Commit9a70505

committed

add more sanity checks to pathman_bgw tests

1 parent0faf90f commit9a70505Copy full SHA for 9a70505

File tree

+12

-4

lines changed

+12

-4

lines changed

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -187,6 +187,7 @@ DECLARE`
`187`	`187`	`iint4 := 0; -- protect from endless loop`
`188`	`188`	`BEGIN`
`189`	`189`	`LOOP`
	`190`	`+-- get total number of processed rows`
`190`	`191`	`SELECT processed`
`191`	`192`	`FROM pathman_concurrent_part_tasks`
`192`	`193`	`WHERE relid = 'test_bgw.conc_part'::regclass`
`@@ -200,9 +201,12 @@ BEGIN`
`200`	`201`
`201`	`202`	`ASSERT rows IS NOT NULL;`
`202`	`203`
`203`		`--- rows should increase!`
`204`		`-IF rows_old <= rows THEN`
	`204`	`+IF rows_old = rows THEN`
`205`	`205`	`i = i + 1;`
	`206`	`+ELSIF rows < rows_old THEN`
	`207`	`+RAISE EXCEPTION 'rows is decreasing: new %, old %', rows, rows_old;`
	`208`	`+ELSIF rows > 500 THEN`
	`209`	`+RAISE EXCEPTION 'processed % rows', rows;`
`206`	`210`	`END IF;`
`207`	`211`	`ELSE`
`208`	`212`	`EXIT; -- exit loop`

Lines changed: 6 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -101,6 +101,7 @@ DECLARE`
`101`	`101`	`iint4 :=0;-- protect from endless loop`
`102`	`102`	`BEGIN`
`103`	`103`	`LOOP`
	`104`	`+-- get total number of processed rows`
`104`	`105`	`SELECT processed`
`105`	`106`	`FROM pathman_concurrent_part_tasks`
`106`	`107`	`WHERE relid='test_bgw.conc_part'::regclass`
`@@ -114,9 +115,12 @@ BEGIN`
`114`	`115`
`115`	`116`	`ASSERT rowsIS NOT NULL;`
`116`	`117`
`117`		`--- rows should increase!`
`118`		`-IF rows_old<= rows THEN`
	`118`	`+IF rows_old= rows THEN`
`119`	`119`	`i= i+1;`
	`120`	`+ELSIF rows< rows_old THEN`
	`121`	`+RAISE EXCEPTION'rows is decreasing: new %, old %', rows, rows_old;`
	`122`	`+ELSIF rows>500 THEN`
	`123`	`+RAISE EXCEPTION'processed % rows', rows;`
`120`	`124`	`END IF;`
`121`	`125`	`ELSE`
`122`	`126`	`EXIT;-- exit loop`

Comments

(0)