test/he3pg
1
0
Fork 0
mirror of https://gitee.com/he3db/he3pg.git synced 2024-12-02 04:07:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add DelRangeWals api

Browse Source 
Signed-off-by: shipixian <shipixian_yewu@cmss.chinamobile.com>
This commit is contained in:
shipixian 2023-05-04 17:13:58 +08:00
parent 41625f37ac
commit 801bd35ee7
3 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/storage/smgr/md.c
View File

@ -683,7 +683,7 @@ void mdread(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,
pageKey.blkNo = blocknum;
pageKey.pageLsn = PageGetLSN(buffer);
pageKey.replyLsn = 0;
ReceivePageFromDataBuffer(&pageKey, (uin8_t *)buffer);
ReceivePageFromDataBuffer(&pageKey, (uint8_t *)buffer);
}
}

1
src/include/utils/backend_status.h
View File

@ -10,6 +10,7 @@
#ifndef BACKEND_STATUS_H
#define BACKEND_STATUS_H
#include "access/xlogdefs.h"
#include "datatype/timestamp.h"
#include "libpq/pqcomm.h"
#include "miscadmin.h" /* for BackendType */

1
src/include/utils/hfs.h
View File

@ -80,6 +80,7 @@ extern Bufrd ReadWalsByPage(uint32_t dbid,
extern void InsertConsistToKV(uint64_t lsn);
extern uint64_t GetConsistLsn(uint64_t lsn);
extern void DelConsistLsns(uint64_t lsn);
extern void DelRangeWals(uint32_t timeline, uint64_t startPtr,uint64_t endPtr);
//extern void ReceivePageFromDataBuffer(PageKey *pk, uint8_t *buffer); //when evict one page out databuffer, we should call this to store the page.
extern uint8_t EvictOnePageOutOfMemory(PageKey pageKey, char *value);