diff options
Diffstat (limited to 'src/backend/utils')
-rw-r--r-- | src/backend/utils/activity/pgstat_io.c | 8 | ||||
-rw-r--r-- | src/backend/utils/probes.d | 6 |
2 files changed, 11 insertions, 3 deletions
diff --git a/src/backend/utils/activity/pgstat_io.c b/src/backend/utils/activity/pgstat_io.c index ae8bb34f78b..0e4f26427ca 100644 --- a/src/backend/utils/activity/pgstat_io.c +++ b/src/backend/utils/activity/pgstat_io.c @@ -65,12 +65,18 @@ pgstat_bktype_io_stats_valid(PgStat_BktypeIO *backend_io, void pgstat_count_io_op(IOObject io_object, IOContext io_context, IOOp io_op) { + pgstat_count_io_op_n(io_object, io_context, io_op, 1); +} + +void +pgstat_count_io_op_n(IOObject io_object, IOContext io_context, IOOp io_op, uint32 cnt) +{ Assert((unsigned int) io_object < IOOBJECT_NUM_TYPES); Assert((unsigned int) io_context < IOCONTEXT_NUM_TYPES); Assert((unsigned int) io_op < IOOP_NUM_TYPES); Assert(pgstat_tracks_io_op(MyBackendType, io_object, io_context, io_op)); - PendingIOStats.data[io_object][io_context][io_op]++; + PendingIOStats.data[io_object][io_context][io_op] += cnt; have_iostats = true; } diff --git a/src/backend/utils/probes.d b/src/backend/utils/probes.d index 204a2649b09..0af275587b7 100644 --- a/src/backend/utils/probes.d +++ b/src/backend/utils/probes.d @@ -55,10 +55,12 @@ provider postgresql { probe sort__start(int, bool, int, int, bool, int); probe sort__done(bool, long); - probe buffer__read__start(ForkNumber, BlockNumber, Oid, Oid, Oid, int, bool); - probe buffer__read__done(ForkNumber, BlockNumber, Oid, Oid, Oid, int, bool, bool); + probe buffer__read__start(ForkNumber, BlockNumber, Oid, Oid, Oid, int); + probe buffer__read__done(ForkNumber, BlockNumber, Oid, Oid, Oid, int, bool); probe buffer__flush__start(ForkNumber, BlockNumber, Oid, Oid, Oid); probe buffer__flush__done(ForkNumber, BlockNumber, Oid, Oid, Oid); + probe buffer__extend__start(ForkNumber, Oid, Oid, Oid, int, unsigned int); + probe buffer__extend__done(ForkNumber, Oid, Oid, Oid, int, unsigned int, BlockNumber); probe buffer__checkpoint__start(int); probe buffer__checkpoint__sync__start(); |