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

slock

Browse Source
This commit is contained in:
zoujia 2023-05-19 15:57:58 +08:00
parent 83ba25ac3d
commit cc872c74e4
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3814,17 +3814,17 @@ mustflush:
int bRelativeOffset = 0;
int eRelativeOffset = 0;
SpinLockAcquire(&XLogCtl->info_lck);
XLogParralFlush flushInfo = XLogCtl->LogFlush;
SpinLockRelease(&XLogCtl->info_lck);
// SpinLockAcquire(&XLogCtl->info_lck);
// XLogParralFlush flushInfo = XLogCtl->LogFlush;
// SpinLockRelease(&XLogCtl->info_lck);
// printf("end flush wals, begin %d, curLoc %d, WriteRqst.Write %ld\n", flushInfo.begin, curLoc, WriteRqst.Write);
while (flushInfo.begin < curLoc)
while (XlogCtl.LogFlush.begin < curLoc)
{
pg_usleep(20L);
SpinLockAcquire(&XLogCtl->info_lck);
flushInfo = XLogCtl->LogFlush;
SpinLockRelease(&XLogCtl->info_lck);
// SpinLockAcquire(&XLogCtl->info_lck);
// flushInfo = XLogCtl->LogFlush;
// SpinLockRelease(&XLogCtl->info_lck);
}
/*