diff options
| author | Tomas Vondra <tomas.vondra@postgresql.org> | 2022-03-07 20:53:16 +0100 |
|---|---|---|
| committer | Tomas Vondra <tomas.vondra@postgresql.org> | 2022-03-07 20:53:16 +0100 |
| commit | d5ed9da41d96988d905b49bebb273a9b2d6e2915 (patch) | |
| tree | c20f8bdfaba0f53eb6fd41630d001447fc2aff01 /src/backend/replication/logical/decode.c | |
| parent | 25751f54b8e02a8fff62e9dbdbc9f2efbb4e8dc1 (diff) | |
| download | postgresql-d5ed9da41d96988d905b49bebb273a9b2d6e2915.tar.gz postgresql-d5ed9da41d96988d905b49bebb273a9b2d6e2915.zip | |
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
Diffstat (limited to 'src/backend/replication/logical/decode.c')
| -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 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. |