121 bool register_delete)
129 switch (relpersistence)
131 case RELPERSISTENCE_TEMP:
135 case RELPERSISTENCE_UNLOGGED:
139 case RELPERSISTENCE_PERMANENT:
144 elog(
ERROR,
"invalid relpersistence: %c", relpersistence);
172 if (relpersistence == RELPERSISTENCE_PERMANENT && !
XLogIsNeeded())
192 xlrec.
rnode = *rnode;
291 bool need_fsm_vacuum =
false;
308 blocks[nforks] = nblocks;
320 need_fsm_vacuum =
true;
371 xlrec.
blkno = nblocks;
457 bool copying_initfork;
468 copying_initfork = relpersistence == RELPERSISTENCE_UNLOGGED &&
478 (relpersistence == RELPERSISTENCE_PERMANENT || copying_initfork);
482 for (blkno = 0; blkno < nblocks; blkno++)
505 errmsg(
"invalid page in block %u of relation %s",
536 if (use_wal || copying_initfork)
605 if (delete->atCommit)
606 (void)
hash_search(tmphash, (
void *) &
delete->relnode,
688 else if (maxrels <= nrels)
694 srels[nrels++] = srel;
706 for (
int i = 0;
i < nrels;
i++)
741 if (isParallelWorker)
810 else if (maxrels <= nrels)
816 srels[nrels++] = srel;
823 int n = nblocks[fork];
981 bool need_fsm_vacuum =
false;
1014 blocks[nforks] = xlrec->
blkno;
1032 need_fsm_vacuum =
true;
1055 if (need_fsm_vacuum)
1062 elog(
PANIC,
"smgr_redo: unknown op code %u", info);
#define BackendIdForTempRelations()
#define InvalidBlockNumber
#define BlockNumberIsValid(blockNumber)
bool PageIsVerifiedExtended(Page page, BlockNumber blkno, int flags)
void PageSetChecksumInplace(Page page, BlockNumber blkno)
#define MemSet(start, val, len)
void hash_destroy(HTAB *hashp)
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
long hash_get_num_entries(HTAB *hashp)
void * hash_seq_search(HASH_SEQ_STATUS *status)
void hash_seq_init(HASH_SEQ_STATUS *status, HTAB *hashp)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
void FreeSpaceMapVacuumRange(Relation rel, BlockNumber start, BlockNumber end)
BlockNumber FreeSpaceMapPrepareTruncateRel(Relation rel, BlockNumber nblocks)
Assert(fmt[strlen(fmt) - 1] !='\n')
MemoryContext TopTransactionContext
void pfree(void *pointer)
MemoryContext TopMemoryContext
MemoryContext CurrentMemoryContext
void * repalloc(void *pointer, Size size)
void * MemoryContextAlloc(MemoryContext context, Size size)
#define CHECK_FOR_INTERRUPTS()
#define ERRCODE_DATA_CORRUPTED
#define DELAY_CHKPT_COMPLETE
static SMgrRelation RelationGetSmgr(Relation rel)
#define RelationNeedsWAL(relation)
#define RelationCloseSmgr(relation)
#define AssertPendingSyncs_RelationCache()
struct RelFileNode RelFileNode
#define RelFileNodeEquals(node1, node2)
#define relpath(rnode, forknum)
#define relpathbackend(rnode, backend, forknum)
Size mul_size(Size s1, Size s2)
BlockNumber smgrnblocks(SMgrRelation reln, ForkNumber forknum)
void smgrextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, char *buffer, bool skipFsync)
void smgrdosyncall(SMgrRelation *rels, int nrels)
void smgrimmedsync(SMgrRelation reln, ForkNumber forknum)
void smgrcreate(SMgrRelation reln, ForkNumber forknum, bool isRedo)
void smgrclose(SMgrRelation reln)
void smgrread(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum, char *buffer)
void smgrtruncate(SMgrRelation reln, ForkNumber *forknum, int nforks, BlockNumber *nblocks)
bool smgrexists(SMgrRelation reln, ForkNumber forknum)
SMgrRelation smgropen(RelFileNode rnode, BackendId backend)
void smgrdounlinkall(SMgrRelation *rels, int nrels, bool isRedo)
void RelationPreTruncate(Relation rel)
struct PendingRelDelete PendingRelDelete
void SerializePendingSyncs(Size maxSize, char *startAddress)
void AtSubCommit_smgr(void)
SMgrRelation RelationCreateStorage(RelFileNode rnode, char relpersistence, bool register_delete)
int smgrGetPendingDeletes(bool forCommit, RelFileNode **ptr)
Size EstimatePendingSyncsSpace(void)
static HTAB * pendingSyncHash
struct PendingRelSync PendingRelSync
static PendingRelDelete * pendingDeletes
void AtSubAbort_smgr(void)
void RelationCopyStorage(SMgrRelation src, SMgrRelation dst, ForkNumber forkNum, char relpersistence)
void smgr_redo(XLogReaderState *record)
void RelationPreserveStorage(RelFileNode rnode, bool atCommit)
void PostPrepare_smgr(void)
bool RelFileNodeSkippingWAL(RelFileNode rnode)
void log_smgrcreate(const RelFileNode *rnode, ForkNumber forkNum)
void RestorePendingSyncs(char *startAddress)
static void AddPendingSync(const RelFileNode *rnode)
void RelationDropStorage(Relation rel)
void RelationTruncate(Relation rel, BlockNumber nblocks)
void smgrDoPendingSyncs(bool isCommit, bool isParallelWorker)
void smgrDoPendingDeletes(bool isCommit)
#define SMGR_TRUNCATE_ALL
#define XLOG_SMGR_TRUNCATE
#define SMGR_TRUNCATE_HEAP
#define SMGR_TRUNCATE_FSM
struct PendingRelDelete * next
RelFileNodeBackend smgr_rnode
BlockNumber smgr_targblock
BlockNumber smgr_cached_nblocks[MAX_FORKNUM+1]
BlockNumber visibilitymap_prepare_truncate(Relation rel, BlockNumber nheapblocks)
int GetCurrentTransactionNestLevel(void)
bool IsInParallelMode(void)
void XLogFlush(XLogRecPtr record)
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
XLogRecPtr log_newpage(RelFileNode *rnode, ForkNumber forkNum, BlockNumber blkno, Page page, bool page_std)
void log_newpage_range(Relation rel, ForkNumber forkNum, BlockNumber startblk, BlockNumber endblk, bool page_std)
void XLogBeginInsert(void)
void XLogRegisterData(char *data, int len)
#define XLogRecGetInfo(decoder)
#define XLogRecGetData(decoder)
#define XLogRecHasAnyBlockRefs(decoder)
#define XLR_SPECIAL_REL_UPDATE
void XLogTruncateRelation(RelFileNode rnode, ForkNumber forkNum, BlockNumber nblocks)
void FreeFakeRelcacheEntry(Relation fakerel)
Relation CreateFakeRelcacheEntry(RelFileNode rnode)