mirror of
https://github.com/postgres/postgres.git
synced 2026-03-17 16:12:13 -04:00
850196b610
* Have both physical and logical walsender share a 'xlogreader' state struct for tracking state. This replaces the existing globals sendSeg and sendCxt. * Change WALRead not to receive XLogReaderState->seg and ->segcxt as separate arguments anymore; just use the ones from 'state'. This is made possible by the above change. * have the XLogReader segment_open contract require the callbacks to install the file descriptor in the state struct themselves instead of returning it. xlogreader was already ignoring any possible failed return from the callbacks, relying solely on them never returning. (This point is not altogether excellent, as it means the callbacks have to know more of XLogReaderState; but to really improve on that we would have to pass back error info from the callbacks to xlogreader. And the complexity would not be saved but instead just transferred to the callers of WALRead, which would have to learn how to throw errors from the open_segment callback in addition of, as currently, from pg_pread.) * segment_open no longer receives the 'segcxt' as a separate argument, since it's part of the XLogReaderState argument. Per comments from Kyotaro Horiguchi. Author: Álvaro Herrera <alvherre@alvh.no-ip.org> Discussion: https://postgr.es/m/20200511203336.GA9913@alvherre.pgsql
63 lines
2.1 KiB
C
63 lines
2.1 KiB
C
/*
|
|
* xlogutils.h
|
|
*
|
|
* Utilities for replaying WAL records.
|
|
*
|
|
* Portions Copyright (c) 1996-2020, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* src/include/access/xlogutils.h
|
|
*/
|
|
#ifndef XLOG_UTILS_H
|
|
#define XLOG_UTILS_H
|
|
|
|
#include "access/xlogreader.h"
|
|
#include "storage/bufmgr.h"
|
|
|
|
|
|
extern bool XLogHaveInvalidPages(void);
|
|
extern void XLogCheckInvalidPages(void);
|
|
|
|
extern void XLogDropRelation(RelFileNode rnode, ForkNumber forknum);
|
|
extern void XLogDropDatabase(Oid dbid);
|
|
extern void XLogTruncateRelation(RelFileNode rnode, ForkNumber forkNum,
|
|
BlockNumber nblocks);
|
|
|
|
/* Result codes for XLogReadBufferForRedo[Extended] */
|
|
typedef enum
|
|
{
|
|
BLK_NEEDS_REDO, /* changes from WAL record need to be applied */
|
|
BLK_DONE, /* block is already up-to-date */
|
|
BLK_RESTORED, /* block was restored from a full-page image */
|
|
BLK_NOTFOUND /* block was not found (and hence does not
|
|
* need to be replayed) */
|
|
} XLogRedoAction;
|
|
|
|
extern XLogRedoAction XLogReadBufferForRedo(XLogReaderState *record,
|
|
uint8 buffer_id, Buffer *buf);
|
|
extern Buffer XLogInitBufferForRedo(XLogReaderState *record, uint8 block_id);
|
|
extern XLogRedoAction XLogReadBufferForRedoExtended(XLogReaderState *record,
|
|
uint8 buffer_id,
|
|
ReadBufferMode mode, bool get_cleanup_lock,
|
|
Buffer *buf);
|
|
|
|
extern Buffer XLogReadBufferExtended(RelFileNode rnode, ForkNumber forknum,
|
|
BlockNumber blkno, ReadBufferMode mode);
|
|
|
|
extern Relation CreateFakeRelcacheEntry(RelFileNode rnode);
|
|
extern void FreeFakeRelcacheEntry(Relation fakerel);
|
|
|
|
extern int read_local_xlog_page(XLogReaderState *state,
|
|
XLogRecPtr targetPagePtr, int reqLen,
|
|
XLogRecPtr targetRecPtr, char *cur_page);
|
|
extern void wal_segment_open(XLogReaderState *state,
|
|
XLogSegNo nextSegNo,
|
|
TimeLineID *tli_p);
|
|
extern void wal_segment_close(XLogReaderState *state);
|
|
|
|
extern void XLogReadDetermineTimeline(XLogReaderState *state,
|
|
XLogRecPtr wantPage, uint32 wantLength);
|
|
|
|
extern void WALReadRaiseError(WALReadError *errinfo);
|
|
|
|
#endif
|