v2-0002-Use-int64-for-page-numbers-in-clog.c-async.c.patch
application/octet-stream
Filename: v2-0002-Use-int64-for-page-numbers-in-clog.c-async.c.patch
Type: application/octet-stream
Part: 1
Patch
Format: format-patch
Series: patch v2-0002
Subject: Use int64 for page numbers in clog.c & async.c
| File | + | − |
|---|---|---|
| src/backend/access/transam/clog.c | 2 | 2 |
| src/backend/commands/async.c | 3 | 3 |
From bf5cfda7b04005e6b221faa4382b27b46c50cbd1 Mon Sep 17 00:00:00 2001
From: Aleksander Alekseev <aleksander@timescale.com>
Date: Wed, 26 Jun 2024 14:02:42 +0300
Subject: [PATCH v2 2/2] Use int64 for page numbers in clog.c & async.c
Oversight of 4ed8f0913bfd
Aleksander Alekseev, Noah Misch
---
src/backend/access/transam/clog.c | 4 ++--
src/backend/commands/async.c | 6 +++---
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/backend/access/transam/clog.c b/src/backend/access/transam/clog.c
index 44c253246b..e6f79320e9 100644
--- a/src/backend/access/transam/clog.c
+++ b/src/backend/access/transam/clog.c
@@ -445,7 +445,7 @@ TransactionGroupUpdateXidStatus(TransactionId xid, XidStatus status,
PGPROC *proc = MyProc;
uint32 nextidx;
uint32 wakeidx;
- int prevpageno;
+ int64 prevpageno;
LWLock *prevlock = NULL;
/* We should definitely have an XID whose status needs to be updated. */
@@ -577,7 +577,7 @@ TransactionGroupUpdateXidStatus(TransactionId xid, XidStatus status,
while (nextidx != INVALID_PROC_NUMBER)
{
PGPROC *nextproc = &ProcGlobal->allProcs[nextidx];
- int thispageno = nextproc->clogGroupMemberPage;
+ int64 thispageno = nextproc->clogGroupMemberPage;
/*
* If the page to update belongs to a different bank than the previous
diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c
index ab4c72762d..f38c5feabb 100644
--- a/src/backend/commands/async.c
+++ b/src/backend/commands/async.c
@@ -1271,9 +1271,9 @@ asyncQueueUnregister(void)
static bool
asyncQueueIsFull(void)
{
- int headPage = QUEUE_POS_PAGE(QUEUE_HEAD);
- int tailPage = QUEUE_POS_PAGE(QUEUE_TAIL);
- int occupied = headPage - tailPage;
+ int64 headPage = QUEUE_POS_PAGE(QUEUE_HEAD);
+ int64 tailPage = QUEUE_POS_PAGE(QUEUE_TAIL);
+ int64 occupied = headPage - tailPage;
return occupied >= max_notify_queue_pages;
}
--
2.45.2