db/pg_probackup
db/pg_probackup
1
0
Fork 0
mirror of https://github.com/postgrespro/pg_probackup.git synced 2025-02-09 14:33:17 +02:00
Code Issues Releases Activity

minor changes to log messages

Browse Source
This commit is contained in:
Grigory Smolkin 2017-11-22 17:04:46 +03:00
parent d153c26104
commit 5534b107a0
3 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/backup.c
View File

@ -867,8 +867,8 @@ do_backup(void)
current.status = BACKUP_STATUS_DONE; current.status = BACKUP_STATUS_DONE;
pgBackupWriteBackupControlFile(&current); pgBackupWriteBackupControlFile(&current);
elog(LOG, "Backup completed. Total bytes : " INT64_FORMAT "", //elog(LOG, "Backup completed. Total bytes : " INT64_FORMAT "",
current.data_bytes); // current.data_bytes);
pgBackupValidate(&current); pgBackupValidate(&current);
@ -1402,6 +1402,11 @@ wait_wal_lsn(XLogRecPtr lsn, bool wait_prev_segment)
timeout = archive_timeout; timeout = archive_timeout;
} }
if (wait_prev_segment)
elog(LOG, "Looking for segment: %s", wal_segment);
else
elog(LOG, "Looking for LSN: %X/%X in segment: %s", (uint32) (lsn >> 32), (uint32) lsn, wal_segment);
/* Wait until target LSN is archived or streamed */ /* Wait until target LSN is archived or streamed */
while (true) while (true)
{ {
@ -1409,6 +1414,7 @@ wait_wal_lsn(XLogRecPtr lsn, bool wait_prev_segment)
if (file_exists) if (file_exists)
{ {
elog(LOG, "Found segment: %s", wal_segment);
/* Do not check LSN for previous WAL segment */ /* Do not check LSN for previous WAL segment */
if (wait_prev_segment) if (wait_prev_segment)
return; return;
@ -1419,8 +1425,11 @@ wait_wal_lsn(XLogRecPtr lsn, bool wait_prev_segment)
if ((stream_wal && wal_contains_lsn(wal_dir, lsn, tli)) || if ((stream_wal && wal_contains_lsn(wal_dir, lsn, tli)) ||
(!stream_wal && wal_contains_lsn(arclog_path, lsn, tli))) (!stream_wal && wal_contains_lsn(arclog_path, lsn, tli)))
/* Target LSN was found */ /* Target LSN was found */
{
elog(LOG, "Found LSN: %X/%X", (uint32) (lsn >> 32), (uint32) lsn);
return; return;
} }
}
sleep(1); sleep(1);
if (interrupted) if (interrupted)
@ -1654,6 +1663,8 @@ pg_stop_backup(pgBackup *backup)
} }
if (!res) if (!res)
elog(ERROR, "pg_stop backup() failed"); elog(ERROR, "pg_stop backup() failed");
else
elog(INFO, "pg_stop backup() successfully executed");
} }
backup_in_progress = false; backup_in_progress = false;

2
src/data.c
View File

@ -508,7 +508,7 @@ restore_data_file(const char *from_root,
if (header.block < blknum) if (header.block < blknum)
elog(ERROR, "backup is broken at block %u", blknum); elog(ERROR, "backup is broken at block %u", blknum);
elog(VERBOSE, "file %s, header compressed size %d", file->path, header.compressed_size); //elog(VERBOSE, "file %s, header compressed size %d", file->path, header.compressed_size);
Assert(header.compressed_size <= BLCKSZ); Assert(header.compressed_size <= BLCKSZ);
read_len = fread(compressed_page.data, 1, read_len = fread(compressed_page.data, 1,

6
src/validate.c
View File

@ -51,12 +51,12 @@ pgBackupValidate(pgBackup *backup)
return; return;
} }
elog(LOG, "Validate backup %s", backup_id_string); elog(INFO, "Validating backup %s", backup_id_string);
if (backup->backup_mode != BACKUP_MODE_FULL && if (backup->backup_mode != BACKUP_MODE_FULL &&
backup->backup_mode != BACKUP_MODE_DIFF_PAGE && backup->backup_mode != BACKUP_MODE_DIFF_PAGE &&
backup->backup_mode != BACKUP_MODE_DIFF_PTRACK) backup->backup_mode != BACKUP_MODE_DIFF_PTRACK)
elog(LOG, "Invalid backup_mode of backup %s", backup_id_string); elog(INFO, "Invalid backup_mode of backup %s", backup_id_string);
pgBackupGetPath(backup, base_path, lengthof(base_path), DATABASE_DIR); pgBackupGetPath(backup, base_path, lengthof(base_path), DATABASE_DIR);
pgBackupGetPath(backup, path, lengthof(path), DATABASE_FILE_LIST); pgBackupGetPath(backup, path, lengthof(path), DATABASE_FILE_LIST);
@ -99,7 +99,7 @@ pgBackupValidate(pgBackup *backup)
if (corrupted) if (corrupted)
elog(WARNING, "Backup %s is corrupted", backup_id_string); elog(WARNING, "Backup %s is corrupted", backup_id_string);
else else
elog(LOG, "Backup %s is valid", backup_id_string); elog(INFO, "Backup %s is valid", backup_id_string);
free(backup_id_string); free(backup_id_string);
} }