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

fix bug when copy wal into walbuffer

Browse Source 
Signed-off-by: shipixian <shipixian_yewu@cmss.chinamobile.com>
This commit is contained in:
shipixian 2023-03-28 13:59:24 +08:00
parent 2311fe482a
commit 7e8e77b95f
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/access/transam/xlog.c
View File

@ -2140,9 +2140,9 @@ He3DBCopyXLogRecordToWAL(int write_len, XLogRecPtr StartPos, XLogRecPtr EndPos)
*
* 如果xlog的长度超过剩余空间，就从xlog buffer的起始地址开始复制
*/
// int XlogBufferLength = (XLOGbuffers-1) * XLOG_BLCKSZ;
// int UsedXlogBufferLength = StartPos % ((XLOGbuffers-1) * XLOG_BLCKSZ);
// int remaindXlogBufferLength = XlogBufferLength - UsedXlogBufferLength;
int XlogBufferLength = (XLOGbuffers-1) * XLOG_BLCKSZ;
int UsedXlogBufferLength = StartPos % ((XLOGbuffers-1) * XLOG_BLCKSZ);
int remaindXlogBufferLength = XlogBufferLength - UsedXlogBufferLength;
/*
* Get a pointer to the right place in the right WAL buffer to start
* inserting to.
@ -2159,6 +2159,8 @@ He3DBCopyXLogRecordToWAL(int write_len, XLogRecPtr StartPos, XLogRecPtr EndPos)
for (int i = 0; i < grouo_rec_count; i++)
{
rdata = (XLogRecData *)&groupRecData[i];
if (remaindXlogBufferLength <= 0)
currpos = XLogCtl->pages - remaindXlogBufferLength;
while (rdata != NULL)
{
char *rdata_data = rdata->data;
@ -2180,6 +2182,7 @@ He3DBCopyXLogRecordToWAL(int write_len, XLogRecPtr StartPos, XLogRecPtr EndPos)
CurrPos += rdata_len;
written += rdata_len;
remaindXlogBufferLength -= rdata_len;
rdata = rdata->next;
}
}