From af56fb208e9b6f45de7c2f1b2d8e25214d2370c3 Mon Sep 17 00:00:00 2001 From: Andres Freund Date: Tue, 18 Mar 2025 14:40:06 -0400 Subject: [PATCH v2.11 27/27] StartReadBuffers debug stuff --- src/backend/storage/buffer/bufmgr.c | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) diff --git a/src/backend/storage/buffer/bufmgr.c b/src/backend/storage/buffer/bufmgr.c index 0909888c342..ba695badbeb 100644 --- a/src/backend/storage/buffer/bufmgr.c +++ b/src/backend/storage/buffer/bufmgr.c @@ -1781,6 +1781,18 @@ AsyncReadBuffers(ReadBuffersOperation *operation, int *nblocks_progress) IOObject io_object; bool did_start_io; +#if 0 + ereport(DEBUG3, + errmsg("%s: op->blocks: %d, op->blocks_done: %d, *nblocks_progress: %d, first buf %d", + __func__, + operation->nblocks, + nblocks_done, + *nblocks_progress, + buffers[0]), + errhidestmt(true), + errhidecontext(true)); +#endif + /* * When this IO is executed synchronously, either because the caller will * immediately block waiting for the IO or because IOMETHOD_SYNC is used, @@ -1845,6 +1857,13 @@ AsyncReadBuffers(ReadBuffersOperation *operation, int *nblocks_progress) operation->nblocks_done += 1; *nblocks_progress = 1; + ereport(DEBUG3, + errmsg("%s - trunc: %d", + __func__, + operation->nblocks_done), + errhidestmt(true), + errhidecontext(true)); + pgaio_io_release(ioh); pgaio_wref_clear(&operation->io_wref); did_start_io = false; @@ -1894,6 +1913,12 @@ AsyncReadBuffers(ReadBuffersOperation *operation, int *nblocks_progress) */ for (int i = nblocks_done + 1; i < operation->nblocks; i++) { +#if 0 + /* FIXME: Remove forced short read */ + if (i > 3) + break; +#endif + if (!ReadBuffersCanStartIO(buffers[i], true)) break; /* Must be consecutive block numbers. */ -- 2.48.1.76.g4e746b1a31.dirty