|
30 | 30 | #include "utils/memutils.h"
|
31 | 31 | #endif
|
32 | 32 |
|
33 |
| -static bool allocate_recordbuf(XLogReaderState *state, uint32 reclength); |
34 | 33 |
|
| 34 | +static void report_invalid_record(XLogReaderState *state, const char *fmt,...) |
| 35 | + pg_attribute_printf(2, 3); |
| 36 | +static bool allocate_recordbuf(XLogReaderState *state, uint32 reclength); |
| 37 | +static int ReadPageInternal(XLogReaderState *state, XLogRecPtr pageptr, |
| 38 | + int reqLen); |
| 39 | +static void XLogReaderInvalReadState(XLogReaderState *state); |
35 | 40 | static bool ValidXLogRecordHeader(XLogReaderState *state, XLogRecPtr RecPtr,
|
36 | 41 | XLogRecPtr PrevRecPtr, XLogRecord *record, bool randAccess);
|
37 | 42 | static bool ValidXLogRecord(XLogReaderState *state, XLogRecord *record,
|
38 | 43 | XLogRecPtr recptr);
|
39 |
| -static int ReadPageInternal(XLogReaderState *state, XLogRecPtr pageptr, |
40 |
| - int reqLen); |
41 |
| -static void report_invalid_record(XLogReaderState *state, const char *fmt,...) pg_attribute_printf(2, 3); |
42 |
| - |
43 | 44 | static void ResetDecoder(XLogReaderState *state);
|
44 | 45 |
|
45 | 46 | /* size of the buffer allocated for error message. */
|
@@ -621,7 +622,7 @@ ReadPageInternal(XLogReaderState *state, XLogRecPtr pageptr, int reqLen)
|
621 | 622 | /*
|
622 | 623 | * Invalidate the xlogreader's read state to force a re-read.
|
623 | 624 | */
|
624 |
| -void |
| 625 | +static void |
625 | 626 | XLogReaderInvalReadState(XLogReaderState *state)
|
626 | 627 | {
|
627 | 628 | state->readSegNo = 0;
|
|
0 commit comments