#include "access/xlogreader.h"
#include "lib/stringinfo.h"
#include "storage/bufpage.h"
#include "storage/itemptr.h"
#include "storage/relfilelocator.h"
#include "utils/relcache.h"

Include dependency graph for brin_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_brin_createidx

struct	xl_brin_insert

struct	xl_brin_update

struct	xl_brin_samepage_update

struct	xl_brin_revmap_extend

struct	xl_brin_desummarize

Macros
#define	XLOG_BRIN_CREATE_INDEX 0x00

#define	XLOG_BRIN_INSERT 0x10

#define	XLOG_BRIN_UPDATE 0x20

#define	XLOG_BRIN_SAMEPAGE_UPDATE 0x30

#define	XLOG_BRIN_REVMAP_EXTEND 0x40

#define	XLOG_BRIN_DESUMMARIZE 0x50

#define	XLOG_BRIN_OPMASK 0x70

#define	XLOG_BRIN_INIT_PAGE 0x80

#define	SizeOfBrinCreateIdx (offsetof(xl_brin_createidx, version) + sizeof(uint16))

#define	SizeOfBrinInsert (offsetof(xl_brin_insert, offnum) + sizeof(OffsetNumber))

#define	SizeOfBrinUpdate (offsetof(xl_brin_update, insert) + SizeOfBrinInsert)

#define	SizeOfBrinSamepageUpdate (sizeof(OffsetNumber))

#define	SizeOfBrinRevmapExtend

#define	SizeOfBrinDesummarize

Typedefs
typedef struct xl_brin_createidx	xl_brin_createidx

typedef struct xl_brin_insert	xl_brin_insert

typedef struct xl_brin_update	xl_brin_update

typedef struct xl_brin_samepage_update	xl_brin_samepage_update

typedef struct xl_brin_revmap_extend	xl_brin_revmap_extend

typedef struct xl_brin_desummarize	xl_brin_desummarize

Functions
void	brin_redo (XLogReaderState *record)

void	brin_desc (StringInfo buf, XLogReaderState *record)

const char *	brin_identify (uint8 info)

void	brin_mask (char *pagedata, BlockNumber blkno)

Macro Definition Documentation

◆ SizeOfBrinCreateIdx

#define SizeOfBrinCreateIdx (offsetof(xl_brin_createidx, version) + sizeof(uint16))

Definition at line 55 of file brin_xlog.h.

◆ SizeOfBrinDesummarize

#define SizeOfBrinDesummarize

Value:

(offsetof(xl_brin_desummarize, regOffset) + \

sizeof(OffsetNumber))

OffsetNumber

uint16 OffsetNumber

Definition: off.h:24

xl_brin_desummarize

Definition: brin_xlog.h:134

Definition at line 142 of file brin_xlog.h.

◆ SizeOfBrinInsert

#define SizeOfBrinInsert (offsetof(xl_brin_insert, offnum) + sizeof(OffsetNumber))

Definition at line 74 of file brin_xlog.h.

◆ SizeOfBrinRevmapExtend

#define SizeOfBrinRevmapExtend

Value:

(offsetof(xl_brin_revmap_extend, targetBlk) + \

sizeof(BlockNumber))

BlockNumber

uint32 BlockNumber

Definition: block.h:31

xl_brin_revmap_extend

Definition: brin_xlog.h:116

Definition at line 124 of file brin_xlog.h.

◆ SizeOfBrinSamepageUpdate

#define SizeOfBrinSamepageUpdate (sizeof(OffsetNumber))

Definition at line 107 of file brin_xlog.h.

◆ SizeOfBrinUpdate

#define SizeOfBrinUpdate (offsetof(xl_brin_update, insert) + SizeOfBrinInsert)

Definition at line 95 of file brin_xlog.h.

◆ XLOG_BRIN_CREATE_INDEX

#define XLOG_BRIN_CREATE_INDEX 0x00

Definition at line 31 of file brin_xlog.h.

◆ XLOG_BRIN_DESUMMARIZE

#define XLOG_BRIN_DESUMMARIZE 0x50

Definition at line 36 of file brin_xlog.h.

◆ XLOG_BRIN_INIT_PAGE

#define XLOG_BRIN_INIT_PAGE 0x80

Definition at line 43 of file brin_xlog.h.

◆ XLOG_BRIN_INSERT

#define XLOG_BRIN_INSERT 0x10

Definition at line 32 of file brin_xlog.h.

◆ XLOG_BRIN_OPMASK

#define XLOG_BRIN_OPMASK 0x70

Definition at line 38 of file brin_xlog.h.

◆ XLOG_BRIN_REVMAP_EXTEND

#define XLOG_BRIN_REVMAP_EXTEND 0x40

Definition at line 35 of file brin_xlog.h.

◆ XLOG_BRIN_SAMEPAGE_UPDATE

#define XLOG_BRIN_SAMEPAGE_UPDATE 0x30

Definition at line 34 of file brin_xlog.h.

◆ XLOG_BRIN_UPDATE

#define XLOG_BRIN_UPDATE 0x20

Definition at line 33 of file brin_xlog.h.

Typedef Documentation

◆ xl_brin_createidx

typedef struct xl_brin_createidx xl_brin_createidx

◆ xl_brin_desummarize

typedef struct xl_brin_desummarize xl_brin_desummarize

◆ xl_brin_insert

typedef struct xl_brin_insert xl_brin_insert

◆ xl_brin_revmap_extend

typedef struct xl_brin_revmap_extend xl_brin_revmap_extend

◆ xl_brin_samepage_update

typedef struct xl_brin_samepage_update xl_brin_samepage_update

◆ xl_brin_update

typedef struct xl_brin_update xl_brin_update

Function Documentation

◆ brin_desc()

void brin_desc	(	StringInfo	buf,
		XLogReaderState *	record
	)

Definition at line 20 of file brindesc.c.

{
    char       *rec = XLogRecGetData(record);
    uint8       info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
 
    info &= XLOG_BRIN_OPMASK;
    if (info == XLOG_BRIN_CREATE_INDEX)
    {
        xl_brin_createidx *xlrec = (xl_brin_createidx *) rec;
 
        appendStringInfo(buf, "v%d pagesPerRange %u",
                         xlrec->version, xlrec->pagesPerRange);
    }
    else if (info == XLOG_BRIN_INSERT)
    {
        xl_brin_insert *xlrec = (xl_brin_insert *) rec;
 
        appendStringInfo(buf, "heapBlk %u pagesPerRange %u offnum %u",
                         xlrec->heapBlk,
                         xlrec->pagesPerRange,
                         xlrec->offnum);
    }
    else if (info == XLOG_BRIN_UPDATE)
    {
        xl_brin_update *xlrec = (xl_brin_update *) rec;
 
        appendStringInfo(buf, "heapBlk %u pagesPerRange %u old offnum %u, new offnum %u",
                         xlrec->insert.heapBlk,
                         xlrec->insert.pagesPerRange,
                         xlrec->oldOffnum,
                         xlrec->insert.offnum);
    }
    else if (info == XLOG_BRIN_SAMEPAGE_UPDATE)
    {
        xl_brin_samepage_update *xlrec = (xl_brin_samepage_update *) rec;
 
        appendStringInfo(buf, "offnum %u", xlrec->offnum);
    }
    else if (info == XLOG_BRIN_REVMAP_EXTEND)
    {
        xl_brin_revmap_extend *xlrec = (xl_brin_revmap_extend *) rec;
 
        appendStringInfo(buf, "targetBlk %u", xlrec->targetBlk);
    }
    else if (info == XLOG_BRIN_DESUMMARIZE)
    {
        xl_brin_desummarize *xlrec = (xl_brin_desummarize *) rec;
 
        appendStringInfo(buf, "pagesPerRange %u, heapBlk %u, page offset %u",
                         xlrec->pagesPerRange, xlrec->heapBlk, xlrec->regOffset);
    }
}

References appendStringInfo(), buf, xl_brin_insert::heapBlk, xl_brin_desummarize::heapBlk, xl_brin_update::insert, xl_brin_insert::offnum, xl_brin_samepage_update::offnum, xl_brin_update::oldOffnum, xl_brin_createidx::pagesPerRange, xl_brin_insert::pagesPerRange, xl_brin_desummarize::pagesPerRange, xl_brin_desummarize::regOffset, xl_brin_revmap_extend::targetBlk, xl_brin_createidx::version, XLOG_BRIN_CREATE_INDEX, XLOG_BRIN_DESUMMARIZE, XLOG_BRIN_INSERT, XLOG_BRIN_OPMASK, XLOG_BRIN_REVMAP_EXTEND, XLOG_BRIN_SAMEPAGE_UPDATE, XLOG_BRIN_UPDATE, XLogRecGetData, and XLogRecGetInfo.

◆ brin_identify()

const char * brin_identify ( uint8 info )

Definition at line 74 of file brindesc.c.

{
    const char *id = NULL;
 
    switch (info & ~XLR_INFO_MASK)
    {
        case XLOG_BRIN_CREATE_INDEX:
            id = "CREATE_INDEX";
            break;
        case XLOG_BRIN_INSERT:
            id = "INSERT";
            break;
        case XLOG_BRIN_INSERT | XLOG_BRIN_INIT_PAGE:
            id = "INSERT+INIT";
            break;
        case XLOG_BRIN_UPDATE:
            id = "UPDATE";
            break;
        case XLOG_BRIN_UPDATE | XLOG_BRIN_INIT_PAGE:
            id = "UPDATE+INIT";
            break;
        case XLOG_BRIN_SAMEPAGE_UPDATE:
            id = "SAMEPAGE_UPDATE";
            break;
        case XLOG_BRIN_REVMAP_EXTEND:
            id = "REVMAP_EXTEND";
            break;
        case XLOG_BRIN_DESUMMARIZE:
            id = "DESUMMARIZE";
            break;
    }
 
    return id;
}

References XLOG_BRIN_CREATE_INDEX, XLOG_BRIN_DESUMMARIZE, XLOG_BRIN_INIT_PAGE, XLOG_BRIN_INSERT, XLOG_BRIN_REVMAP_EXTEND, XLOG_BRIN_SAMEPAGE_UPDATE, XLOG_BRIN_UPDATE, and XLR_INFO_MASK.

◆ brin_mask()

void brin_mask	(	char *	pagedata,
		BlockNumber	blkno
	)

Definition at line 342 of file brin_xlog.c.

{
    Page        page = (Page) pagedata;
    PageHeader  pagehdr = (PageHeader) page;
 
    mask_page_lsn_and_checksum(page);
 
    mask_page_hint_bits(page);
 
    /*
     * Regular brin pages contain unused space which needs to be masked.
     * Similarly for meta pages, but mask it only if pd_lower appears to have
     * been set correctly.
     */
    if (BRIN_IS_REGULAR_PAGE(page) ||
        (BRIN_IS_META_PAGE(page) && pagehdr->pd_lower > SizeOfPageHeaderData))
    {
        mask_unused_space(page);
    }
 
    /*
     * BRIN_EVACUATE_PAGE is not WAL-logged, since it's of no use in recovery.
     * Mask it.  See brin_start_evacuating_page() for details.
     */
    BrinPageFlags(page) &= ~BRIN_EVACUATE_PAGE;
}

References BRIN_IS_META_PAGE, BRIN_IS_REGULAR_PAGE, BrinPageFlags, mask_page_hint_bits(), mask_page_lsn_and_checksum(), mask_unused_space(), PageHeaderData::pd_lower, and SizeOfPageHeaderData.

◆ brin_redo()

void brin_redo ( XLogReaderState * record )

Definition at line 309 of file brin_xlog.c.

{
    uint8       info = XLogRecGetInfo(record) & ~XLR_INFO_MASK;
 
    switch (info & XLOG_BRIN_OPMASK)
    {
        case XLOG_BRIN_CREATE_INDEX:
            brin_xlog_createidx(record);
            break;
        case XLOG_BRIN_INSERT:
            brin_xlog_insert(record);
            break;
        case XLOG_BRIN_UPDATE:
            brin_xlog_update(record);
            break;
        case XLOG_BRIN_SAMEPAGE_UPDATE:
            brin_xlog_samepage_update(record);
            break;
        case XLOG_BRIN_REVMAP_EXTEND:
            brin_xlog_revmap_extend(record);
            break;
        case XLOG_BRIN_DESUMMARIZE:
            brin_xlog_desummarize_page(record);
            break;
        default:
            elog(PANIC, "brin_redo: unknown op code %u", info);
    }
}

References brin_xlog_createidx(), brin_xlog_desummarize_page(), brin_xlog_insert(), brin_xlog_revmap_extend(), brin_xlog_samepage_update(), brin_xlog_update(), elog, PANIC, XLOG_BRIN_CREATE_INDEX, XLOG_BRIN_DESUMMARIZE, XLOG_BRIN_INSERT, XLOG_BRIN_OPMASK, XLOG_BRIN_REVMAP_EXTEND, XLOG_BRIN_SAMEPAGE_UPDATE, XLOG_BRIN_UPDATE, and XLogRecGetInfo.

Data Structures

Macros

Typedefs

Functions