db/pgbackrest
1
0
Fork 0
mirror of https://github.com/pgbackrest/pgbackrest.git synced 2025-03-05 15:05:48 +02:00
Code Issues Releases Activity

Changes to manifest.

Browse Source
This commit is contained in:
David Steele 2014-02-13 23:37:52 -05:00
parent 5c393a0df9
commit e93a444a41
1 changed files with 52 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

101
pg_backrest_backup.pm
View File

@ -328,20 +328,23 @@ sub backup_manifest_load
tie %oBackupManifestFile, 'Config::IniFiles', (-file => $strBackupManifestFile) or confess &log(ERROR, "backup manifest '${strBackupManifestFile}' could not be loaded"); tie %oBackupManifestFile, 'Config::IniFiles', (-file => $strBackupManifestFile) or confess &log(ERROR, "backup manifest '${strBackupManifestFile}' could not be loaded");
my %oBackupManifest; my %oBackupManifest;
my $strSection;
foreach $strSection (sort(keys %oBackupManifestFile)) foreach my $strSection (keys %oBackupManifestFile)
{ {
my $strKey; foreach my $strKey (keys ${oBackupManifestFile}{"${strSection}"})
#&log(DEBUG, "section: ${strSection}");
foreach $strKey (sort(keys ${oBackupManifestFile}{"${strSection}"}))
{ {
my $strValue = ${oBackupManifestFile}{"${strSection}"}{"$strKey"}; my $strValue = ${oBackupManifestFile}{"${strSection}"}{"$strKey"};
if ($strValue =~ /^\{.*\}$/)
{
$oBackupManifest{"${strSection}"}{"$strKey"} = decode_json($strValue);
}
else
{
# &log(ERROR, "scalar key ${strKey}, value ${strValue}");
#&log(DEBUG, "key: ${strKey}=${strValue}"); $oBackupManifest{"${strSection}"}{"$strKey"} = $strValue;
$oBackupManifest{"${strSection}"}{"$strKey"} = decode_json($strValue); }
} }
} }
@ -359,20 +362,20 @@ sub backup_manifest_save
my %oBackupManifest; my %oBackupManifest;
tie %oBackupManifest, 'Config::IniFiles' or confess &log(ERROR, "Unable to create backup config"); tie %oBackupManifest, 'Config::IniFiles' or confess &log(ERROR, "Unable to create backup config");
my $strSection; foreach my $strSection (sort (keys $oBackupManifestRef))
foreach $strSection (sort(keys $oBackupManifestRef))
{ {
my $strKey; foreach my $strKey (sort (keys ${$oBackupManifestRef}{"${strSection}"}))
#&log(DEBUG, "section: ${strSection}");
foreach $strKey (sort(keys ${$oBackupManifestRef}{"${strSection}"}))
{ {
my $strValue = encode_json(${$oBackupManifestRef}{"${strSection}"}{"$strKey"}); my $strValue = ${$oBackupManifestRef}{"${strSection}"}{"$strKey"};
#&log(DEBUG, " key: ${strKey}=${strValue}"); if (ref($strValue) eq "HASH")
$oBackupManifest{"${strSection}"}{"$strKey"} = $strValue; {
$oBackupManifest{"${strSection}"}{"$strKey"} = encode_json($strValue);
}
else
{
$oBackupManifest{"${strSection}"}{"$strKey"} = $strValue;
}
} }
} }
@ -431,20 +434,27 @@ sub backup_manifest_build
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{modification_time} = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{modification_time} =
(split("\\.", $oManifestHash{name}{"${strName}"}{modification_time}))[0]; (split("\\.", $oManifestHash{name}{"${strName}"}{modification_time}))[0];
if ($cType eq "f")
{
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{size} = $oManifestHash{name}{"${strName}"}{size};
}
if ($cType eq "f" || $cType eq "l") if ($cType eq "f" || $cType eq "l")
{ {
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{inode} = $oManifestHash{name}{"${strName}"}{inode}; ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{inode} = $oManifestHash{name}{"${strName}"}{inode};
my $bSizeMatch = true;
if ($cType eq "f")
{
$bSizeMatch = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{size} =
${$oLastManifestRef}{"${strSection}"}{"$strName"}{size};
}
if (defined(${$oLastManifestRef}{"${strSection}"}{"$strName"})) if (defined(${$oLastManifestRef}{"${strSection}"}{"$strName"}))
{ {
my $bSizeMatch = true;
if ($cType eq "f")
{
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{size} = $oManifestHash{name}{"${strName}"}{size};
$bSizeMatch = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{size} ==
${$oLastManifestRef}{"${strSection}"}{"$strName"}{size};
}
if ($bSizeMatch && if ($bSizeMatch &&
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{modification_time} == ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{modification_time} ==
${$oLastManifestRef}{"${strSection}"}{"$strName"}{modification_time}) ${$oLastManifestRef}{"${strSection}"}{"$strName"}{modification_time})
@ -457,31 +467,26 @@ sub backup_manifest_build
else else
{ {
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{reference} = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{reference} =
${$oLastManifestRef}{common}{backup}{label}; ${$oLastManifestRef}{backup}{label};
} }
my $strReference = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{reference}; my $strReference = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{reference};
if (!defined(${$oBackupManifestRef}{common}{backup}{reference})) if (!defined(${$oBackupManifestRef}{backup}{reference}))
{ {
${$oBackupManifestRef}{common}{backup}{reference} = $strReference; ${$oBackupManifestRef}{backup}{reference} = $strReference;
} }
else else
{ {
if (${$oBackupManifestRef}{common}{backup}{reference} !~ /$strReference/) if (${$oBackupManifestRef}{backup}{reference} !~ /$strReference/)
{ {
${$oBackupManifestRef}{common}{backup}{reference} .= ",$strReference"; ${$oBackupManifestRef}{backup}{reference} .= ",$strReference";
} }
} }
} }
} }
} }
if ($cType eq "f")
{
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{size} = $oManifestHash{name}{"${strName}"}{size};
}
if ($cType eq "l") if ($cType eq "l")
{ {
${$oBackupManifestRef}{"${strSection}"}{"$strName"}{link_destination} = ${$oBackupManifestRef}{"${strSection}"}{"$strName"}{link_destination} =
@ -491,11 +496,10 @@ sub backup_manifest_build
{ {
my $strTablespaceOid = basename($strName); my $strTablespaceOid = basename($strName);
my $strTablespaceName = ${$oTablespaceMapRef}{oid}{"$strTablespaceOid"}{name}; my $strTablespaceName = ${$oTablespaceMapRef}{oid}{"$strTablespaceOid"}{name};
#&log(DEBUG, "tablespace: ${strTablespace}");
${$oBackupManifestRef}{"${strLevel}:tablespace"}{"${strTablespaceName}"}{oid} = $strTablespaceOid; ${$oBackupManifestRef}{"${strLevel}:tablespace"}{"${strTablespaceName}"}{oid} = $strTablespaceOid;
${$oBackupManifestRef}{"${strLevel}:tablespace"}{"${strTablespaceName}"}{path} = $strLinkDestination; ${$oBackupManifestRef}{"${strLevel}:tablespace"}{"${strTablespaceName}"}{path} = $strLinkDestination;
backup_manifest_build($strCommandManifest, $strLinkDestination, $oBackupManifestRef, $oLastManifestRef, backup_manifest_build($strCommandManifest, $strLinkDestination, $oBackupManifestRef, $oLastManifestRef,
$oTablespaceMapRef, "tablespace:${strTablespaceName}"); $oTablespaceMapRef, "tablespace:${strTablespaceName}");
} }
@ -792,12 +796,12 @@ sub backup
{ {
%oLastManifest = backup_manifest_load($oFile->path_get(PATH_BACKUP_CLUSTER) . "/$strBackupLastPath/backup.manifest"); %oLastManifest = backup_manifest_load($oFile->path_get(PATH_BACKUP_CLUSTER) . "/$strBackupLastPath/backup.manifest");
if (!defined($oLastManifest{common}{backup}{label})) if (!defined($oLastManifest{backup}{label}))
{ {
confess &log(ERROR, "unable to find label in backup $strBackupLastPath"); confess &log(ERROR, "unable to find label in backup $strBackupLastPath");
} }
&log(INFO, "last backup label: $oLastManifest{common}{backup}{label}"); &log(INFO, "last backup label: $oLastManifest{backup}{label}");
} }
# Create the path for the new backup # Create the path for the new backup
@ -855,11 +859,10 @@ sub backup
my %oBackupManifest; my %oBackupManifest;
# Start backup # Start backup
${oBackupManifest}{common}{backup}{label} = $strBackupPath; ${oBackupManifest}{backup}{label} = $strBackupPath;
${oBackupManifest}{common}{test}{test} = "test";
my $strArchiveStart = $oDb->backup_start($strBackupPath); my $strArchiveStart = $oDb->backup_start($strBackupPath);
${oBackupManifest}{archive}{archive_location}{start} = $strArchiveStart; ${oBackupManifest}{backup}{archive_start} = $strArchiveStart;
&log(INFO, 'archive start: ' . $strArchiveStart); &log(INFO, 'archive start: ' . $strArchiveStart);
@ -879,7 +882,7 @@ sub backup
# Stop backup # Stop backup
my $strArchiveStop = $oDb->backup_stop(); my $strArchiveStop = $oDb->backup_stop();
${oBackupManifest}{archive}{archive_location}{stop} = $strArchiveStop; ${oBackupManifest}{backup}{archive_stop} = $strArchiveStop;
&log(INFO, 'archive stop: ' . $strArchiveStop); &log(INFO, 'archive stop: ' . $strArchiveStop);