PostgreSQL Source Code  git master
storage_xlog.h File Reference
#include "access/xlogreader.h"
#include "lib/stringinfo.h"
#include "storage/block.h"
#include "storage/relfilenode.h"
Include dependency graph for storage_xlog.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  xl_smgr_create
 
struct  xl_smgr_truncate
 

Macros

#define XLOG_SMGR_CREATE   0x10
 
#define XLOG_SMGR_TRUNCATE   0x20
 
#define SMGR_TRUNCATE_HEAP   0x0001
 
#define SMGR_TRUNCATE_VM   0x0002
 
#define SMGR_TRUNCATE_FSM   0x0004
 
#define SMGR_TRUNCATE_ALL   (SMGR_TRUNCATE_HEAP|SMGR_TRUNCATE_VM|SMGR_TRUNCATE_FSM)
 

Typedefs

typedef struct xl_smgr_create xl_smgr_create
 
typedef struct xl_smgr_truncate xl_smgr_truncate
 

Functions

void log_smgrcreate (RelFileNode *rnode, ForkNumber forkNum)
 
void smgr_redo (XLogReaderState *record)
 
void smgr_desc (StringInfo buf, XLogReaderState *record)
 
const char * smgr_identify (uint8 info)
 

Macro Definition Documentation

◆ SMGR_TRUNCATE_ALL

#define SMGR_TRUNCATE_ALL   (SMGR_TRUNCATE_HEAP|SMGR_TRUNCATE_VM|SMGR_TRUNCATE_FSM)

Definition at line 43 of file storage_xlog.h.

Referenced by RelationTruncate().

◆ SMGR_TRUNCATE_FSM

#define SMGR_TRUNCATE_FSM   0x0004

Definition at line 42 of file storage_xlog.h.

Referenced by smgr_redo().

◆ SMGR_TRUNCATE_HEAP

#define SMGR_TRUNCATE_HEAP   0x0001

Definition at line 40 of file storage_xlog.h.

Referenced by smgr_redo().

◆ SMGR_TRUNCATE_VM

#define SMGR_TRUNCATE_VM   0x0002

Definition at line 41 of file storage_xlog.h.

Referenced by pg_truncate_visibility_map(), and smgr_redo().

◆ XLOG_SMGR_CREATE

#define XLOG_SMGR_CREATE   0x10

Definition at line 30 of file storage_xlog.h.

Referenced by extractPageInfo(), log_smgrcreate(), smgr_desc(), smgr_identify(), and smgr_redo().

◆ XLOG_SMGR_TRUNCATE

#define XLOG_SMGR_TRUNCATE   0x20

Typedef Documentation

◆ xl_smgr_create

◆ xl_smgr_truncate

Function Documentation

◆ log_smgrcreate()

void log_smgrcreate ( RelFileNode rnode,
ForkNumber  forkNum 
)

Definition at line 124 of file storage.c.

References xl_smgr_create::forkNum, xl_smgr_create::rnode, XLOG_SMGR_CREATE, XLogBeginInsert(), XLogInsert(), XLogRegisterData(), and XLR_SPECIAL_REL_UPDATE.

Referenced by ATExecSetTableSpace(), heap_create_init_fork(), and RelationCreateStorage().

125 {
126  xl_smgr_create xlrec;
127 
128  /*
129  * Make an XLOG entry reporting the file creation.
130  */
131  xlrec.rnode = *rnode;
132  xlrec.forkNum = forkNum;
133 
134  XLogBeginInsert();
135  XLogRegisterData((char *) &xlrec, sizeof(xlrec));
137 }
#define XLR_SPECIAL_REL_UPDATE
Definition: xlogrecord.h:71
#define XLOG_SMGR_CREATE
Definition: storage_xlog.h:30
void XLogRegisterData(char *data, int len)
Definition: xloginsert.c:323
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
Definition: xloginsert.c:415
ForkNumber forkNum
Definition: storage_xlog.h:36
void XLogBeginInsert(void)
Definition: xloginsert.c:120
RelFileNode rnode
Definition: storage_xlog.h:35

◆ smgr_desc()

void smgr_desc ( StringInfo  buf,
XLogReaderState record 
)

Definition at line 21 of file smgrdesc.c.

References appendStringInfo(), appendStringInfoString(), xl_smgr_truncate::blkno, xl_smgr_truncate::flags, xl_smgr_create::forkNum, MAIN_FORKNUM, pfree(), relpathperm, xl_smgr_create::rnode, xl_smgr_truncate::rnode, XLOG_SMGR_CREATE, XLOG_SMGR_TRUNCATE, XLogRecGetData, XLogRecGetInfo, and XLR_INFO_MASK.

22 {
23  char *rec = XLogRecGetData(record);
24  uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
25 
26  if (info == XLOG_SMGR_CREATE)
27  {
28  xl_smgr_create *xlrec = (xl_smgr_create *) rec;
29  char *path = relpathperm(xlrec->rnode, xlrec->forkNum);
30 
31  appendStringInfoString(buf, path);
32  pfree(path);
33  }
34  else if (info == XLOG_SMGR_TRUNCATE)
35  {
36  xl_smgr_truncate *xlrec = (xl_smgr_truncate *) rec;
37  char *path = relpathperm(xlrec->rnode, MAIN_FORKNUM);
38 
39  appendStringInfo(buf, "%s to %u blocks flags %d", path,
40  xlrec->blkno, xlrec->flags);
41  pfree(path);
42  }
43 }
#define relpathperm(rnode, forknum)
Definition: relpath.h:83
unsigned char uint8
Definition: c.h:323
RelFileNode rnode
Definition: storage_xlog.h:49
#define XLOG_SMGR_CREATE
Definition: storage_xlog.h:30
void pfree(void *pointer)
Definition: mcxt.c:1031
#define XLogRecGetData(decoder)
Definition: xlogreader.h:230
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:78
void appendStringInfoString(StringInfo str, const char *s)
Definition: stringinfo.c:157
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:226
#define XLOG_SMGR_TRUNCATE
Definition: storage_xlog.h:31
ForkNumber forkNum
Definition: storage_xlog.h:36
#define XLR_INFO_MASK
Definition: xlogrecord.h:62
BlockNumber blkno
Definition: storage_xlog.h:48
RelFileNode rnode
Definition: storage_xlog.h:35

◆ smgr_identify()

const char* smgr_identify ( uint8  info)

Definition at line 46 of file smgrdesc.c.

References XLOG_SMGR_CREATE, XLOG_SMGR_TRUNCATE, and XLR_INFO_MASK.

47 {
48  const char *id = NULL;
49 
50  switch (info & ~XLR_INFO_MASK)
51  {
52  case XLOG_SMGR_CREATE:
53  id = "CREATE";
54  break;
55  case XLOG_SMGR_TRUNCATE:
56  id = "TRUNCATE";
57  break;
58  }
59 
60  return id;
61 }
#define XLOG_SMGR_CREATE
Definition: storage_xlog.h:30
#define XLOG_SMGR_TRUNCATE
Definition: storage_xlog.h:31
#define XLR_INFO_MASK
Definition: xlogrecord.h:62

◆ smgr_redo()

void smgr_redo ( XLogReaderState record)

Definition at line 476 of file storage.c.

References Assert, xl_smgr_truncate::blkno, CreateFakeRelcacheEntry(), elog, XLogReaderState::EndRecPtr, xl_smgr_truncate::flags, xl_smgr_create::forkNum, FreeFakeRelcacheEntry(), FreeSpaceMapTruncateRel(), FSM_FORKNUM, InvalidBackendId, MAIN_FORKNUM, PANIC, xl_smgr_create::rnode, xl_smgr_truncate::rnode, SMGR_TRUNCATE_FSM, SMGR_TRUNCATE_HEAP, SMGR_TRUNCATE_VM, smgrcreate(), smgrexists(), smgropen(), smgrtruncate(), VISIBILITYMAP_FORKNUM, visibilitymap_truncate(), XLOG_SMGR_CREATE, XLOG_SMGR_TRUNCATE, XLogFlush(), XLogRecGetData, XLogRecGetInfo, XLogRecHasAnyBlockRefs, XLogTruncateRelation(), and XLR_INFO_MASK.

477 {
478  XLogRecPtr lsn = record->EndRecPtr;
479  uint8 info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
480 
481  /* Backup blocks are not used in smgr records */
482  Assert(!XLogRecHasAnyBlockRefs(record));
483 
484  if (info == XLOG_SMGR_CREATE)
485  {
486  xl_smgr_create *xlrec = (xl_smgr_create *) XLogRecGetData(record);
487  SMgrRelation reln;
488 
489  reln = smgropen(xlrec->rnode, InvalidBackendId);
490  smgrcreate(reln, xlrec->forkNum, true);
491  }
492  else if (info == XLOG_SMGR_TRUNCATE)
493  {
494  xl_smgr_truncate *xlrec = (xl_smgr_truncate *) XLogRecGetData(record);
495  SMgrRelation reln;
496  Relation rel;
497 
498  reln = smgropen(xlrec->rnode, InvalidBackendId);
499 
500  /*
501  * Forcibly create relation if it doesn't exist (which suggests that
502  * it was dropped somewhere later in the WAL sequence). As in
503  * XLogReadBufferForRedo, we prefer to recreate the rel and replay the
504  * log as best we can until the drop is seen.
505  */
506  smgrcreate(reln, MAIN_FORKNUM, true);
507 
508  /*
509  * Before we perform the truncation, update minimum recovery point to
510  * cover this WAL record. Once the relation is truncated, there's no
511  * going back. The buffer manager enforces the WAL-first rule for
512  * normal updates to relation files, so that the minimum recovery
513  * point is always updated before the corresponding change in the data
514  * file is flushed to disk. We have to do the same manually here.
515  *
516  * Doing this before the truncation means that if the truncation fails
517  * for some reason, you cannot start up the system even after restart,
518  * until you fix the underlying situation so that the truncation will
519  * succeed. Alternatively, we could update the minimum recovery point
520  * after truncation, but that would leave a small window where the
521  * WAL-first rule could be violated.
522  */
523  XLogFlush(lsn);
524 
525  if ((xlrec->flags & SMGR_TRUNCATE_HEAP) != 0)
526  {
527  smgrtruncate(reln, MAIN_FORKNUM, xlrec->blkno);
528 
529  /* Also tell xlogutils.c about it */
530  XLogTruncateRelation(xlrec->rnode, MAIN_FORKNUM, xlrec->blkno);
531  }
532 
533  /* Truncate FSM and VM too */
534  rel = CreateFakeRelcacheEntry(xlrec->rnode);
535 
536  if ((xlrec->flags & SMGR_TRUNCATE_FSM) != 0 &&
537  smgrexists(reln, FSM_FORKNUM))
538  FreeSpaceMapTruncateRel(rel, xlrec->blkno);
539  if ((xlrec->flags & SMGR_TRUNCATE_VM) != 0 &&
541  visibilitymap_truncate(rel, xlrec->blkno);
542 
544  }
545  else
546  elog(PANIC, "smgr_redo: unknown op code %u", info);
547 }
void XLogTruncateRelation(RelFileNode rnode, ForkNumber forkNum, BlockNumber nblocks)
Definition: xlogutils.c:636
#define SMGR_TRUNCATE_HEAP
Definition: storage_xlog.h:40
void smgrcreate(SMgrRelation reln, ForkNumber forknum, bool isRedo)
Definition: smgr.c:376
unsigned char uint8
Definition: c.h:323
#define SMGR_TRUNCATE_FSM
Definition: storage_xlog.h:42
void smgrtruncate(SMgrRelation reln, ForkNumber forknum, BlockNumber nblocks)
Definition: smgr.c:684
RelFileNode rnode
Definition: storage_xlog.h:49
bool smgrexists(SMgrRelation reln, ForkNumber forknum)
Definition: smgr.c:287
#define PANIC
Definition: elog.h:53
void XLogFlush(XLogRecPtr record)
Definition: xlog.c:2783
#define XLOG_SMGR_CREATE
Definition: storage_xlog.h:30
XLogRecPtr EndRecPtr
Definition: xlogreader.h:120
#define XLogRecGetData(decoder)
Definition: xlogreader.h:230
Relation CreateFakeRelcacheEntry(RelFileNode rnode)
Definition: xlogutils.c:550
void FreeSpaceMapTruncateRel(Relation rel, BlockNumber nblocks)
Definition: freespace.c:259
#define XLogRecGetInfo(decoder)
Definition: xlogreader.h:226
SMgrRelation smgropen(RelFileNode rnode, BackendId backend)
Definition: smgr.c:137
#define XLOG_SMGR_TRUNCATE
Definition: storage_xlog.h:31
void FreeFakeRelcacheEntry(Relation fakerel)
Definition: xlogutils.c:591
#define InvalidBackendId
Definition: backendid.h:23
ForkNumber forkNum
Definition: storage_xlog.h:36
uint64 XLogRecPtr
Definition: xlogdefs.h:21
#define Assert(condition)
Definition: c.h:699
#define XLR_INFO_MASK
Definition: xlogrecord.h:62
void visibilitymap_truncate(Relation rel, BlockNumber nheapblocks)
#define SMGR_TRUNCATE_VM
Definition: storage_xlog.h:41
#define XLogRecHasAnyBlockRefs(decoder)
Definition: xlogreader.h:232
BlockNumber blkno
Definition: storage_xlog.h:48
#define elog
Definition: elog.h:219
RelFileNode rnode
Definition: storage_xlog.h:35