diff options
| author | Tomas Vondra | 2022-03-07 19:53:16 +0000 |
|---|---|---|
| committer | Tomas Vondra | 2022-03-07 19:53:16 +0000 |
| commit | d5ed9da41d96988d905b49bebb273a9b2d6e2915 (patch) | |
| tree | c20f8bdfaba0f53eb6fd41630d001447fc2aff01 | |
| parent | 25751f54b8e02a8fff62e9dbdbc9f2efbb4e8dc1 (diff) | |
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
| -rw-r--r-- | src/backend/replication/logical/decode.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/backend/replication/logical/decode.c b/src/backend/replication/logical/decode.c index 18cf931822..8c00a73cb9 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. |