1999-09-27 17:48:12 +02:00
|
|
|
/*
|
|
|
|
*
|
|
|
|
* xlog.h
|
|
|
|
*
|
|
|
|
* Postgres transaction log manager
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
#ifndef XLOG_H
|
|
|
|
#define XLOG_H
|
|
|
|
|
|
|
|
#include "access/rmgr.h"
|
|
|
|
#include "access/transam.h"
|
2000-10-28 18:21:00 +02:00
|
|
|
#include "access/xlogdefs.h"
|
1999-09-27 17:48:12 +02:00
|
|
|
|
|
|
|
typedef struct XLogRecord
|
|
|
|
{
|
2000-04-12 19:17:23 +02:00
|
|
|
XLogRecPtr xl_prev; /* ptr to previous record in log */
|
|
|
|
XLogRecPtr xl_xact_prev; /* ptr to previous record of this xact */
|
|
|
|
TransactionId xl_xid; /* xact id */
|
2000-07-04 03:49:44 +02:00
|
|
|
uint16 xl_len; /* len of record *data* on this page */
|
2000-04-12 19:17:23 +02:00
|
|
|
uint8 xl_info;
|
|
|
|
RmgrId xl_rmid; /* resource manager inserted this record */
|
1999-09-27 17:48:12 +02:00
|
|
|
|
|
|
|
/* ACTUAL LOG DATA FOLLOWS AT END OF STRUCT */
|
|
|
|
|
|
|
|
} XLogRecord;
|
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#define SizeOfXLogRecord DOUBLEALIGN(sizeof(XLogRecord))
|
|
|
|
#define MAXLOGRECSZ (2 * BLCKSZ)
|
2000-07-04 03:49:44 +02:00
|
|
|
|
|
|
|
#define XLogRecGetData(record) \
|
|
|
|
((char*)record + SizeOfXLogRecord)
|
|
|
|
|
1999-09-27 17:48:12 +02:00
|
|
|
/*
|
|
|
|
* When there is no space on current page we continue on the next
|
|
|
|
* page with subrecord.
|
|
|
|
*/
|
|
|
|
typedef struct XLogSubRecord
|
|
|
|
{
|
2000-04-12 19:17:23 +02:00
|
|
|
uint16 xl_len;
|
|
|
|
uint8 xl_info;
|
1999-09-27 17:48:12 +02:00
|
|
|
|
|
|
|
/* ACTUAL LOG DATA FOLLOWS AT END OF STRUCT */
|
|
|
|
|
|
|
|
} XLogSubRecord;
|
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#define SizeOfXLogSubRecord DOUBLEALIGN(sizeof(XLogSubRecord))
|
1999-09-27 17:48:12 +02:00
|
|
|
|
2000-06-02 12:20:27 +02:00
|
|
|
/*
|
|
|
|
* XLOG uses only low 4 bits of xl_info. High 4 bits may be used
|
|
|
|
* by rmgr...
|
|
|
|
*/
|
2000-04-12 19:17:23 +02:00
|
|
|
#define XLR_TO_BE_CONTINUED 0x01
|
2000-06-02 12:20:27 +02:00
|
|
|
#define XLR_INFO_MASK 0x0F
|
1999-09-27 17:48:12 +02:00
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#define XLOG_PAGE_MAGIC 0x17345168
|
1999-09-27 17:48:12 +02:00
|
|
|
|
|
|
|
typedef struct XLogPageHeaderData
|
|
|
|
{
|
|
|
|
uint32 xlp_magic;
|
|
|
|
uint16 xlp_info;
|
|
|
|
} XLogPageHeaderData;
|
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#define SizeOfXLogPHD DOUBLEALIGN(sizeof(XLogPageHeaderData))
|
1999-09-27 17:48:12 +02:00
|
|
|
|
|
|
|
typedef XLogPageHeaderData *XLogPageHeader;
|
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#define XLP_FIRST_IS_SUBRECORD 0x0001
|
1999-09-27 17:48:12 +02:00
|
|
|
|
2000-10-20 13:01:21 +02:00
|
|
|
#define XLByteLT(left, right) \
|
|
|
|
(right.xlogid > left.xlogid || \
|
|
|
|
(right.xlogid == left.xlogid && right.xrecoff > left.xrecoff))
|
|
|
|
|
|
|
|
#define XLByteLE(left, right) \
|
|
|
|
(right.xlogid > left.xlogid || \
|
|
|
|
(right.xlogid == left.xlogid && right.xrecoff >= left.xrecoff))
|
|
|
|
|
|
|
|
#define XLByteEQ(left, right) \
|
|
|
|
(right.xlogid == left.xlogid && right.xrecoff == left.xrecoff)
|
|
|
|
|
2000-10-28 18:21:00 +02:00
|
|
|
extern StartUpID ThisStartUpID; /* current SUI */
|
2000-10-20 13:01:21 +02:00
|
|
|
extern bool InRecovery;
|
2000-10-21 17:43:36 +02:00
|
|
|
extern XLogRecPtr MyLastRecPtr;
|
|
|
|
|
|
|
|
typedef struct RmgrData
|
|
|
|
{
|
|
|
|
char *rm_name;
|
|
|
|
void (*rm_redo)(XLogRecPtr lsn, XLogRecord *rptr);
|
|
|
|
void (*rm_undo)(XLogRecPtr lsn, XLogRecord *rptr);
|
|
|
|
void (*rm_desc)(char *buf, uint8 xl_info, char *rec);
|
|
|
|
} RmgrData;
|
|
|
|
|
|
|
|
extern RmgrData RmgrTable[];
|
2000-07-03 04:54:21 +02:00
|
|
|
|
2000-06-02 12:20:27 +02:00
|
|
|
extern XLogRecPtr XLogInsert(RmgrId rmid, uint8 info,
|
|
|
|
char *hdr, uint32 hdrlen,
|
|
|
|
char *buf, uint32 buflen);
|
2000-04-12 19:17:23 +02:00
|
|
|
extern void XLogFlush(XLogRecPtr RecPtr);
|
1999-09-27 17:48:12 +02:00
|
|
|
|
2000-11-05 23:50:21 +01:00
|
|
|
extern void CreateCheckPoint(bool shutdown);
|
|
|
|
|
2000-04-12 19:17:23 +02:00
|
|
|
#endif /* XLOG_H */
|