diff options
Diffstat (limited to 'src/backend/access/transam/xloginsert.c')
-rw-r--r-- | src/backend/access/transam/xloginsert.c | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/src/backend/access/transam/xloginsert.c b/src/backend/access/transam/xloginsert.c index 2ce9be2cc76..f3c29fa9091 100644 --- a/src/backend/access/transam/xloginsert.c +++ b/src/backend/access/transam/xloginsert.c @@ -70,7 +70,7 @@ typedef struct { bool in_use; /* is this slot in use? */ uint8 flags; /* REGBUF_* flags */ - RelFileNode rnode; /* identifies the relation and block */ + RelFileLocator rlocator; /* identifies the relation and block */ ForkNumber forkno; BlockNumber block; Page page; /* page content */ @@ -257,7 +257,7 @@ XLogRegisterBuffer(uint8 block_id, Buffer buffer, uint8 flags) regbuf = ®istered_buffers[block_id]; - BufferGetTag(buffer, ®buf->rnode, ®buf->forkno, ®buf->block); + BufferGetTag(buffer, ®buf->rlocator, ®buf->forkno, ®buf->block); regbuf->page = BufferGetPage(buffer); regbuf->flags = flags; regbuf->rdata_tail = (XLogRecData *) ®buf->rdata_head; @@ -278,7 +278,7 @@ XLogRegisterBuffer(uint8 block_id, Buffer buffer, uint8 flags) if (i == block_id || !regbuf_old->in_use) continue; - Assert(!RelFileNodeEquals(regbuf_old->rnode, regbuf->rnode) || + Assert(!RelFileLocatorEquals(regbuf_old->rlocator, regbuf->rlocator) || regbuf_old->forkno != regbuf->forkno || regbuf_old->block != regbuf->block); } @@ -293,7 +293,7 @@ XLogRegisterBuffer(uint8 block_id, Buffer buffer, uint8 flags) * shared buffer pool (i.e. when you don't have a Buffer for it). */ void -XLogRegisterBlock(uint8 block_id, RelFileNode *rnode, ForkNumber forknum, +XLogRegisterBlock(uint8 block_id, RelFileLocator *rlocator, ForkNumber forknum, BlockNumber blknum, Page page, uint8 flags) { registered_buffer *regbuf; @@ -308,7 +308,7 @@ XLogRegisterBlock(uint8 block_id, RelFileNode *rnode, ForkNumber forknum, regbuf = ®istered_buffers[block_id]; - regbuf->rnode = *rnode; + regbuf->rlocator = *rlocator; regbuf->forkno = forknum; regbuf->block = blknum; regbuf->page = page; @@ -331,7 +331,7 @@ XLogRegisterBlock(uint8 block_id, RelFileNode *rnode, ForkNumber forknum, if (i == block_id || !regbuf_old->in_use) continue; - Assert(!RelFileNodeEquals(regbuf_old->rnode, regbuf->rnode) || + Assert(!RelFileLocatorEquals(regbuf_old->rlocator, regbuf->rlocator) || regbuf_old->forkno != regbuf->forkno || regbuf_old->block != regbuf->block); } @@ -768,7 +768,7 @@ XLogRecordAssemble(RmgrId rmid, uint8 info, rdt_datas_last = regbuf->rdata_tail; } - if (prev_regbuf && RelFileNodeEquals(regbuf->rnode, prev_regbuf->rnode)) + if (prev_regbuf && RelFileLocatorEquals(regbuf->rlocator, prev_regbuf->rlocator)) { samerel = true; bkpb.fork_flags |= BKPBLOCK_SAME_REL; @@ -793,8 +793,8 @@ XLogRecordAssemble(RmgrId rmid, uint8 info, } if (!samerel) { - memcpy(scratch, ®buf->rnode, sizeof(RelFileNode)); - scratch += sizeof(RelFileNode); + memcpy(scratch, ®buf->rlocator, sizeof(RelFileLocator)); + scratch += sizeof(RelFileLocator); } memcpy(scratch, ®buf->block, sizeof(BlockNumber)); scratch += sizeof(BlockNumber); @@ -1031,7 +1031,7 @@ XLogSaveBufferForHint(Buffer buffer, bool buffer_std) int flags = 0; PGAlignedBlock copied_buffer; char *origdata = (char *) BufferGetBlock(buffer); - RelFileNode rnode; + RelFileLocator rlocator; ForkNumber forkno; BlockNumber blkno; @@ -1058,8 +1058,8 @@ XLogSaveBufferForHint(Buffer buffer, bool buffer_std) if (buffer_std) flags |= REGBUF_STANDARD; - BufferGetTag(buffer, &rnode, &forkno, &blkno); - XLogRegisterBlock(0, &rnode, forkno, blkno, copied_buffer.data, flags); + BufferGetTag(buffer, &rlocator, &forkno, &blkno); + XLogRegisterBlock(0, &rlocator, forkno, blkno, copied_buffer.data, flags); recptr = XLogInsert(RM_XLOG_ID, XLOG_FPI_FOR_HINT); } @@ -1080,7 +1080,7 @@ XLogSaveBufferForHint(Buffer buffer, bool buffer_std) * the unused space to be left out from the WAL record, making it smaller. */ XLogRecPtr -log_newpage(RelFileNode *rnode, ForkNumber forkNum, BlockNumber blkno, +log_newpage(RelFileLocator *rlocator, ForkNumber forkNum, BlockNumber blkno, Page page, bool page_std) { int flags; @@ -1091,7 +1091,7 @@ log_newpage(RelFileNode *rnode, ForkNumber forkNum, BlockNumber blkno, flags |= REGBUF_STANDARD; XLogBeginInsert(); - XLogRegisterBlock(0, rnode, forkNum, blkno, page, flags); + XLogRegisterBlock(0, rlocator, forkNum, blkno, page, flags); recptr = XLogInsert(RM_XLOG_ID, XLOG_FPI); /* @@ -1112,7 +1112,7 @@ log_newpage(RelFileNode *rnode, ForkNumber forkNum, BlockNumber blkno, * because we can write multiple pages in a single WAL record. */ void -log_newpages(RelFileNode *rnode, ForkNumber forkNum, int num_pages, +log_newpages(RelFileLocator *rlocator, ForkNumber forkNum, int num_pages, BlockNumber *blknos, Page *pages, bool page_std) { int flags; @@ -1142,7 +1142,7 @@ log_newpages(RelFileNode *rnode, ForkNumber forkNum, int num_pages, nbatch = 0; while (nbatch < XLR_MAX_BLOCK_ID && i < num_pages) { - XLogRegisterBlock(nbatch, rnode, forkNum, blknos[i], pages[i], flags); + XLogRegisterBlock(nbatch, rlocator, forkNum, blknos[i], pages[i], flags); i++; nbatch++; } @@ -1177,16 +1177,16 @@ XLogRecPtr log_newpage_buffer(Buffer buffer, bool page_std) { Page page = BufferGetPage(buffer); - RelFileNode rnode; + RelFileLocator rlocator; ForkNumber forkNum; BlockNumber blkno; /* Shared buffers should be modified in a critical section. */ Assert(CritSectionCount > 0); - BufferGetTag(buffer, &rnode, &forkNum, &blkno); + BufferGetTag(buffer, &rlocator, &forkNum, &blkno); - return log_newpage(&rnode, forkNum, blkno, page, page_std); + return log_newpage(&rlocator, forkNum, blkno, page, page_std); } /* |