prepared.out should look like that

kelvich · kelvich · commit 3964400cbb4f · 2017-03-27T22:59:18.000+03:00
diff --git a/contrib/test_decoding/expected/prepared.out b/contrib/test_decoding/expected/prepared.out
@@ -91,6 +91,7 @@ SELECT data FROM pg_logical_slot_peek_changes('regression_slot', NULL, NULL, 'in
  BEGIN
  table public.test_prepared2: INSERT: id[integer]:7
  COMMIT
+ COMMIT PREPARED 'test_prepared#3'
  BEGIN
  table public.test_prepared1: INSERT: id[integer]:8 data[text]:null
  COMMIT
diff --git a/src/backend/replication/logical/reorderbuffer.c b/src/backend/replication/logical/reorderbuffer.c
@@ -1719,6 +1719,8 @@ ReorderBufferPrepare(ReorderBuffer *rb, TransactionId xid,
 	txn->prepared = true;
 	strcpy(txn->gid, gid);
 
+	fprintf(stderr, "ReorderBufferPrepare xid = %d, found = %d\n", xid, txn == NULL ? 42 : txn->prepared);
+
 	ReorderBufferCommitInternal(txn, rb, xid, commit_lsn, end_lsn,
 										commit_time, origin_id, origin_lsn);
 }
@@ -1735,6 +1737,8 @@ ReorderBufferTxnIsPrepared(ReorderBuffer *rb, TransactionId xid)
 	txn = ReorderBufferTXNByXid(rb, xid, false, NULL, InvalidXLogRecPtr,
 								false);
 
+	fprintf(stderr, "ReorderBufferTxnIsPrepared xid = %d, found = %d\n", xid, txn == NULL ? 42 : txn->prepared);
+
 	return txn == NULL ? true : txn->prepared;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -1719,6 +1719,8 @@ ReorderBufferPrepare(ReorderBuffer *rb, TransactionId xid,`
`1719`	`1719`	`txn->prepared = true;`
`1720`	`1720`	`strcpy(txn->gid, gid);`
`1721`	`1721`
	`1722`	`+ fprintf(stderr, "ReorderBufferPrepare xid = %d, found = %d\n", xid, txn == NULL ? 42 : txn->prepared);`
	`1723`	`+`
`1722`	`1724`	`ReorderBufferCommitInternal(txn, rb, xid, commit_lsn, end_lsn,`
`1723`	`1725`	`commit_time, origin_id, origin_lsn);`
`1724`	`1726`	`}`
`@@ -1735,6 +1737,8 @@ ReorderBufferTxnIsPrepared(ReorderBuffer *rb, TransactionId xid)`
`1735`	`1737`	`txn = ReorderBufferTXNByXid(rb, xid, false, NULL, InvalidXLogRecPtr,`
`1736`	`1738`	`false);`
`1737`	`1739`
	`1740`	`+ fprintf(stderr, "ReorderBufferTxnIsPrepared xid = %d, found = %d\n", xid, txn == NULL ? 42 : txn->prepared);`
	`1741`	`+`
`1738`	`1742`	`return txn == NULL ? true : txn->prepared;`
`1739`	`1743`	`}`
`1740`	`1744`