@@ -151,6 +151,11 @@ do_backup_database(parray *backup_list, pgBackupOption bkupopt)
151151if (current .backup_mode != BACKUP_MODE_DIFF_PTRACK && !disable_ptrack_clear )
152152pg_ptrack_clear ();
153153
154+ /* notify start of backup to PostgreSQL server */
155+ time2iso (label ,lengthof (label ),current .start_time );
156+ strncat (label ," with pg_arman" ,lengthof (label ));
157+ pg_start_backup (label ,smooth_checkpoint ,& current );
158+
154159/* start stream replication */
155160if (stream_wal )
156161{
@@ -160,11 +165,6 @@ do_backup_database(parray *backup_list, pgBackupOption bkupopt)
160165pthread_create (& stream_thread ,NULL , (void * (* )(void * ))StreamLog ,dst_backup_path );
161166}
162167
163- /* notify start of backup to PostgreSQL server */
164- time2iso (label ,lengthof (label ),current .start_time );
165- strncat (label ," with pg_arman" ,lengthof (label ));
166- pg_start_backup (label ,smooth_checkpoint ,& current );
167-
168168if (!from_replica )
169169{
170170/* If backup_label does not exist in $PGDATA, stop taking backup */
@@ -1435,10 +1435,15 @@ StreamLog(void *arg)
14351435if (!RunIdentifySystem (conn ,NULL ,& starttli ,& startpos ,NULL ))
14361436disconnect_and_exit (1 );
14371437
1438+ /*
1439+ * We must use startpos as start_lsn from start_backup
1440+ */
1441+ startpos = current .start_lsn ;
14381442
14391443/*
14401444 * Always start streaming at the beginning of a segment
14411445 */
1446+
14421447startpos -= startpos %XLOG_SEG_SIZE ;
14431448
14441449/*