Commit698932b

authored and

committed

Fix bug in MtmUpdateLsnMapping

1 parent599262c commit698932bCopy full SHA for 698932b

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -2491,8 +2491,8 @@ void MtmUpdateLsnMapping(int node_id, XLogRecPtr end_lsn)`
`2491`	`2491`	`flushpos=dlist_container(MtmFlushPosition,node,iter.cur);`
`2492`	`2492`	`if (flushpos->local_end <=local_flush)`
`2493`	`2493`	`{`
`2494`		`-if (Mtm->nodes[node_id-1].flushPos<local_flush) {`
`2495`		`-Mtm->nodes[node_id-1].flushPos=local_flush;`
	`2494`	`+if (Mtm->nodes[node_id-1].flushPos<flushpos->remote_end) {`
	`2495`	`+Mtm->nodes[node_id-1].flushPos=flushpos->remote_end;`
`2496`	`2496`	`}`
`2497`	`2497`	`dlist_delete(iter.cur);`
`2498`	`2498`	`pfree(flushpos);`

Comments

(0)