mirror of
https://github.com/pgbackrest/pgbackrest.git
synced 2024-12-14 10:13:05 +02:00
f0250dab4b
The Perl process was exiting directly when called but that interfered with proper locking for the forked async process. Now Perl returns results to the C process which handles all errors, including signals.
745 lines
28 KiB
Perl
745 lines
28 KiB
Perl
####################################################################################################################################
|
|
# INFO MODULE
|
|
####################################################################################################################################
|
|
package pgBackRest::Info;
|
|
|
|
use strict;
|
|
use warnings FATAL => qw(all);
|
|
use Carp qw(confess);
|
|
|
|
use English '-no_match_vars';
|
|
use Exporter qw(import);
|
|
our @EXPORT = qw();
|
|
use File::Basename qw(dirname);
|
|
|
|
use pgBackRest::Backup::Common;
|
|
use pgBackRest::Backup::Info;
|
|
use pgBackRest::Common::Exception;
|
|
use pgBackRest::Common::Log;
|
|
use pgBackRest::Common::Ini;
|
|
use pgBackRest::Common::String;
|
|
use pgBackRest::Backup::Common;
|
|
use pgBackRest::Backup::Info;
|
|
use pgBackRest::Config::Config;
|
|
use pgBackRest::InfoCommon;
|
|
use pgBackRest::Manifest;
|
|
use pgBackRest::Protocol::Helper;
|
|
use pgBackRest::Protocol::Storage::Helper;
|
|
use pgBackRest::Storage::Helper;
|
|
|
|
####################################################################################################################################
|
|
# Info constants
|
|
####################################################################################################################################
|
|
use constant INFO_SECTION_BACKREST => 'backrest';
|
|
use constant INFO_SECTION_ARCHIVE => 'archive';
|
|
use constant INFO_SECTION_DB => 'database';
|
|
use constant INFO_SECTION_INFO => 'info';
|
|
use constant INFO_SECTION_REPO => 'repository';
|
|
use constant INFO_SECTION_TIMESTAMP => 'timestamp';
|
|
use constant INFO_SECTION_STATUS => 'status';
|
|
|
|
use constant INFO_STANZA_NAME => 'name';
|
|
|
|
use constant INFO_STANZA_STATUS_OK => 'ok';
|
|
use constant INFO_STANZA_STATUS_ERROR => 'error';
|
|
|
|
use constant INFO_STANZA_STATUS_OK_CODE => 0;
|
|
use constant INFO_STANZA_STATUS_OK_MESSAGE => INFO_STANZA_STATUS_OK;
|
|
use constant INFO_STANZA_STATUS_MISSING_STANZA_CODE => 1;
|
|
use constant INFO_STANZA_STATUS_MISSING_STANZA_MESSAGE => 'missing stanza path';
|
|
use constant INFO_STANZA_STATUS_NO_BACKUP_CODE => 2;
|
|
use constant INFO_STANZA_STATUS_NO_BACKUP_MESSAGE => 'no valid backups';
|
|
use constant INFO_STANZA_STATUS_MISSING_STANZA_DATA_CODE => 3;
|
|
use constant INFO_STANZA_STATUS_MISSING_STANZA_DATA_MESSAGE => 'missing stanza data';
|
|
|
|
use constant INFO_KEY_CODE => 'code';
|
|
use constant INFO_KEY_DELTA => 'delta';
|
|
use constant INFO_KEY_FORMAT => 'format';
|
|
use constant INFO_KEY_ID => INFO_HISTORY_ID;
|
|
use constant INFO_KEY_LABEL => 'label';
|
|
use constant INFO_KEY_MAX => 'max';
|
|
use constant INFO_KEY_MIN => 'min';
|
|
use constant INFO_KEY_MESSAGE => 'message';
|
|
use constant INFO_KEY_PRIOR => 'prior';
|
|
use constant INFO_KEY_REFERENCE => 'reference';
|
|
use constant INFO_KEY_SIZE => 'size';
|
|
use constant INFO_KEY_START => 'start';
|
|
use constant INFO_KEY_STOP => 'stop';
|
|
use constant INFO_KEY_SYSTEM_ID => INFO_SYSTEM_ID;
|
|
use constant INFO_KEY_TYPE => 'type';
|
|
use constant INFO_KEY_VERSION => INFO_DB_VERSION;
|
|
|
|
####################################################################################################################################
|
|
# CONSTRUCTOR
|
|
####################################################################################################################################
|
|
sub new
|
|
{
|
|
my $class = shift; # Class name
|
|
|
|
# Create the class hash
|
|
my $self = {};
|
|
bless $self, $class;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my ($strOperation) = logDebugParam(__PACKAGE__ . '->new');
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'self', value => $self}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# process
|
|
####################################################################################################################################
|
|
sub process
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my ($strOperation) = logDebugParam(__PACKAGE__ . '->process');
|
|
|
|
# Get stanza if specified
|
|
my $strStanza = cfgOptionTest(CFGOPT_STANZA) ? cfgOption(CFGOPT_STANZA) : undef;
|
|
|
|
# Get the stanza list with all info
|
|
my $oyStanzaList = $self->stanzaList($strStanza);
|
|
|
|
if (cfgOptionTest(CFGOPT_OUTPUT, CFGOPTVAL_INFO_OUTPUT_TEXT))
|
|
{
|
|
my $strOutput = $self->formatText($oyStanzaList);
|
|
|
|
if (defined($strOutput))
|
|
{
|
|
syswrite(*STDOUT, $strOutput);
|
|
}
|
|
else
|
|
{
|
|
syswrite(*STDOUT, 'No stanzas exist in ' . storageRepo()->pathGet() . ".\n");
|
|
}
|
|
}
|
|
elsif (cfgOptionTest(CFGOPT_OUTPUT, CFGOPTVAL_INFO_OUTPUT_JSON))
|
|
{
|
|
my $oJSON = JSON::PP->new()->canonical()->pretty()->indent_length(4);
|
|
$self->outputJSON($oJSON->encode($oyStanzaList));
|
|
}
|
|
else
|
|
{
|
|
confess &log(ASSERT, "invalid info output option '" . cfgOption(CFGOPT_OUTPUT) . "'");
|
|
}
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn($strOperation);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# outputJSON
|
|
###################################################################################################################################
|
|
sub outputJSON
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$strJSON,
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->outputJSON', \@_,
|
|
{name => 'strJSON'},
|
|
);
|
|
|
|
syswrite(*STDOUT, $strJSON);
|
|
|
|
# On some systems a linefeed will be appended by encode() but others will not have it. In our case there should always
|
|
# be a terminating linefeed.
|
|
if ($strJSON !~ /\n$/)
|
|
{
|
|
syswrite(*STDOUT, "\n");
|
|
}
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# formatText
|
|
#
|
|
# Format --output=text info.
|
|
####################################################################################################################################
|
|
sub formatText
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$oyStanzaList,
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->formatText', \@_,
|
|
{name => 'oyStanzaList', trace => true},
|
|
);
|
|
|
|
my $strOutput;
|
|
|
|
foreach my $oStanzaInfo (@{$oyStanzaList})
|
|
{
|
|
# Output stanza name and status
|
|
$strOutput .= (defined($strOutput) ? "\n" : '') . $self->formatTextStanza($oStanzaInfo) . "\n";
|
|
|
|
# Initialize the flag to indicate the first DB in the INFO_BACKUP_SECTION_DB is the current database
|
|
my $bDbCurrent = true;
|
|
|
|
# Loop through the DB history array for the stanza from newest to oldest
|
|
foreach my $hDbInfo (reverse @{$oStanzaInfo->{&INFO_BACKUP_SECTION_DB}})
|
|
{
|
|
if ($bDbCurrent)
|
|
{
|
|
$strOutput .= "\n db (current)";
|
|
}
|
|
|
|
# Get the archive information for the DB
|
|
my $strOutputArchive;
|
|
foreach my $hDbArchive (@{$oStanzaInfo->{&INFO_SECTION_ARCHIVE}})
|
|
{
|
|
if ($hDbArchive->{&INFO_SECTION_DB}{&INFO_HISTORY_ID} == $hDbInfo->{&INFO_HISTORY_ID})
|
|
{
|
|
# Output archive start / stop values
|
|
$strOutputArchive .= "\n wal archive min/max (" . $hDbArchive->{&INFO_KEY_ID} . "): ";
|
|
|
|
if (defined($hDbArchive->{&INFO_KEY_MIN}))
|
|
{
|
|
$strOutputArchive .= $hDbArchive->{&INFO_KEY_MIN} . ' / ' . $hDbArchive->{&INFO_KEY_MAX};
|
|
}
|
|
else
|
|
{
|
|
$strOutputArchive .= 'none present';
|
|
}
|
|
|
|
$strOutputArchive .= "\n";
|
|
}
|
|
}
|
|
|
|
# Get information for each stanza backup for the DB, from oldest to newest
|
|
my $strOutputBackup;
|
|
foreach my $oBackupInfo (@{$$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}})
|
|
{
|
|
if ($oBackupInfo->{&INFO_SECTION_DB}{&INFO_KEY_ID} == $hDbInfo->{&INFO_HISTORY_ID})
|
|
{
|
|
$strOutputBackup .= "\n" . $self->formatTextBackup($oBackupInfo) . "\n";
|
|
}
|
|
}
|
|
|
|
if (defined($strOutputArchive) || defined($strOutputBackup))
|
|
{
|
|
if (!$bDbCurrent)
|
|
{
|
|
$strOutput .= "\n db (prior)";
|
|
}
|
|
|
|
if (defined($strOutputArchive))
|
|
{
|
|
$strOutput .= $strOutputArchive;
|
|
}
|
|
|
|
if (defined($strOutputBackup))
|
|
{
|
|
$strOutput .= $strOutputBackup;
|
|
}
|
|
}
|
|
|
|
$bDbCurrent = false;
|
|
}
|
|
}
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'strOutput', value => $strOutput, trace => true}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# formatTextStanza
|
|
#
|
|
# Format --output=text stanza info.
|
|
####################################################################################################################################
|
|
sub formatTextStanza
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$oStanzaInfo,
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->formatTextStanza', \@_,
|
|
{name => 'oStanzaInfo', trace => true},
|
|
);
|
|
|
|
# Output stanza name and status
|
|
my $strOutput =
|
|
'stanza: ' . $oStanzaInfo->{&INFO_STANZA_NAME} . "\n" .
|
|
" status: " . ($oStanzaInfo->{&INFO_SECTION_STATUS}{&INFO_KEY_CODE} == 0 ? INFO_STANZA_STATUS_OK :
|
|
INFO_STANZA_STATUS_ERROR . ' (' . $oStanzaInfo->{&INFO_SECTION_STATUS}{&INFO_KEY_MESSAGE} . ')');
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'strOutput', value => $strOutput, trace => true}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# formatTextBackup
|
|
#
|
|
# Format --output=text backup info.
|
|
####################################################################################################################################
|
|
sub formatTextBackup
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$oBackupInfo,
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->formatTextBackup', \@_,
|
|
{name => 'oBackupInfo', trace => true},
|
|
);
|
|
|
|
my $strOutput =
|
|
' ' . $$oBackupInfo{&INFO_KEY_TYPE} . ' backup: ' . $$oBackupInfo{&INFO_KEY_LABEL} . "\n" .
|
|
|
|
' timestamp start/stop: ' .
|
|
timestampFormat(undef, $$oBackupInfo{&INFO_SECTION_TIMESTAMP}{&INFO_KEY_START}) .
|
|
' / ' .
|
|
timestampFormat(undef, $$oBackupInfo{&INFO_SECTION_TIMESTAMP}{&INFO_KEY_STOP}) . "\n" .
|
|
|
|
" wal start/stop: ";
|
|
|
|
if (defined($oBackupInfo->{&INFO_SECTION_ARCHIVE}{&INFO_KEY_START}) &&
|
|
defined($oBackupInfo->{&INFO_SECTION_ARCHIVE}{&INFO_KEY_STOP}))
|
|
{
|
|
$strOutput .=
|
|
$oBackupInfo->{&INFO_SECTION_ARCHIVE}{&INFO_KEY_START} . ' / ' . $oBackupInfo->{&INFO_SECTION_ARCHIVE}{&INFO_KEY_STOP};
|
|
}
|
|
else
|
|
{
|
|
$strOutput .= 'n/a';
|
|
}
|
|
|
|
$strOutput .=
|
|
"\n database size: " .
|
|
(defined($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_KEY_SIZE}) ?
|
|
fileSizeFormat($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_KEY_SIZE}) : '') .
|
|
', backup size: ' .
|
|
(defined($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_KEY_DELTA}) ?
|
|
fileSizeFormat($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_KEY_DELTA}) : '') . "\n" .
|
|
|
|
' repository size: ' .
|
|
(defined($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_SECTION_REPO}{&INFO_KEY_SIZE}) ?
|
|
fileSizeFormat($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_SECTION_REPO}{&INFO_KEY_SIZE}) : '') .
|
|
', repository backup size: ' .
|
|
(defined($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_SECTION_REPO}{&INFO_KEY_DELTA}) ?
|
|
fileSizeFormat($$oBackupInfo{&INFO_SECTION_INFO}{&INFO_SECTION_REPO}{&INFO_KEY_DELTA}) : '');
|
|
|
|
# List the backup reference chain, if any, for this backup
|
|
if (defined($oBackupInfo->{&INFO_KEY_REFERENCE}) && @{$oBackupInfo->{&INFO_KEY_REFERENCE}} > 0)
|
|
{
|
|
$strOutput .= "\n backup reference list: " . (join(', ', @{$$oBackupInfo{&INFO_KEY_REFERENCE}}));
|
|
}
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'strOutput', value => $strOutput, trace => true}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# stanzaList
|
|
####################################################################################################################################
|
|
sub stanzaList
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$strStanza
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->stanzaList', \@_,
|
|
{name => 'strStanza', required => false}
|
|
);
|
|
|
|
my @oyStanzaList;
|
|
|
|
# Run remotely
|
|
if (!isRepoLocal())
|
|
{
|
|
@oyStanzaList = @{protocolGet(CFGOPTVAL_REMOTE_TYPE_BACKUP)->cmdExecute(OP_INFO_STANZA_LIST, [$strStanza], true)};
|
|
}
|
|
# Run locally
|
|
else
|
|
{
|
|
my @stryStanza = storageRepo()->list(cfgCommandName(CFGCMD_BACKUP), {bIgnoreMissing => true});
|
|
|
|
foreach my $strStanzaFound (@stryStanza)
|
|
{
|
|
if (defined($strStanza) && $strStanza ne $strStanzaFound)
|
|
{
|
|
next;
|
|
}
|
|
|
|
my $oStanzaInfo = {};
|
|
$$oStanzaInfo{&INFO_STANZA_NAME} = $strStanzaFound;
|
|
($$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}, $$oStanzaInfo{&INFO_BACKUP_SECTION_DB}) =
|
|
$self->backupList($strStanzaFound);
|
|
|
|
# If there are no backups then set status to no backup
|
|
if (defined($$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}) && @{$$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}} == 0)
|
|
{
|
|
$$oStanzaInfo{&INFO_SECTION_STATUS} =
|
|
{
|
|
&INFO_KEY_CODE => INFO_STANZA_STATUS_NO_BACKUP_CODE,
|
|
&INFO_KEY_MESSAGE => INFO_STANZA_STATUS_NO_BACKUP_MESSAGE
|
|
};
|
|
}
|
|
# Else status is OK
|
|
elsif (defined($$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}))
|
|
{
|
|
$$oStanzaInfo{&INFO_SECTION_STATUS} =
|
|
{
|
|
&INFO_KEY_CODE => INFO_STANZA_STATUS_OK_CODE,
|
|
&INFO_KEY_MESSAGE => INFO_STANZA_STATUS_OK_MESSAGE
|
|
};
|
|
}
|
|
|
|
# Array to store tne min/max archive for each database for which there are archives
|
|
my @oyDbArchiveList = ();
|
|
|
|
if (!defined($$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP}))
|
|
{
|
|
$$oStanzaInfo{&INFO_SECTION_STATUS} =
|
|
{
|
|
&INFO_KEY_CODE => INFO_STANZA_STATUS_MISSING_STANZA_DATA_CODE,
|
|
&INFO_KEY_MESSAGE => INFO_STANZA_STATUS_MISSING_STANZA_DATA_MESSAGE
|
|
};
|
|
|
|
$$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP} = [];
|
|
$$oStanzaInfo{&INFO_BACKUP_SECTION_DB} = [];
|
|
}
|
|
else
|
|
{
|
|
# Get the current DB info (always last element in the array)
|
|
my $hDbCurrent = @{$oStanzaInfo->{&INFO_BACKUP_SECTION_DB}}[-1];
|
|
my $strDbCurrentVersion = $hDbCurrent->{&INFO_KEY_VERSION};
|
|
my $ullDbCurrentSystemId = $hDbCurrent->{&INFO_KEY_SYSTEM_ID};
|
|
|
|
# Loop through the DB history from oldest to newest
|
|
foreach my $hDbInfo (@{$oStanzaInfo->{&INFO_BACKUP_SECTION_DB}})
|
|
{
|
|
my $strArchiveStanzaPath = "archive/" . $strStanzaFound;
|
|
my $strDbVersion = $hDbInfo->{&INFO_KEY_VERSION};
|
|
my $ullDbSysId = $hDbInfo->{&INFO_KEY_SYSTEM_ID};
|
|
|
|
# With multiple DB versions, the backup.info history-id may not be the same as archive.info history-id, so the
|
|
# archive path must be built by retrieving the archive id given the db version and system id of the backup
|
|
my $oArchiveInfo = new pgBackRest::Archive::Info(storageRepo()->pathGet($strArchiveStanzaPath));
|
|
my $strArchiveId = $oArchiveInfo->archiveId({strDbVersion => $hDbInfo->{&INFO_KEY_VERSION},
|
|
ullDbSysId => $hDbInfo->{&INFO_KEY_SYSTEM_ID}});
|
|
my $strArchivePath = "archive/${strStanzaFound}/${strArchiveId}";
|
|
|
|
# Fill in the archive info if available
|
|
my $hDbArchive = $self->dbArchiveSection($hDbInfo, $strArchiveId, $strArchivePath, $strDbCurrentVersion,
|
|
$ullDbCurrentSystemId);
|
|
|
|
if (defined($hDbArchive))
|
|
{
|
|
push(@oyDbArchiveList, $hDbArchive);
|
|
}
|
|
}
|
|
}
|
|
|
|
# Store the archive min/max for each database in the archive section
|
|
$oStanzaInfo->{&INFO_SECTION_ARCHIVE} = \@oyDbArchiveList;
|
|
|
|
push @oyStanzaList, $oStanzaInfo;
|
|
}
|
|
|
|
if (defined($strStanza) && @oyStanzaList == 0)
|
|
{
|
|
my $oStanzaInfo = {};
|
|
|
|
$$oStanzaInfo{&INFO_STANZA_NAME} = $strStanza;
|
|
|
|
$$oStanzaInfo{&INFO_SECTION_STATUS} =
|
|
{
|
|
&INFO_KEY_CODE => INFO_STANZA_STATUS_MISSING_STANZA_CODE,
|
|
&INFO_KEY_MESSAGE => INFO_STANZA_STATUS_MISSING_STANZA_MESSAGE
|
|
};
|
|
|
|
$$oStanzaInfo{&INFO_BACKUP_SECTION_BACKUP} = [];
|
|
$$oStanzaInfo{&INFO_BACKUP_SECTION_DB} = [];
|
|
|
|
push @oyStanzaList, $oStanzaInfo;
|
|
}
|
|
}
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'oyStanzaList', value => \@oyStanzaList, log => false, ref => true}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# backupList
|
|
###################################################################################################################################
|
|
sub backupList
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$strStanza
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->backupList', \@_,
|
|
{name => 'strStanza'}
|
|
);
|
|
|
|
# Load the backup.info but do not attempt to validate it
|
|
my $oBackupInfo = undef;
|
|
|
|
# Turn off console logging to control when to display the error
|
|
logDisable();
|
|
|
|
eval
|
|
{
|
|
$oBackupInfo = new pgBackRest::Backup::Info(storageRepo()->pathGet(cfgCommandName(CFGCMD_BACKUP) . "/${strStanza}"), false);
|
|
logEnable();
|
|
return true;
|
|
}
|
|
or do
|
|
{
|
|
logEnable();
|
|
|
|
if (exceptionCode($EVAL_ERROR) == ERROR_FILE_MISSING)
|
|
{
|
|
return;
|
|
}
|
|
elsif (exceptionCode($EVAL_ERROR) == ERROR_CIPHER)
|
|
{
|
|
# Confess the encryption error with additional hint
|
|
confess &log(ERROR, exceptionMessage($EVAL_ERROR) .
|
|
"\nHINT: use option --stanza if encryption settings are different for the stanza than the global settings",
|
|
ERROR_CIPHER);
|
|
}
|
|
else
|
|
{
|
|
# Confess unhandled errors
|
|
confess $EVAL_ERROR;
|
|
}
|
|
};
|
|
|
|
# Build the db list
|
|
my @oyDbList;
|
|
|
|
foreach my $iHistoryId ($oBackupInfo->keys(INFO_BACKUP_SECTION_DB_HISTORY))
|
|
{
|
|
my $oDbHash =
|
|
{
|
|
&INFO_HISTORY_ID => $iHistoryId + 0,
|
|
&INFO_DB_VERSION =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_DB_HISTORY, $iHistoryId, INFO_BACKUP_KEY_DB_VERSION),
|
|
&INFO_SYSTEM_ID =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_DB_HISTORY, $iHistoryId, INFO_BACKUP_KEY_SYSTEM_ID)
|
|
};
|
|
|
|
push(@oyDbList, $oDbHash);
|
|
}
|
|
|
|
# Build the backup list
|
|
my @oyBackupList;
|
|
|
|
foreach my $strBackup ($oBackupInfo->keys(INFO_BACKUP_SECTION_BACKUP_CURRENT))
|
|
{
|
|
my $oBackupHash =
|
|
{
|
|
&INFO_SECTION_ARCHIVE =>
|
|
{
|
|
&INFO_KEY_START =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_ARCHIVE_START, false),
|
|
&INFO_KEY_STOP =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_ARCHIVE_STOP, false),
|
|
},
|
|
&INFO_SECTION_BACKREST =>
|
|
{
|
|
&INFO_KEY_FORMAT =>
|
|
$oBackupInfo->numericGet(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INI_KEY_FORMAT),
|
|
&INFO_KEY_VERSION =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INI_KEY_VERSION)
|
|
},
|
|
&INFO_SECTION_DB =>
|
|
{
|
|
&INFO_KEY_ID =>
|
|
$oBackupInfo->numericGet(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_HISTORY_ID)
|
|
},
|
|
&INFO_SECTION_INFO =>
|
|
{
|
|
&INFO_SECTION_REPO =>
|
|
{
|
|
# Size of the backup in the repository, taking compression into account
|
|
&INFO_KEY_SIZE =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_BACKUP_REPO_SIZE),
|
|
# Size of this backup only (does not include referenced backups like repo->size)
|
|
&INFO_KEY_DELTA =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_BACKUP_REPO_SIZE_DELTA),
|
|
},
|
|
# Original database size
|
|
&INFO_KEY_SIZE =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_BACKUP_SIZE),
|
|
# Amount of database backed up (will be equal for full backups)
|
|
&INFO_KEY_DELTA =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_BACKUP_SIZE_DELTA),
|
|
},
|
|
&INFO_SECTION_TIMESTAMP =>
|
|
{
|
|
&INFO_KEY_START =>
|
|
$oBackupInfo->numericGet(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_TIMESTAMP_START),
|
|
&INFO_KEY_STOP =>
|
|
$oBackupInfo->numericGet(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_TIMESTAMP_STOP),
|
|
},
|
|
&INFO_KEY_LABEL => $strBackup,
|
|
&INFO_KEY_PRIOR =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_PRIOR, false),
|
|
&INFO_KEY_REFERENCE =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_REFERENCE, false),
|
|
&INFO_KEY_TYPE =>
|
|
$oBackupInfo->get(INFO_BACKUP_SECTION_BACKUP_CURRENT, $strBackup, INFO_BACKUP_KEY_TYPE)
|
|
};
|
|
|
|
push(@oyBackupList, $oBackupHash);
|
|
}
|
|
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'oyBackupList', value => \@oyBackupList, log => false, ref => true},
|
|
{name => 'oyDbList', value => \@oyDbList, log => false, ref => true}
|
|
);
|
|
}
|
|
|
|
####################################################################################################################################
|
|
# dbArchiveSection - fills the archive section for a db. Note this is a function in order to aid unit test coverage.
|
|
####################################################################################################################################
|
|
sub dbArchiveSection
|
|
{
|
|
my $self = shift;
|
|
|
|
# Assign function parameters, defaults, and log debug info
|
|
my
|
|
(
|
|
$strOperation,
|
|
$hDbInfo,
|
|
$strArchiveId,
|
|
$strArchivePath,
|
|
$strDbCurrentVersion,
|
|
$ullDbCurrentSystemId,
|
|
) =
|
|
logDebugParam
|
|
(
|
|
__PACKAGE__ . '->dbArchiveSection', \@_,
|
|
{name => 'hDbInfo'},
|
|
{name => 'strArchiveId'},
|
|
{name => 'strArchivePath'},
|
|
{name => 'strDbCurrentVersion'},
|
|
{name => 'ullDbCurrentSystemId'},
|
|
);
|
|
|
|
my $hDbArchive = undef;
|
|
my $strArchiveStart = undef;
|
|
my $strArchiveStop = undef;
|
|
|
|
if (storageRepo()->pathExists($strArchivePath))
|
|
{
|
|
my @stryWalMajor = storageRepo()->list($strArchivePath, {strExpression => '^[0-F]{16}$'});
|
|
|
|
# Get first WAL segment
|
|
foreach my $strWalMajor (@stryWalMajor)
|
|
{
|
|
my @stryWalFile = storageRepo()->list(
|
|
"${strArchivePath}/${strWalMajor}",
|
|
{strExpression => "^[0-F]{24}-[0-f]{40}(\\." . COMPRESS_EXT . "){0,1}\$"});
|
|
|
|
if (@stryWalFile > 0)
|
|
{
|
|
$strArchiveStart = substr($stryWalFile[0], 0, 24);
|
|
last;
|
|
}
|
|
}
|
|
|
|
# Get last WAL segment
|
|
foreach my $strWalMajor (sort({$b cmp $a} @stryWalMajor))
|
|
{
|
|
my @stryWalFile = storageRepo()->list(
|
|
"${strArchivePath}/${strWalMajor}",
|
|
{strExpression => "^[0-F]{24}-[0-f]{40}(\\." . COMPRESS_EXT . "){0,1}\$", strSortOrder => 'reverse'});
|
|
|
|
if (@stryWalFile > 0)
|
|
{
|
|
$strArchiveStop = substr($stryWalFile[0], 0, 24);
|
|
last;
|
|
}
|
|
}
|
|
}
|
|
|
|
# If there is an archive or the database is the current database then store it
|
|
if (($strDbCurrentVersion eq $hDbInfo->{&INFO_KEY_VERSION} &&
|
|
$ullDbCurrentSystemId == $hDbInfo->{&INFO_KEY_SYSTEM_ID}) ||
|
|
defined($strArchiveStart) )
|
|
{
|
|
$hDbArchive =
|
|
{
|
|
&INFO_KEY_ID => $strArchiveId,
|
|
&INFO_KEY_MIN => $strArchiveStart,
|
|
&INFO_KEY_MAX => $strArchiveStop,
|
|
&INFO_SECTION_DB =>
|
|
{
|
|
&INFO_HISTORY_ID => $hDbInfo->{&INFO_HISTORY_ID} + 0,
|
|
},
|
|
};
|
|
}
|
|
# Return from function and log return values if any
|
|
return logDebugReturn
|
|
(
|
|
$strOperation,
|
|
{name => 'hDbArchive', value => $hDbArchive, trace => true},
|
|
);
|
|
}
|
|
|
|
1;
|