@@ -87,7 +87,6 @@ do_backup_instance(PGconn *backup_conn, PGNodeInfo *nodeInfo, bool no_sync, bool
87
87
{
88
88
int i ;
89
89
char external_prefix [MAXPGPATH ]; /* Temp value. Used as template */
90
- char dst_backup_path [MAXPGPATH ];
91
90
char label [1024 ];
92
91
XLogRecPtr prev_backup_start_lsn = InvalidXLogRecPtr ;
93
92
@@ -270,17 +269,19 @@ do_backup_instance(PGconn *backup_conn, PGNodeInfo *nodeInfo, bool no_sync, bool
270
269
/* start stream replication */
271
270
if (stream_wal )
272
271
{
273
- join_path_components (dst_backup_path , current .database_dir , PG_XLOG_DIR );
274
- fio_mkdir (dst_backup_path , DIR_PERMISSION , FIO_BACKUP_HOST );
272
+ char stream_xlog_path [MAXPGPATH ];
275
273
276
- start_WAL_streaming (backup_conn , dst_backup_path , & instance_config .conn_opt ,
274
+ join_path_components (stream_xlog_path , current .database_dir , PG_XLOG_DIR );
275
+ fio_mkdir (stream_xlog_path , DIR_PERMISSION , FIO_BACKUP_HOST );
276
+
277
+ start_WAL_streaming (backup_conn , stream_xlog_path , & instance_config .conn_opt ,
277
278
current .start_lsn , current .tli );
278
279
279
280
/* Make sure that WAL streaming is working
280
281
* PAGE backup in stream mode is waited twice, first for
281
282
* segment in WAL archive and then for streamed segment
282
283
*/
283
- wait_wal_lsn (current .start_lsn , true, current .tli , false, true, ERROR , true, & current );
284
+ wait_wal_lsn (current .start_lsn , true, current .tli , false, true, ERROR , true, stream_xlog_path );
284
285
}
285
286
286
287
/* initialize backup's file list */
0 commit comments