Skip to content

Commit 1f964fc

Browse files
knizhnikknizhnik
committed
Add more gc activity statistic functions
1 parent 839090d commit 1f964fc

File tree

2 files changed

+28
-4
lines changed

2 files changed

+28
-4
lines changed

‎src/backend/storage/file/cfs.c

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -839,7 +839,10 @@ PG_FUNCTION_INFO_V1(cfs_enable_gc);
839839
PG_FUNCTION_INFO_V1(cfs_version);
840840
PG_FUNCTION_INFO_V1(cfs_estimate);
841841
PG_FUNCTION_INFO_V1(cfs_compression_ratio);
842-
PG_FUNCTION_INFO_V1(cfs_gc_activity);
842+
PG_FUNCTION_INFO_V1(cfs_gc_activity_processed_bytes);
843+
PG_FUNCTION_INFO_V1(cfs_gc_activity_processed_pages);
844+
PG_FUNCTION_INFO_V1(cfs_gc_activity_processed_files);
845+
PG_FUNCTION_INFO_V1(cfs_gc_activity_scanned_files);
843846

844847
Datum cfs_start_gc(PG_FUNCTION_ARGS)
845848
{
@@ -982,7 +985,22 @@ Datum cfs_compression_ratio(PG_FUNCTION_ARGS)
982985
PG_RETURN_FLOAT8((double)virtSize/physSize);
983986
}
984987

985-
Datum cfs_gc_activity(PG_FUNCTION_ARGS)
988+
Datum cfs_gc_activity_processed_bytes(PG_FUNCTION_ARGS)
986989
{
987990
PG_RETURN_INT64(cfs_state->gc_stat.processedBytes);
988991
}
992+
993+
Datum cfs_gc_activity_processed_pages(PG_FUNCTION_ARGS)
994+
{
995+
PG_RETURN_INT64(cfs_state->gc_stat.processedPages);
996+
}
997+
998+
Datum cfs_gc_activity_processed_files(PG_FUNCTION_ARGS)
999+
{
1000+
PG_RETURN_INT64(cfs_state->gc_stat.processedFiles);
1001+
}
1002+
1003+
Datum cfs_gc_activity_scanned_files(PG_FUNCTION_ARGS)
1004+
{
1005+
PG_RETURN_INT64(cfs_state->gc_stat.scannedFiles);
1006+
}

‎src/include/catalog/pg_proc.h

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5348,10 +5348,16 @@ DATA(insert OID = 6102 ( cfs_enable_gc PGNSP PGUID 12 1 0 0 0 f f f f t f v
53485348
DESCR("Enable or disable CFS garbage collection");
53495349
DATA(insert OID = 6103 ( cfs_estimate PGNSP PGUID 12 1 0 0 0 f f f f t f v s 1 0 701 "2205" _null_ _null_ _null_ _null_ _null_ cfs_estimate _null_ _null_ _null_ ));
53505350
DESCR("Estimate relation compression ratio");
5351-
DATA(insert OID = 6019 ( cfs_compression_ratio PGNSP PGUID 12 1 0 0 0 f f f f t f v s 1 0 701 "2205" _null_ _null_ _null_ _null_ _null_ cfs_compression_ratio _null_ _null_ _null_ ));
5351+
DATA(insert OID = 6104 ( cfs_compression_ratio PGNSP PGUID 12 1 0 0 0 f f f f t f v s 1 0 701 "2205" _null_ _null_ _null_ _null_ _null_ cfs_compression_ratio _null_ _null_ _null_ ));
53525352
DESCR("Compression ration of relation");
5353-
DATA(insert OID = 6020 ( cfs_gc_activity PGNSP PGUID 12 1 0 0 0 f f f f t f v s 0 0 20 "" _null_ _null_ _null_ _null_ _null_ cfs_gc_activity _null_ _null_ _null_ ));
5353+
DATA(insert OID = 6105 ( cfs_gc_activity_processed_bytes PGNSP PGUID 12 1 0 0 0 f f f f t f v s 0 0 20 "" _null_ _null_ _null_ _null_ _null_ cfs_gc_activity_processed_bytes _null_ _null_ _null_ ));
53545354
DESCR("Number of bytes proceeded by CFS garbage collectors since system start");
5355+
DATA(insert OID = 6106 ( cfs_gc_activity_processed_files PGNSP PGUID 12 1 0 0 0 f f f f t f v s 0 0 20 "" _null_ _null_ _null_ _null_ _null_ cfs_gc_activity_processed_files _null_ _null_ _null_ ));
5356+
DESCR("Number of files compacted by CFS garbage collectors since system start");
5357+
DATA(insert OID = 6107 ( cfs_gc_activity_processed_pages PGNSP PGUID 12 1 0 0 0 f f f f t f v s 0 0 20 "" _null_ _null_ _null_ _null_ _null_ cfs_gc_activity_processed_pages _null_ _null_ _null_ ));
5358+
DESCR("Number of transferred pages by CFS garbage collectors since system start");
5359+
DATA(insert OID = 6108 ( cfs_gc_activity_scanned_files PGNSP PGUID 12 1 0 0 0 f f f f t f v s 0 0 20 "" _null_ _null_ _null_ _null_ _null_ cfs_gc_activity_scanned_files _null_ _null_ _null_ ));
5360+
DESCR("Number of files scanned by CFS garbage collectors since system start");
53555361

53565362
/* distance functions */
53575363
DATA(insert OID = 3343 ( int2_dist PGNSP PGUID 12 1 0 0 0 f f f f t f i s 2 0 21 "21 21" _null_ _null_ _null_ _null_ _null_ int2_dist _null_ _null_ _null_ ));

0 commit comments

Comments
 (0)