diff options
| -rw-r--r-- | src/backend/replication/walsender.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index 44ce6240d7c..0d35e77fc17 100644 --- a/src/backend/replication/walsender.c +++ b/src/backend/replication/walsender.c @@ -1072,9 +1072,6 @@ WalSndWriteData(LogicalDecodingContext *ctx, XLogRecPtr lsn, TransactionId xid, TimestampTz now; int64 now_int; - /* output previously gathered data in a CopyData packet */ - pq_putmessage_noblock('d', ctx->out->data, ctx->out->len); - /* * Fill the send timestamp last, so that it is taken as late as possible. * This is somewhat ugly, but the protocol's set as it's already used for @@ -1087,6 +1084,9 @@ WalSndWriteData(LogicalDecodingContext *ctx, XLogRecPtr lsn, TransactionId xid, memcpy(&ctx->out->data[1 + sizeof(int64) + sizeof(int64)], tmpbuf.data, sizeof(int64)); + /* output previously gathered data in a CopyData packet */ + pq_putmessage_noblock('d', ctx->out->data, ctx->out->len); + CHECK_FOR_INTERRUPTS(); /* Try to flush pending output to the client */ |