Commit71e6895

authored and

committed

[PBCKP-270] Updated wait_wal_lsn function for begin backup without wal file for streaming WAL.

1 parent8b46c8a commit71e6895Copy full SHA for 71e6895

File tree

+18

-0

lines changed

+18

-0

lines changed

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1327,6 +1327,16 @@ wait_wal_lsn(const char *wal_segment_dir, XLogRecPtr target_lsn, bool is_start_l`
`1327`	`1327`	`}`
`1328`	`1328`	`else`
`1329`	`1329`	`elog(LOG,"Found WAL segment: %s",wal_segment_path);`
	`1330`	`+`
	`1331`	`+`
	`1332`	`+/* Check current file for stream. It may be not exist in S3 */`
	`1333`	`+if (!file_exists&&segment_only&&is_start_lsn&&in_stream_dir&&try_count>1)`
	`1334`	`+{`
	`1335`	`+if(isStreamProccessed(wal_segment))`
	`1336`	`+returnInvalidXLogRecPtr;`
	`1337`	`+`
	`1338`	`+}`
	`1339`	`+`
`1330`	`1340`	`}`
`1331`	`1341`
`1332`	`1342`	`if (file_exists)`

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1222,3 +1222,9 @@ CalculateCopyStreamSleeptime(TimestampTz now, int standby_message_timeout,`
`1222`	`1222`
`1223`	`1223`	`returnsleeptime;`
`1224`	`1224`	`}`
	`1225`	`+`
	`1226`	`+`
	`1227`	`+boolisStreamProccessed(char*seg_filename)`
	`1228`	`+{`
	`1229`	`+returnstill_sending&& !strcmp(current_walfile_name,seg_filename);`
	`1230`	`+}`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,7 @@ struct WalWriteMethod`
`85`	`85`
`86`	`86`	`/* Return a text for the last error in this Walfile */`
`87`	`87`	`constchar(getlasterror) (void);`
	`88`	`+`
`88`	`89`	`};`
`89`	`90`
`90`	`91`	`/*`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1221,6 +1221,7 @@ extern XLogRecPtr wait_wal_lsn(const char *wal_segment_dir, XLogRecPtr lsn, bool`
`1221`	`1221`	`externvoidwait_wal_and_calculate_stop_lsn(constcharxlog_path,XLogRecPtrstop_lsn,pgBackupbackup);`
`1222`	`1222`	`externint64calculate_datasize_of_filelist(parray*filelist);`
`1223`	`1223`
	`1224`	`+externboolisStreamProccessed(charseg_filename);/ Checks, that this file is stream processing. File name without path. */`
`1224`	`1225`
`1225`	`1226`	`/*`
`1226`	`1227`	`* Slices and arrays for C strings`

Comments

(0)