brin_xlog.h File Reference

#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))

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))

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, XLogRecGetInfo, and XLR_INFO_MASK.

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_EVACUATE_PAGE, 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, XLogRecGetInfo, and XLR_INFO_MASK.