Skip to content

Commit 546a99b

Browse files
committed
return 64-bit total_rows from show_concurrent_part_tasks_internal()
1 parent d3fa9f8 commit 546a99b

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

init.sql

+1-1
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,7 @@ RETURNS TABLE (
285285
pid INT,
286286
dbid OID,
287287
relid REGCLASS,
288-
processed INT,
288+
processed INT8,
289289
status TEXT)
290290
AS 'pg_pathman', 'show_concurrent_part_tasks_internal'
291291
LANGUAGE C STRICT;

src/pathman_workers.c

+2-3
Original file line numberDiff line numberDiff line change
@@ -837,7 +837,7 @@ show_concurrent_part_tasks_internal(PG_FUNCTION_ARGS)
837837
TupleDescInitEntry(tupdesc, Anum_pathman_cp_tasks_relid,
838838
"relid", REGCLASSOID, -1, 0);
839839
TupleDescInitEntry(tupdesc, Anum_pathman_cp_tasks_processed,
840-
"processed", INT4OID, -1, 0);
840+
"processed", INT8OID, -1, 0);
841841
TupleDescInitEntry(tupdesc, Anum_pathman_cp_tasks_status,
842842
"status", TEXTOID, -1, 0);
843843

@@ -874,8 +874,7 @@ show_concurrent_part_tasks_internal(PG_FUNCTION_ARGS)
874874

875875
/* Record processed rows */
876876
values[Anum_pathman_cp_tasks_processed - 1] =
877-
/* FIXME: use Int64GetDatum() in release 1.5 */
878-
Int32GetDatum((int32) slot_copy.total_rows);
877+
Int64GetDatum(slot_copy.total_rows);
879878

880879
/* Now build a status string */
881880
values[Anum_pathman_cp_tasks_status - 1] =

0 commit comments

Comments
 (0)