test/he3pg
1
0
Fork 0
mirror of https://gitee.com/he3db/he3pg.git synced 2024-11-29 18:58:35 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

!188 fix: #I7H9RH

Browse Source 
Merge pull request !188 from wangyao/dev_performance
This commit is contained in:
shenzhengntu 2023-07-03 12:07:28 +00:00 committed by Gitee
commit 5c92c23dcd
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/access/transam/pagehashqueue.c
View File

@ -405,8 +405,9 @@ CleanLogIndexMain(int argc, char *argv[])
}
if (PrevPushPoint != 0) {
XLogRecPtr lastReplPtr = GetXLogReplayRecPtr(NULL);
// elog(LOG, "deal page from %x to %x", PrevPushPoint, lastReplPtr);
TagNode *tagList = GetBufTagByLsnRange(PrevPushPoint,lastReplPtr-1);
if (tagList->next != NULL && tagList->tag.lsn > PrevPushPoint) {
if (tagList->next != NULL && tagList->tag.lsn >= PrevPushPoint) {
LastPushPoint = tagList->tag.lsn;
TagNode *next = tagList->next;
int pageNum = 0;

6
src/backend/storage/lmgr/he3db_logindex.c
View File

@ -592,8 +592,12 @@ TagNode *GetBufTagByLsnRange(XLogRecPtr start_lsn, XLogRecPtr end_lsn)
XLogRecPtr page_max_lsn;
// Prevent metadata changes during discovery.
// TODO change to Lightweight Lock
// change to Lightweight Lock
head_node = InitTagNode();
if (end_lsn < start_lsn)
{
return head_node;
}
LWLockAcquire(LogIndexMemListLock,LW_SHARED);
tbl_index = log_index_mem_list->table_start_index;
while(tbl_index != log_index_mem_list->active_table_index)