postgres.git / summary / log / commit / refs
commit d5ed9da41d96988d905b49bebb273a9b2d6e2915
Author: Tomas Vondra <tomas.vondra@postgresql.org>
Date: Mon Mar 07 19:53:16 2022 +0000
First released in: 15.0
Call ReorderBufferProcessXid from sequence_decode
Commit 0da92dc530c added sequence_decode() implementing logical decoding
of sequences, but it failed to call ReorderBufferProcessXid() as it
should. So add the missing call.
Reported-by: Amit Kapila
Discussion: https://postgr.es/m/CAA4eK1KGn6cQqJEsubOOENwQOANsExiV2sKL52r4U10J8NJEMQ%40mail.gmail.com
src/backend/replication/logical/decode.c | 2 ++
1 file changed, 2 insertions(+)
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c
index 18cf9318221..8c00a73cb9f 100644
--- a/src/backend/replication/logical/decode.c
+++ b/src/backend/replication/logical/decode.c
@@ -1321,6 +1321,8 @@ sequence_decode(LogicalDecodingContext *ctx, XLogRecordBuffer *buf)
if (info != XLOG_SEQ_LOG)
elog(ERROR, "unexpected RM_SEQ_ID record type: %u", info);
+ ReorderBufferProcessXid(ctx->reorder, XLogRecGetXid(r), buf->origptr);
+
/*
* If we don't have snapshot or we are just fast-forwarding, there is no
* point in decoding messages.
[parent: 25751f54b8e0]