Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commitecf0a7d

Browse files
committed
[PBCKP-434] prefer to RunXLogThreads with consistent_read=true
I doubt 'false' is ever usable.
1 parentbed69c3 commitecf0a7d

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

‎src/parsexlog.c

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,7 @@ extractPageMap(const char *archivedir, uint32 wal_seg_size,
245245
/* easy case */
246246
extract_isok=RunXLogThreads(archivedir,0,InvalidTransactionId,
247247
InvalidXLogRecPtr,end_tli,wal_seg_size,
248-
startpoint,endpoint,false,extractPageInfo,
248+
startpoint,endpoint,true,extractPageInfo,
249249
NULL);
250250
else
251251
{
@@ -330,7 +330,7 @@ extractPageMap(const char *archivedir, uint32 wal_seg_size,
330330
extract_isok=RunXLogThreads(archivedir,0,InvalidTransactionId,
331331
InvalidXLogRecPtr,tmp_interval->tli,wal_seg_size,
332332
tmp_interval->begin_lsn,tmp_interval->end_lsn,
333-
false,extractPageInfo,NULL);
333+
true,extractPageInfo,NULL);
334334
if (!extract_isok)
335335
break;
336336

@@ -359,7 +359,7 @@ validate_backup_wal_from_start_to_stop(pgBackup *backup,
359359
got_endpoint=RunXLogThreads(archivedir,0,InvalidTransactionId,
360360
InvalidXLogRecPtr,tli,xlog_seg_size,
361361
backup->start_lsn,backup->stop_lsn,
362-
false,NULL,NULL);
362+
true,NULL,NULL);
363363

364364
if (!got_endpoint)
365365
{
@@ -1161,6 +1161,11 @@ XLogThreadWorker(void *arg)
11611161
elog(ERROR,"Thread [%d]: out of memory",reader_data->thread_num);
11621162
xlogreader->system_identifier=instance_config.system_identifier;
11631163

1164+
elog(LOG,"Thread [%d]: Starting LSN: %X/%X , end: %X/%X",
1165+
reader_data->thread_num,
1166+
(uint32) (thread_arg->startpoint >>32), (uint32) (thread_arg->startpoint),
1167+
(uint32) (thread_arg->endpoint >>32), (uint32) (thread_arg->endpoint));
1168+
11641169
found=XLogFindNextRecord(xlogreader,thread_arg->startpoint);
11651170

11661171
/*
@@ -1190,11 +1195,6 @@ XLogThreadWorker(void *arg)
11901195

11911196
thread_arg->startpoint=found;
11921197

1193-
elog(VERBOSE,"Thread [%d]: Starting LSN: %X/%X",
1194-
reader_data->thread_num,
1195-
(uint32) (thread_arg->startpoint >>32),
1196-
(uint32) (thread_arg->startpoint));
1197-
11981198
while (need_read)
11991199
{
12001200
XLogRecord*record;

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp