Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit546a99b

Browse files
committed
return 64-bit total_rows from show_concurrent_part_tasks_internal()
1 parentd3fa9f8 commit546a99b

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

‎init.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,7 @@ RETURNS TABLE (
285285
pidINT,
286286
dbidOID,
287287
relidREGCLASS,
288-
processedINT,
288+
processedINT8,
289289
statusTEXT)
290290
AS'pg_pathman','show_concurrent_part_tasks_internal'
291291
LANGUAGE C STRICT;

‎src/pathman_workers.c

Lines changed: 2 additions & 3 deletions
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)

[8]ページ先頭

©2009-2025 Movatter.jp