Fix typo in ReorderBufferIterTXNInit().

tglsfdc · tglsfdc · commit f8c58554db48 · 2016-06-30T12:37:02.000-04:00
This looks like it would cause changes from subtransactions to be missed
by the iterator being constructed, if those changes had been spilled to
disk previously.  This implies that large subtransactions might be lost
(in whole or in part) by logical replication.  Found and fixed by
Petru-Florin Mihancea, per bug #14208.

Report: &lt;20160622144830.5791.22512@wrigleys.postgresql.org&gt;
diff --git a/src/backend/replication/logical/reorderbuffer.c b/src/backend/replication/logical/reorderbuffer.c
@@ -960,7 +960,7 @@ ReorderBufferIterTXNInit(ReorderBuffer *rb, ReorderBufferTXN *txn)
 		{
 			ReorderBufferChange *cur_change;
 
-			if (txn->nentries != txn->nentries_mem)
+			if (cur_txn->nentries != cur_txn->nentries_mem)
 				ReorderBufferRestoreChanges(rb, cur_txn,
 											&state->entries[off].fd,
 											&state->entries[off].segno);

Original file line number	Diff line number	Diff line change
`@@ -960,7 +960,7 @@ ReorderBufferIterTXNInit(ReorderBuffer rb, ReorderBufferTXN txn)`
`960`	`960`	`{`
`961`	`961`	`ReorderBufferChange *cur_change;`
`962`	`962`
`963`		`- if (txn->nentries != txn->nentries_mem)`
	`963`	`+ if (cur_txn->nentries != cur_txn->nentries_mem)`
`964`	`964`	`ReorderBufferRestoreChanges(rb, cur_txn,`
`965`	`965`	`&state->entries[off].fd,`
`966`	`966`	`&state->entries[off].segno);`