diff options
Diffstat (limited to 'src/backend/replication/walreceiverfuncs.c')
| -rw-r--r-- | src/backend/replication/walreceiverfuncs.c | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/backend/replication/walreceiverfuncs.c b/src/backend/replication/walreceiverfuncs.c index 876196f9da3..b31e964fecd 100644 --- a/src/backend/replication/walreceiverfuncs.c +++ b/src/backend/replication/walreceiverfuncs.c @@ -185,8 +185,8 @@ RequestXLogStreaming(XLogRecPtr recptr, const char *conninfo) * being created by XLOG streaming, which might cause trouble later on if * the segment is e.g archived. */ - if (recptr.xrecoff % XLogSegSize != 0) - recptr.xrecoff -= recptr.xrecoff % XLogSegSize; + if (recptr % XLogSegSize != 0) + recptr -= recptr % XLogSegSize; SpinLockAcquire(&walrcv->mutex); @@ -204,8 +204,7 @@ RequestXLogStreaming(XLogRecPtr recptr, const char *conninfo) * If this is the first startup of walreceiver, we initialize receivedUpto * and latestChunkStart to receiveStart. */ - if (walrcv->receiveStart.xlogid == 0 && - walrcv->receiveStart.xrecoff == 0) + if (walrcv->receiveStart == 0) { walrcv->receivedUpto = recptr; walrcv->latestChunkStart = recptr; |