/dports/databases/postgresql14-server/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql13-server/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 693 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 737 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 738 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 761 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 762 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 763 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 764 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 794 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-client/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 693 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 737 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 738 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 761 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 762 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 763 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 764 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 794 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql14-docs/postgresql-14.1/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 831 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 832 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 877 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1115 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1131 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1143 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 690 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 734 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 735 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 758 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 759 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 760 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 761 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 790 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql13-docs/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
H A D | xlogutils.c | 693 state->segcxt.ws_segsize + state->segoff); in XLogReadDetermineTimeline() 737 ((wantPage + wantLength) / state->segcxt.ws_segsize) < in XLogReadDetermineTimeline() 738 (state->currTLIValidUntil / state->segcxt.ws_segsize)) in XLogReadDetermineTimeline() 761 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * in XLogReadDetermineTimeline() 762 state->segcxt.ws_segsize - 1; in XLogReadDetermineTimeline() 763 Assert(wantPage / state->segcxt.ws_segsize == in XLogReadDetermineTimeline() 764 endOfSegment / state->segcxt.ws_segsize); in XLogReadDetermineTimeline() 794 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize); in wal_segment_open()
|
/dports/databases/postgresql13-client/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in getInstruction() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in translateRegister() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) [all …]
|
H A D | xlogutils.c | 693 state->segcxt.ws_segsize + state->segoff); 737 ((wantPage + wantLength) / state->segcxt.ws_segsize) < 738 (state->currTLIValidUntil / state->segcxt.ws_segsize)) 761 endOfSegment = ((wantPage / state->segcxt.ws_segsize) + 1) * 762 state->segcxt.ws_segsize - 1; 763 Assert(wantPage / state->segcxt.ws_segsize == 764 endOfSegment / state->segcxt.ws_segsize); 794 XLogFilePath(path, tli, nextSegNo, state->segcxt.ws_segsize);
|
/dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
/dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|
/dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/access/transam/ |
H A D | xlogreader.c | 223 segcxt->ws_segsize = segsize; in WALOpenSegmentInit() 565 state->EndRecPtr += state->segcxt.ws_segsize - 1; in XLogReadRecord() 622 XLByteToSeg(pageptr, targetSegNo, state->segcxt.ws_segsize); in ReadPageInternal() 623 targetPageOff = XLogSegmentOffset(pageptr, state->segcxt.ws_segsize); in ReadPageInternal() 834 XLByteToSeg(recptr, segno, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 835 offset = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in XLogReaderValidatePageHeader() 880 else if (longhdr->xlp_seg_size != state->segcxt.ws_segsize) in XLogReaderValidatePageHeader() 1118 startoff = XLogSegmentOffset(recptr, state->segcxt.ws_segsize); in WALRead() 1134 XLByteToSeg(recptr, nextSegNo, state->segcxt.ws_segsize); in WALRead() 1146 if (nbytes > (state->segcxt.ws_segsize - startoff)) in WALRead() [all …]
|