Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit e912319

Browse files
committed
Fix incorrect variable types for origin IDs in decode.c
These variables used XLogRecPtr instead of RepOriginId. Author: Masahiko Sawada Discussion: https://postgr.es/m/CAD21AoBm-vNyBSXGp4bmJGvhr=S-EGc5q1dtV70cFTcJvLhC=Q@mail.gmail.com Backpatch-through: 14
1 parent bfcf1b3 commit e912319

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/backend/replication/logical/decode.c

+2-2
Original file line numberDiff line numberDiff line change
@@ -714,7 +714,7 @@ DecodePrepare(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
714714
SnapBuild *builder = ctx->snapshot_builder;
715715
XLogRecPtr origin_lsn = parsed->origin_lsn;
716716
TimestampTz prepare_time = parsed->xact_time;
717-
XLogRecPtr origin_id = XLogRecGetOrigin(buf->record);
717+
RepOriginId origin_id = XLogRecGetOrigin(buf->record);
718718
int i;
719719
TransactionId xid = parsed->twophase_xid;
720720

@@ -790,7 +790,7 @@ DecodeAbort(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
790790
int i;
791791
XLogRecPtr origin_lsn = InvalidXLogRecPtr;
792792
TimestampTz abort_time = parsed->xact_time;
793-
XLogRecPtr origin_id = XLogRecGetOrigin(buf->record);
793+
RepOriginId origin_id = XLogRecGetOrigin(buf->record);
794794
bool skip_xact;
795795

796796
if (parsed->xinfo & XACT_XINFO_HAS_ORIGIN)

0 commit comments

Comments
 (0)