aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/backend/access/brin/brin.c11
-rw-r--r--src/backend/access/brin/brin_pageops.c20
-rw-r--r--src/backend/access/brin/brin_revmap.c4
-rw-r--r--src/backend/access/brin/brin_xlog.c4
-rw-r--r--src/backend/access/rmgrdesc/brindesc.c12
-rw-r--r--src/include/access/brin_internal.h9
-rw-r--r--src/include/access/brin_xlog.h4
7 files changed, 29 insertions, 35 deletions
diff --git a/src/backend/access/brin/brin.c b/src/backend/access/brin/brin.c
index 76cc36c3469..ae655497951 100644
--- a/src/backend/access/brin/brin.c
+++ b/src/backend/access/brin/brin.c
@@ -247,12 +247,10 @@ brininsert(PG_FUNCTION_ARGS)
* the same page though, so downstream we must be prepared to cope
* if this turns out to not be possible after all.
*/
+ newtup = brin_form_tuple(bdesc, heapBlk, dtup, &newsz);
samepage = brin_can_do_samepage_update(buf, origsz, newsz);
-
LockBuffer(buf, BUFFER_LOCK_UNLOCK);
- newtup = brin_form_tuple(bdesc, heapBlk, dtup, &newsz);
-
/*
* Try to update the tuple. If this doesn't work for whatever
* reason, we need to restart from the top; the revmap might be
@@ -589,9 +587,10 @@ brinbuildCallback(Relation index,
while (thisblock > state->bs_currRangeStart + state->bs_pagesPerRange - 1)
{
- BRIN_elog(DEBUG2, "brinbuildCallback: completed a range: %u--%u",
- state->bs_currRangeStart,
- state->bs_currRangeStart + state->bs_pagesPerRange);
+ BRIN_elog((DEBUG2,
+ "brinbuildCallback: completed a range: %u--%u",
+ state->bs_currRangeStart,
+ state->bs_currRangeStart + state->bs_pagesPerRange));
/* create the index tuple and insert it */
form_and_insert_tuple(state);
diff --git a/src/backend/access/brin/brin_pageops.c b/src/backend/access/brin/brin_pageops.c
index c34b86c94c7..50f1dec1631 100644
--- a/src/backend/access/brin/brin_pageops.c
+++ b/src/backend/access/brin/brin_pageops.c
@@ -216,12 +216,12 @@ brin_doupdate(Relation idxrel, BlockNumber pagesPerRange,
info = XLOG_BRIN_UPDATE | (extended ? XLOG_BRIN_INIT_PAGE : 0);
- xlrec.new.node = idxrel->rd_node;
- ItemPointerSet(&xlrec.new.tid, BufferGetBlockNumber(newbuf), newoff);
- xlrec.new.heapBlk = heapBlk;
- xlrec.new.tuplen = newsz;
- xlrec.new.revmapBlk = BufferGetBlockNumber(revmapbuf);
- xlrec.new.pagesPerRange = pagesPerRange;
+ xlrec.insert.node = idxrel->rd_node;
+ ItemPointerSet(&xlrec.insert.tid, BufferGetBlockNumber(newbuf), newoff);
+ xlrec.insert.heapBlk = heapBlk;
+ xlrec.insert.tuplen = newsz;
+ xlrec.insert.revmapBlk = BufferGetBlockNumber(revmapbuf);
+ xlrec.insert.pagesPerRange = pagesPerRange;
ItemPointerSet(&xlrec.oldtid, BufferGetBlockNumber(oldbuf), oldoff);
rdata[0].data = (char *) &xlrec;
@@ -342,8 +342,8 @@ brin_doinsert(Relation idxrel, BlockNumber pagesPerRange,
elog(ERROR, "could not insert new index tuple to page");
MarkBufferDirty(*buffer);
- BRIN_elog(DEBUG2, "inserted tuple (%u,%u) for range starting at %u",
- blk, off, heapBlk);
+ BRIN_elog((DEBUG2, "inserted tuple (%u,%u) for range starting at %u",
+ blk, off, heapBlk));
ItemPointerSet(&tid, blk, off);
brinSetHeapBlockItemptr(revmapbuf, pagesPerRange, heapBlk, tid);
@@ -593,8 +593,8 @@ brin_getinsertbuffer(Relation irel, Buffer oldbuf, Size itemsz,
newblk = BufferGetBlockNumber(buf);
*was_extended = extended = true;
- BRIN_elog(DEBUG2, "brin_getinsertbuffer: extending to page %u",
- BufferGetBlockNumber(buf));
+ BRIN_elog((DEBUG2, "brin_getinsertbuffer: extending to page %u",
+ BufferGetBlockNumber(buf)));
}
else if (newblk == oldblk)
{
diff --git a/src/backend/access/brin/brin_revmap.c b/src/backend/access/brin/brin_revmap.c
index b08a94b742d..7f55ded1f19 100644
--- a/src/backend/access/brin/brin_revmap.c
+++ b/src/backend/access/brin/brin_revmap.c
@@ -331,10 +331,6 @@ revmap_get_buffer(BrinRevmap *revmap, BlockNumber heapBlk)
Assert(mapBlk != BRIN_METAPAGE_BLKNO &&
mapBlk <= revmap->rm_lastRevmapPage);
- BRIN_elog(DEBUG2, "getting revmap page for logical page %lu (physical %u) for heap %u",
- HEAPBLK_TO_REVMAP_BLK(revmap->rm_pagesPerRange, heapBlk),
- mapBlk, heapBlk);
-
/*
* Obtain the buffer from which we need to read. If we already have the
* correct buffer in our access struct, use that; otherwise, release that,
diff --git a/src/backend/access/brin/brin_xlog.c b/src/backend/access/brin/brin_xlog.c
index 8dc80ad1e52..ebef984e7f1 100644
--- a/src/backend/access/brin/brin_xlog.c
+++ b/src/backend/access/brin/brin_xlog.c
@@ -144,7 +144,7 @@ brin_xlog_update(XLogRecPtr lsn, XLogRecord *record)
/* First remove the old tuple */
blkno = ItemPointerGetBlockNumber(&(xlrec->oldtid));
- action = XLogReadBufferForRedo(lsn, record, 2, xlrec->new.node,
+ action = XLogReadBufferForRedo(lsn, record, 2, xlrec->insert.node,
blkno, &buffer);
if (action == BLK_NEEDS_REDO)
{
@@ -164,7 +164,7 @@ brin_xlog_update(XLogRecPtr lsn, XLogRecord *record)
}
/* Then insert the new tuple and update revmap, like in an insertion. */
- brin_xlog_insert_update(lsn, record, &xlrec->new, newtup);
+ brin_xlog_insert_update(lsn, record, &xlrec->insert, newtup);
if (BufferIsValid(buffer))
UnlockReleaseBuffer(buffer);
diff --git a/src/backend/access/rmgrdesc/brindesc.c b/src/backend/access/rmgrdesc/brindesc.c
index 39135bf52e7..97dc3c0fa91 100644
--- a/src/backend/access/rmgrdesc/brindesc.c
+++ b/src/backend/access/rmgrdesc/brindesc.c
@@ -49,14 +49,14 @@ brin_desc(StringInfo buf, XLogRecord *record)
xl_brin_update *xlrec = (xl_brin_update *) rec;
appendStringInfo(buf, "rel %u/%u/%u heapBlk %u revmapBlk %u pagesPerRange %u old TID (%u,%u) TID (%u,%u)",
- xlrec->new.node.spcNode, xlrec->new.node.dbNode,
- xlrec->new.node.relNode,
- xlrec->new.heapBlk, xlrec->new.revmapBlk,
- xlrec->new.pagesPerRange,
+ xlrec->insert.node.spcNode, xlrec->insert.node.dbNode,
+ xlrec->insert.node.relNode,
+ xlrec->insert.heapBlk, xlrec->insert.revmapBlk,
+ xlrec->insert.pagesPerRange,
ItemPointerGetBlockNumber(&xlrec->oldtid),
ItemPointerGetOffsetNumber(&xlrec->oldtid),
- ItemPointerGetBlockNumber(&xlrec->new.tid),
- ItemPointerGetOffsetNumber(&xlrec->new.tid));
+ ItemPointerGetBlockNumber(&xlrec->insert.tid),
+ ItemPointerGetOffsetNumber(&xlrec->insert.tid));
}
else if (info == XLOG_BRIN_SAMEPAGE_UPDATE)
{
diff --git a/src/include/access/brin_internal.h b/src/include/access/brin_internal.h
index 651ab5f67e4..34491ef5f3f 100644
--- a/src/include/access/brin_internal.h
+++ b/src/include/access/brin_internal.h
@@ -72,13 +72,12 @@ typedef struct BrinDesc
#define BRIN_PROCNUM_UNION 4
/* procedure numbers up to 10 are reserved for BRIN future expansion */
-#define BRIN_DEBUG
+#undef BRIN_DEBUG
-/* we allow debug if using GCC; otherwise don't bother */
-#if defined(BRIN_DEBUG) && defined(__GNUC__)
-#define BRIN_elog(level, ...) elog(level, __VA_ARGS__)
+#ifdef BRIN_DEBUG
+#define BRIN_elog(args) elog args
#else
-#define BRIN_elog(a) void(0)
+#define BRIN_elog(args) ((void) 0)
#endif
/* brin.c */
diff --git a/src/include/access/brin_xlog.h b/src/include/access/brin_xlog.h
index 3d959e81d63..d748db4d0c6 100644
--- a/src/include/access/brin_xlog.h
+++ b/src/include/access/brin_xlog.h
@@ -76,10 +76,10 @@ typedef struct xl_brin_insert
typedef struct xl_brin_update
{
ItemPointerData oldtid;
- xl_brin_insert new;
+ xl_brin_insert insert;
} xl_brin_update;
-#define SizeOfBrinUpdate (offsetof(xl_brin_update, new) + SizeOfBrinInsert)
+#define SizeOfBrinUpdate (offsetof(xl_brin_update, insert) + SizeOfBrinInsert)
/* This is what we need to know about a BRIN tuple samepage update */
typedef struct xl_brin_samepage_update