check type of 'rows' in bgw_main_concurrent_part()

funbringer · funbringer · commit 4d7ce5db9800 · 2017-10-12T16:09:21.000+03:00
diff --git a/src/pathman_workers.c b/src/pathman_workers.c
@@ -569,6 +569,7 @@ bgw_main_concurrent_part(Datum main_arg)
 
 				/* Extract number of processed rows */
 				rows = DatumGetInt64(SPI_getbinval(tuple, tupdesc, 1, &isnull));
+				Assert(tupdesc->attrs[0]->atttypid == INT8OID); /* check type */
 				Assert(!isnull); /* ... and ofc it must not be NULL */
 			}
 			/* Else raise generic error */

Original file line number	Diff line number	Diff line change
`@@ -569,6 +569,7 @@ bgw_main_concurrent_part(Datum main_arg)`
`569`	`569`
`570`	`570`	`/* Extract number of processed rows */`
`571`	`571`	`rows = DatumGetInt64(SPI_getbinval(tuple, tupdesc, 1, &isnull));`
	`572`	`+ Assert(tupdesc->attrs[0]->atttypid == INT8OID); /* check type */`
`572`	`573`	`Assert(!isnull); /* ... and ofc it must not be NULL */`
`573`	`574`	`}`
`574`	`575`	`/* Else raise generic error */`