提交 14b79227 编写于 作者: A Ashwin Agrawal

Remove beginLoc from rm_desc routines signature.

Upstream doesn't have it and not used anymore in Greenplum, so loose it.
上级 d9122f25
...@@ -662,7 +662,7 @@ out_target(StringInfo buf, RelFileNode *node) ...@@ -662,7 +662,7 @@ out_target(StringInfo buf, RelFileNode *node)
} }
void void
bitmap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) bitmap_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -705,7 +705,7 @@ desc_node(StringInfo buf, RelFileNode node, BlockNumber blkno) ...@@ -705,7 +705,7 @@ desc_node(StringInfo buf, RelFileNode node, BlockNumber blkno)
} }
void void
gin_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) gin_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -363,7 +363,7 @@ out_gistxlogPageSplit(StringInfo buf, gistxlogPageSplit *xlrec) ...@@ -363,7 +363,7 @@ out_gistxlogPageSplit(StringInfo buf, gistxlogPageSplit *xlrec)
} }
void void
gist_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) gist_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -719,6 +719,6 @@ hash_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribut ...@@ -719,6 +719,6 @@ hash_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribut
} }
void void
hash_desc(StringInfo buf __attribute__((unused)), XLogRecPtr beginLoc, XLogRecord *record __attribute__((unused))) hash_desc(StringInfo buf __attribute__((unused)), XLogRecord *record __attribute__((unused)))
{ {
} }
...@@ -5506,7 +5506,7 @@ out_target(StringInfo buf, xl_heaptid *target) ...@@ -5506,7 +5506,7 @@ out_target(StringInfo buf, xl_heaptid *target)
} }
void void
heap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) heap_desc(StringInfo buf, XLogRecord *record)
{ {
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
uint8 xl_info = record->xl_info; uint8 xl_info = record->xl_info;
...@@ -5647,7 +5647,7 @@ bool heap_getrelfilenode( ...@@ -5647,7 +5647,7 @@ bool heap_getrelfilenode(
} }
void void
heap2_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) heap2_desc(StringInfo buf, XLogRecord *record)
{ {
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
uint8 xl_info = record->xl_info; uint8 xl_info = record->xl_info;
......
...@@ -1144,7 +1144,7 @@ out_delete_page(StringInfo buf, uint8 info, XLogRecord *record) ...@@ -1144,7 +1144,7 @@ out_delete_page(StringInfo buf, uint8 info, XLogRecord *record)
} }
void void
btree_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) btree_desc(StringInfo buf, XLogRecord *record)
{ {
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
uint8 xl_info = record->xl_info; uint8 xl_info = record->xl_info;
......
...@@ -831,7 +831,7 @@ clog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -831,7 +831,7 @@ clog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
clog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) clog_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -1010,7 +1010,7 @@ DistributedLog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -1010,7 +1010,7 @@ DistributedLog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
DistributedLog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) DistributedLog_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -2050,7 +2050,7 @@ multixact_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __att ...@@ -2050,7 +2050,7 @@ multixact_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __att
} }
void void
multixact_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) multixact_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -6174,7 +6174,7 @@ xact_desc_assignment(StringInfo buf, xl_xact_assignment *xlrec) ...@@ -6174,7 +6174,7 @@ xact_desc_assignment(StringInfo buf, xl_xact_assignment *xlrec)
} }
void void
xact_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) xact_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -1271,7 +1271,7 @@ begin:; ...@@ -1271,7 +1271,7 @@ begin:;
contiguousCopy = XLogContiguousCopy(record, rdata); contiguousCopy = XLogContiguousCopy(record, rdata);
appendStringInfo(&buf, " - "); appendStringInfo(&buf, " - ");
RmgrTable[record->xl_rmid].rm_desc(&buf, RecPtr, (XLogRecord*)contiguousCopy); RmgrTable[record->xl_rmid].rm_desc(&buf, (XLogRecord*)contiguousCopy);
pfree(contiguousCopy); pfree(contiguousCopy);
elog(LOG, "%s", buf.data); elog(LOG, "%s", buf.data);
...@@ -7308,7 +7308,6 @@ StartupXLOG(void) ...@@ -7308,7 +7308,6 @@ StartupXLOG(void)
xlog_outrec(&buf, record); xlog_outrec(&buf, record);
appendStringInfo(&buf, " - "); appendStringInfo(&buf, " - ");
RmgrTable[record->xl_rmid].rm_desc(&buf, RmgrTable[record->xl_rmid].rm_desc(&buf,
record->xl_info,
XLogRecGetData(record)); XLogRecGetData(record));
elog(LOG, "%s", buf.data); elog(LOG, "%s", buf.data);
pfree(buf.data); pfree(buf.data);
...@@ -10108,7 +10107,7 @@ xlog_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribut ...@@ -10108,7 +10107,7 @@ xlog_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribut
} }
void void
xlog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) xlog_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
...@@ -11460,7 +11459,6 @@ rm_redo_error_callback(void *arg) ...@@ -11460,7 +11459,6 @@ rm_redo_error_callback(void *arg)
initStringInfo(&buf); initStringInfo(&buf);
RmgrTable[redoErrorCallBack->record->xl_rmid].rm_desc( RmgrTable[redoErrorCallBack->record->xl_rmid].rm_desc(
&buf, &buf,
redoErrorCallBack->location,
redoErrorCallBack->record); redoErrorCallBack->record);
/* don't bother emitting empty description */ /* don't bother emitting empty description */
......
...@@ -564,7 +564,7 @@ smgr_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -564,7 +564,7 @@ smgr_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
smgr_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) smgr_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -48,7 +48,7 @@ appendonly_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -48,7 +48,7 @@ appendonly_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
appendonly_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) appendonly_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 xl_info = record->xl_info; uint8 xl_info = record->xl_info;
uint8 info = xl_info & ~XLR_INFO_MASK; uint8 info = xl_info & ~XLR_INFO_MASK;
......
...@@ -2173,7 +2173,7 @@ dbase_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attri ...@@ -2173,7 +2173,7 @@ dbase_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attri
} }
void void
dbase_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) dbase_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -1758,7 +1758,7 @@ seq_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -1758,7 +1758,7 @@ seq_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
seq_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) seq_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -1695,7 +1695,7 @@ tblspc_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -1695,7 +1695,7 @@ tblspc_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
tblspc_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) tblspc_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -747,7 +747,7 @@ standby_desc_running_xacts(StringInfo buf, xl_running_xacts *xlrec) ...@@ -747,7 +747,7 @@ standby_desc_running_xacts(StringInfo buf, xl_running_xacts *xlrec)
} }
void void
standby_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) standby_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -896,7 +896,7 @@ relmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record) ...@@ -896,7 +896,7 @@ relmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record)
} }
void void
relmap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record) relmap_desc(StringInfo buf, XLogRecord *record)
{ {
uint8 info = record->xl_info & ~XLR_INFO_MASK; uint8 info = record->xl_info & ~XLR_INFO_MASK;
char *rec = XLogRecGetData(record); char *rec = XLogRecGetData(record);
......
...@@ -844,7 +844,7 @@ extern bool _bitmap_findvalue(Relation lovHeap, Relation lovIndex, ...@@ -844,7 +844,7 @@ extern bool _bitmap_findvalue(Relation lovHeap, Relation lovIndex,
* prototypes for functions in bitmapxlog.c * prototypes for functions in bitmapxlog.c
*/ */
extern void bitmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void bitmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void bitmap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void bitmap_desc(StringInfo buf, XLogRecord *record);
extern void bitmap_xlog_startup(void); extern void bitmap_xlog_startup(void);
extern void bitmap_xlog_cleanup(void); extern void bitmap_xlog_cleanup(void);
extern bool bitmap_safe_restartpoint(void); extern bool bitmap_safe_restartpoint(void);
......
...@@ -54,6 +54,6 @@ extern bool CLOGTransactionIsOld(TransactionId xid); ...@@ -54,6 +54,6 @@ extern bool CLOGTransactionIsOld(TransactionId xid);
#define CLOG_TRUNCATE 0x10 #define CLOG_TRUNCATE 0x10
extern void clog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void clog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void clog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void clog_desc(StringInfo buf, XLogRecord *record);
#endif /* CLOG_H */ #endif /* CLOG_H */
...@@ -81,6 +81,6 @@ extern bool DistributedLog_GetLowWaterXid( ...@@ -81,6 +81,6 @@ extern bool DistributedLog_GetLowWaterXid(
#define DISTRIBUTEDLOG_TRUNCATE 0x10 #define DISTRIBUTEDLOG_TRUNCATE 0x10
extern void DistributedLog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void DistributedLog_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void DistributedLog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void DistributedLog_desc(StringInfo buf, XLogRecord *record);
#endif /* DISTRIBUTEDLOG_H */ #endif /* DISTRIBUTEDLOG_H */
...@@ -63,7 +63,7 @@ extern void ginUpdateStats(Relation index, const GinStatsData *stats); ...@@ -63,7 +63,7 @@ extern void ginUpdateStats(Relation index, const GinStatsData *stats);
/* ginxlog.c */ /* ginxlog.c */
extern void gin_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void gin_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void gin_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void gin_desc(StringInfo buf, XLogRecord *record);
extern void gin_xlog_startup(void); extern void gin_xlog_startup(void);
extern void gin_xlog_cleanup(void); extern void gin_xlog_cleanup(void);
extern bool gin_safe_restartpoint(void); extern bool gin_safe_restartpoint(void);
......
...@@ -297,7 +297,7 @@ extern GISTInsertStack *gistFindPath(Relation r, BlockNumber child); ...@@ -297,7 +297,7 @@ extern GISTInsertStack *gistFindPath(Relation r, BlockNumber child);
/* gistxlog.c */ /* gistxlog.c */
extern void gist_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void gist_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void gist_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void gist_desc(StringInfo buf, XLogRecord *record);
extern void gist_xlog_startup(void); extern void gist_xlog_startup(void);
extern void gist_xlog_cleanup(void); extern void gist_xlog_cleanup(void);
extern void gist_mask(char *pagedata, BlockNumber blkno); extern void gist_mask(char *pagedata, BlockNumber blkno);
......
...@@ -354,6 +354,6 @@ extern OffsetNumber _hash_binsearch_last(Page page, uint32 hash_value); ...@@ -354,6 +354,6 @@ extern OffsetNumber _hash_binsearch_last(Page page, uint32 hash_value);
/* hash.c */ /* hash.c */
extern void hash_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void hash_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void hash_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void hash_desc(StringInfo buf, XLogRecord *record);
#endif /* HASH_H */ #endif /* HASH_H */
...@@ -147,12 +147,12 @@ extern void heap_restrpos(HeapScanDesc scan); ...@@ -147,12 +147,12 @@ extern void heap_restrpos(HeapScanDesc scan);
extern void heap_sync(Relation relation); extern void heap_sync(Relation relation);
extern void heap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr); extern void heap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr);
extern void heap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void heap_desc(StringInfo buf, XLogRecord *record);
extern bool heap_getrelfilenode( extern bool heap_getrelfilenode(
XLogRecord *record, XLogRecord *record,
RelFileNode *relFileNode); RelFileNode *relFileNode);
extern void heap2_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr); extern void heap2_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr);
extern void heap2_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void heap2_desc(StringInfo buf, XLogRecord *record);
extern void heap_mask(char *pagedata, BlockNumber blkno); extern void heap_mask(char *pagedata, BlockNumber blkno);
extern void log_heap_newpage(Relation rel, extern void log_heap_newpage(Relation rel,
......
...@@ -78,6 +78,6 @@ extern void multixact_twophase_postabort(TransactionId xid, uint16 info, ...@@ -78,6 +78,6 @@ extern void multixact_twophase_postabort(TransactionId xid, uint16 info,
extern void multixact_redo(XLogRecPtr beginLoc __attribute__((unused)), extern void multixact_redo(XLogRecPtr beginLoc __attribute__((unused)),
XLogRecPtr lsn __attribute__((unused)), XLogRecord *record); XLogRecPtr lsn __attribute__((unused)), XLogRecord *record);
extern void multixact_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void multixact_desc(StringInfo buf, XLogRecord *record);
#endif /* MULTIXACT_H */ #endif /* MULTIXACT_H */
...@@ -646,7 +646,7 @@ extern void _bt_leafbuild(BTSpool *btspool, BTSpool *spool2); ...@@ -646,7 +646,7 @@ extern void _bt_leafbuild(BTSpool *btspool, BTSpool *spool2);
* prototypes for functions in nbtxlog.c * prototypes for functions in nbtxlog.c
*/ */
extern void btree_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void btree_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void btree_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void btree_desc(StringInfo buf, XLogRecord *record);
extern void btree_xlog_startup(void); extern void btree_xlog_startup(void);
extern void btree_xlog_cleanup(void); extern void btree_xlog_cleanup(void);
extern bool btree_safe_restartpoint(void); extern bool btree_safe_restartpoint(void);
......
...@@ -274,7 +274,7 @@ extern void RecordDistributedForgetCommitted(struct TMGXACT_LOG *gxact_log); ...@@ -274,7 +274,7 @@ extern void RecordDistributedForgetCommitted(struct TMGXACT_LOG *gxact_log);
extern int xactGetCommittedChildren(TransactionId **ptr); extern int xactGetCommittedChildren(TransactionId **ptr);
extern void xact_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void xact_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void xact_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void xact_desc(StringInfo buf, XLogRecord *record);
extern const char *IsoLevelAsUpperString(int IsoLevel); extern const char *IsoLevelAsUpperString(int IsoLevel);
#endif /* XACT_H */ #endif /* XACT_H */
...@@ -314,7 +314,7 @@ extern XLogRecPtr XLogSaveBufferForHint(Buffer buffer); ...@@ -314,7 +314,7 @@ extern XLogRecPtr XLogSaveBufferForHint(Buffer buffer);
extern void RestoreBkpBlocks(XLogRecPtr lsn, XLogRecord *record, bool cleanup); extern void RestoreBkpBlocks(XLogRecPtr lsn, XLogRecord *record, bool cleanup);
extern void xlog_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribute__((unused)), XLogRecord *record); extern void xlog_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribute__((unused)), XLogRecord *record);
extern void xlog_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void xlog_desc(StringInfo buf, XLogRecord *record);
extern void issue_xlog_fsync(int fd, uint32 log, uint32 seg); extern void issue_xlog_fsync(int fd, uint32 log, uint32 seg);
......
...@@ -254,7 +254,7 @@ typedef struct RmgrData ...@@ -254,7 +254,7 @@ typedef struct RmgrData
{ {
const char *rm_name; const char *rm_name;
void (*rm_redo) (XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr); void (*rm_redo) (XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr);
void (*rm_desc) (StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); void (*rm_desc) (StringInfo buf, XLogRecord *record);
void (*rm_startup) (void); void (*rm_startup) (void);
void (*rm_cleanup) (void); void (*rm_cleanup) (void);
bool (*rm_safe_restartpoint) (void); bool (*rm_safe_restartpoint) (void);
......
...@@ -38,6 +38,6 @@ extern void PostPrepare_smgr(void); ...@@ -38,6 +38,6 @@ extern void PostPrepare_smgr(void);
extern void log_smgrcreate(RelFileNode *rnode, ForkNumber forkNum); extern void log_smgrcreate(RelFileNode *rnode, ForkNumber forkNum);
extern void smgr_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void smgr_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void smgr_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void smgr_desc(StringInfo buf, XLogRecord *record);
#endif /* STORAGE_H */ #endif /* STORAGE_H */
...@@ -400,7 +400,7 @@ typedef struct ...@@ -400,7 +400,7 @@ typedef struct
} xl_ao_truncate; } xl_ao_truncate;
extern void appendonly_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void appendonly_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void appendonly_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void appendonly_desc(StringInfo buf, XLogRecord *record);
extern void appendonly_update_finish(AppendOnlyUpdateDesc aoUpdateDesc); extern void appendonly_update_finish(AppendOnlyUpdateDesc aoUpdateDesc);
......
...@@ -63,7 +63,7 @@ extern Oid get_database_oid(const char *dbname, bool missingok); ...@@ -63,7 +63,7 @@ extern Oid get_database_oid(const char *dbname, bool missingok);
extern char *get_database_name(Oid dbid); extern char *get_database_name(Oid dbid);
extern void dbase_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribute__((unused)), XLogRecord *rptr); extern void dbase_redo(XLogRecPtr beginLoc __attribute__((unused)), XLogRecPtr lsn __attribute__((unused)), XLogRecord *rptr);
extern void dbase_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void dbase_desc(StringInfo buf, XLogRecord *record);
extern void check_encoding_locale_matches(int encoding, const char *collate, const char *ctype); extern void check_encoding_locale_matches(int encoding, const char *collate, const char *ctype);
......
...@@ -80,7 +80,7 @@ extern void AlterSequence(AlterSeqStmt *stmt); ...@@ -80,7 +80,7 @@ extern void AlterSequence(AlterSeqStmt *stmt);
extern void ResetSequence(Oid seq_relid); extern void ResetSequence(Oid seq_relid);
extern void seq_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr); extern void seq_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr);
extern void seq_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void seq_desc(StringInfo buf, XLogRecord *record);
/* /*
* CDB: nextval entry point called by sequence server * CDB: nextval entry point called by sequence server
......
...@@ -59,7 +59,7 @@ extern char *get_tablespace_name(Oid spc_oid); ...@@ -59,7 +59,7 @@ extern char *get_tablespace_name(Oid spc_oid);
extern bool directory_is_empty(const char *path); extern bool directory_is_empty(const char *path);
extern void tblspc_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr); extern void tblspc_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *rptr);
extern void tblspc_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void tblspc_desc(StringInfo buf, XLogRecord *record);
extern void set_short_version(const char *path); extern void set_short_version(const char *path);
#endif /* TABLESPACE_H */ #endif /* TABLESPACE_H */
...@@ -81,7 +81,7 @@ typedef struct xl_running_xacts ...@@ -81,7 +81,7 @@ typedef struct xl_running_xacts
/* Recovery handlers for the Standby Rmgr (RM_STANDBY_ID) */ /* Recovery handlers for the Standby Rmgr (RM_STANDBY_ID) */
extern void standby_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void standby_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void standby_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void standby_desc(StringInfo buf, XLogRecord *record);
/* /*
* Declarations for GetRunningTransactionData(). Similar to Snapshots, but * Declarations for GetRunningTransactionData(). Similar to Snapshots, but
......
...@@ -57,6 +57,6 @@ extern void RelationMapInitializePhase2(void); ...@@ -57,6 +57,6 @@ extern void RelationMapInitializePhase2(void);
extern void RelationMapInitializePhase3(void); extern void RelationMapInitializePhase3(void);
extern void relmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record); extern void relmap_redo(XLogRecPtr beginLoc, XLogRecPtr lsn, XLogRecord *record);
extern void relmap_desc(StringInfo buf, XLogRecPtr beginLoc, XLogRecord *record); extern void relmap_desc(StringInfo buf, XLogRecord *record);
#endif /* RELMAPPER_H */ #endif /* RELMAPPER_H */
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册