Skip to content

Commit facada7

Browse files
committed
Throw an error if WAL file is from different database system. Fix: add this check for all wal readers
1 parent 321aa42 commit facada7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/parsexlog.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,9 +149,9 @@ doExtractPageMap(void *arg)
149149

150150
private_data = &extract_arg->private_data;
151151
xlogreader = XLogReaderAllocate(&SimpleXLogPageRead, private_data);
152-
xlogreader->system_identifier = system_identifier;
153152
if (xlogreader == NULL)
154153
elog(ERROR, "out of memory");
154+
xlogreader->system_identifier = system_identifier;
155155

156156
found = XLogFindNextRecord(xlogreader, extract_arg->startpoint);
157157

@@ -870,6 +870,7 @@ InitXLogPageRead(XLogPageReadPrivate *private_data, const char *archivedir,
870870
xlogreader = XLogReaderAllocate(&SimpleXLogPageRead, private_data);
871871
if (xlogreader == NULL)
872872
elog(ERROR, "out of memory");
873+
xlogreader->system_identifier = system_identifier;
873874
}
874875

875876
return xlogreader;

0 commit comments

Comments
 (0)