@@ -2394,6 +2394,8 @@ process_block_change(ForkNumber forknum, RelFileNode rnode, BlockNumber blkno)
2394
2394
/*
2395
2395
* Stop WAL streaming if current 'xlogpos' exceeds 'stop_backup_lsn', which is
2396
2396
* set by pg_stop_backup().
2397
+ *
2398
+ * TODO: Add streamed file to file list when segment is finished
2397
2399
*/
2398
2400
static bool
2399
2401
stop_streaming (XLogRecPtr xlogpos , uint32 timeline , bool segment_finished )
@@ -2499,7 +2501,11 @@ StreamLog(void *arg)
2499
2501
ctl .sysidentifier = NULL ;
2500
2502
2501
2503
#if PG_VERSION_NUM >= 100000
2502
- ctl .walmethod = CreateWalDirectoryMethod (stream_arg -> basedir , 0 , true);
2504
+ ctl .walmethod = CreateWalDirectoryMethod (
2505
+ stream_arg -> basedir ,
2506
+ // (instance_config.compress_alg == NONE_COMPRESS) ? 0 : instance_config.compress_level,
2507
+ 0 ,
2508
+ true);
2503
2509
ctl .replication_slot = replication_slot ;
2504
2510
ctl .stop_socket = PGINVALID_SOCKET ;
2505
2511
#if PG_VERSION_NUM >= 100000 && PG_VERSION_NUM < 110000
@@ -2509,6 +2515,8 @@ StreamLog(void *arg)
2509
2515
ctl .basedir = (char * ) stream_arg -> basedir ;
2510
2516
#endif
2511
2517
2518
+ ctl .do_sync = false; /* We sync all files at the end of backup */
2519
+ // ctl.mark_done /* for future use in s3 */
2512
2520
ctl .stream_stop = stop_streaming ;
2513
2521
ctl .standby_message_timeout = standby_message_timeout ;
2514
2522
ctl .partial_suffix = NULL ;
0 commit comments