Commitd582627

committed

cleanup xlogreader in SwitchThreadtoNextWal so we don't need to seek back

1 parent81f1ed2 commitd582627Copy full SHA for d582627

File tree

-4

lines changed

-4

lines changed

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -1461,10 +1461,7 @@ XLogThreadWorker(void *arg)`
`1461`	`1461`	`*/`
`1462`	`1462`	`strncmp(errormsg,"missing contrecord",18)==0))`
`1463`	`1463`	`{`
`1464`		`-if (SwitchThreadToNextWal(xlogreader,thread_arg))`
`1465`		`-continue;`
`1466`		`-else`
`1467`		`-break;`
	`1464`	`+continue;`
`1468`	`1465`	`}`
`1469`	`1466`
`1470`	`1467`	`/*`
`@@ -1649,6 +1646,8 @@ SwitchThreadToNextWal(XLogReaderState xlogreader, xlog_thread_arg arg)`
`1649`	`1646`	`PrintXLogCorruptionMsg(reader_data,ERROR);`
`1650`	`1647`	`}`
`1651`	`1648`	`arg->startpoint=found;`
	`1649`	`+/* Reset xlog reader therefore we don't have to seek back */`
	`1650`	`+CleanupXLogPageRead(xlogreader);`
`1652`	`1651`
`1653`	`1652`	`elog(VERBOSE,"Thread [%d]: Switched to LSN %X/%X",`
`1654`	`1653`	`reader_data->thread_num,`

Comments

(0)