mirror of
https://github.com/postgrespro/pg_probackup.git
synced 2026-06-21 01:34:15 +02:00
This commit is contained in:
@@ -762,13 +762,6 @@ dir_check_file(pgFile *file, bool backup_logs)
|
||||
}
|
||||
else
|
||||
{
|
||||
/*
|
||||
* snapfs files:
|
||||
* RELFILENODE.BLOCKNO.snapmap.SNAPID
|
||||
* RELFILENODE.BLOCKNO.snap.SNAPID
|
||||
*/
|
||||
if (strstr(file->name, "snap") != NULL)
|
||||
return true;
|
||||
|
||||
len = strlen(file->name);
|
||||
/* reloid.cfm */
|
||||
|
||||
+1
-2
@@ -5,7 +5,7 @@ from . import init, merge, option, show, compatibility, \
|
||||
backup, delete, delta, restore, validate, \
|
||||
retention, pgpro560, pgpro589, pgpro2068, false_positive, replica, \
|
||||
compression, page, ptrack, archive, exclude, cfs_backup, cfs_restore, \
|
||||
cfs_validate_backup, auth_test, time_stamp, snapfs, logging, \
|
||||
cfs_validate_backup, auth_test, time_stamp, logging, \
|
||||
locking, remote, external, config, checkdb, set_backup, incr_restore, \
|
||||
CVE_2018_1058
|
||||
|
||||
@@ -53,7 +53,6 @@ def load_tests(loader, tests, pattern):
|
||||
suite.addTests(loader.loadTestsFromModule(retention))
|
||||
suite.addTests(loader.loadTestsFromModule(set_backup))
|
||||
suite.addTests(loader.loadTestsFromModule(show))
|
||||
suite.addTests(loader.loadTestsFromModule(snapfs))
|
||||
suite.addTests(loader.loadTestsFromModule(time_stamp))
|
||||
suite.addTests(loader.loadTestsFromModule(validate))
|
||||
suite.addTests(loader.loadTestsFromModule(CVE_2018_1058))
|
||||
|
||||
@@ -1,61 +0,0 @@
|
||||
import unittest
|
||||
import os
|
||||
from time import sleep
|
||||
from .helpers.ptrack_helpers import ProbackupTest, ProbackupException
|
||||
|
||||
|
||||
module_name = 'snapfs'
|
||||
|
||||
|
||||
class SnapFSTest(ProbackupTest, unittest.TestCase):
|
||||
|
||||
# @unittest.expectedFailure
|
||||
def test_snapfs_simple(self):
|
||||
"""standart backup modes with ARCHIVE WAL method"""
|
||||
if not self.enterprise:
|
||||
self.skipTest('This test must be run on enterprise')
|
||||
fname = self.id().split('.')[3]
|
||||
node = self.make_simple_node(
|
||||
base_dir=os.path.join(module_name, fname, 'node'),
|
||||
initdb_params=['--data-checksums'])
|
||||
|
||||
backup_dir = os.path.join(self.tmp_path, module_name, fname, 'backup')
|
||||
self.init_pb(backup_dir)
|
||||
self.add_instance(backup_dir, 'node', node)
|
||||
self.set_archiving(backup_dir, 'node', node)
|
||||
node.slow_start()
|
||||
|
||||
self.backup_node(backup_dir, 'node', node)
|
||||
|
||||
node.safe_psql(
|
||||
'postgres',
|
||||
'select pg_make_snapshot()')
|
||||
|
||||
node.pgbench_init(scale=10)
|
||||
|
||||
pgbench = node.pgbench(options=['-T', '50', '-c', '2', '--no-vacuum'])
|
||||
pgbench.wait()
|
||||
|
||||
self.backup_node(
|
||||
backup_dir, 'node', node, backup_type='page')
|
||||
|
||||
node.safe_psql(
|
||||
'postgres',
|
||||
'select pg_remove_snapshot(1)')
|
||||
|
||||
self.backup_node(
|
||||
backup_dir, 'node', node, backup_type='page')
|
||||
|
||||
pgdata = self.pgdata_content(node.data_dir)
|
||||
|
||||
node.cleanup()
|
||||
|
||||
self.restore_node(
|
||||
backup_dir, 'node',
|
||||
node, options=["-j", "4"])
|
||||
|
||||
pgdata_restored = self.pgdata_content(node.data_dir)
|
||||
self.compare_pgdata(pgdata, pgdata_restored)
|
||||
|
||||
# Clean after yourself
|
||||
self.del_test_dir(module_name, fname)
|
||||
Reference in New Issue
Block a user