Merge "Remove unnecessary open call and related vars in unit tests"
This commit is contained in:
commit
531a6d46e0
@ -33,8 +33,7 @@ from swift import __version__ as swift_version
|
|||||||
from swift.common.swob import (Request, WsgiBytesIO, HTTPNoContent)
|
from swift.common.swob import (Request, WsgiBytesIO, HTTPNoContent)
|
||||||
from swift.common import constraints
|
from swift.common import constraints
|
||||||
from swift.account.server import AccountController
|
from swift.account.server import AccountController
|
||||||
from swift.common.utils import (normalize_timestamp, replication, public,
|
from swift.common.utils import (normalize_timestamp, replication, public)
|
||||||
mkdirs, storage_directory)
|
|
||||||
from swift.common.request_helpers import get_sys_meta_prefix
|
from swift.common.request_helpers import get_sys_meta_prefix
|
||||||
from test.unit import patch_policies, debug_logger
|
from test.unit import patch_policies, debug_logger
|
||||||
from swift.common.storage_policy import StoragePolicy, POLICIES
|
from swift.common.storage_policy import StoragePolicy, POLICIES
|
||||||
@ -172,12 +171,6 @@ class TestAccountController(unittest.TestCase):
|
|||||||
self.assertEqual(resp.status_int, 507)
|
self.assertEqual(resp.status_int, 507)
|
||||||
|
|
||||||
def test_REPLICATE_rsync_then_merge_works(self):
|
def test_REPLICATE_rsync_then_merge_works(self):
|
||||||
mkdirs(os.path.join(self.testdir, 'sda1', 'account', 'p', 'a', 'a'))
|
|
||||||
db_file = os.path.join(self.testdir, 'sda1',
|
|
||||||
storage_directory('account', 'p', 'a'),
|
|
||||||
'a' + '.db')
|
|
||||||
open(db_file, 'w')
|
|
||||||
|
|
||||||
def fake_rsync_then_merge(self, drive, db_file, args):
|
def fake_rsync_then_merge(self, drive, db_file, args):
|
||||||
return HTTPNoContent()
|
return HTTPNoContent()
|
||||||
|
|
||||||
@ -193,12 +186,6 @@ class TestAccountController(unittest.TestCase):
|
|||||||
self.assertEqual(resp.status_int, 204)
|
self.assertEqual(resp.status_int, 204)
|
||||||
|
|
||||||
def test_REPLICATE_complete_rsync_works(self):
|
def test_REPLICATE_complete_rsync_works(self):
|
||||||
mkdirs(os.path.join(self.testdir, 'sda1', 'account', 'p', 'a', 'a'))
|
|
||||||
db_file = os.path.join(self.testdir, 'sda1',
|
|
||||||
storage_directory('account', 'p', 'a'),
|
|
||||||
'a' + '.db')
|
|
||||||
open(db_file, 'w')
|
|
||||||
|
|
||||||
def fake_complete_rsync(self, drive, db_file, args):
|
def fake_complete_rsync(self, drive, db_file, args):
|
||||||
return HTTPNoContent()
|
return HTTPNoContent()
|
||||||
# check complete_rsync
|
# check complete_rsync
|
||||||
|
@ -40,7 +40,7 @@ import swift.container
|
|||||||
from swift.container import server as container_server
|
from swift.container import server as container_server
|
||||||
from swift.common import constraints
|
from swift.common import constraints
|
||||||
from swift.common.utils import (Timestamp, mkdirs, public, replication,
|
from swift.common.utils import (Timestamp, mkdirs, public, replication,
|
||||||
storage_directory, lock_parent_directory)
|
lock_parent_directory)
|
||||||
from test.unit import fake_http_connect, debug_logger
|
from test.unit import fake_http_connect, debug_logger
|
||||||
from swift.common.storage_policy import (POLICIES, StoragePolicy)
|
from swift.common.storage_policy import (POLICIES, StoragePolicy)
|
||||||
from swift.common.request_helpers import get_sys_meta_prefix
|
from swift.common.request_helpers import get_sys_meta_prefix
|
||||||
@ -1286,12 +1286,6 @@ class TestContainerController(unittest.TestCase):
|
|||||||
self.assertEqual(resp.status_int, 507)
|
self.assertEqual(resp.status_int, 507)
|
||||||
|
|
||||||
def test_REPLICATE_rsync_then_merge_works(self):
|
def test_REPLICATE_rsync_then_merge_works(self):
|
||||||
mkdirs(os.path.join(self.testdir, 'sda1', 'containers', 'p', 'a', 'a'))
|
|
||||||
db_file = os.path.join(self.testdir, 'sda1',
|
|
||||||
storage_directory('containers', 'p', 'a'),
|
|
||||||
'a' + '.db')
|
|
||||||
open(db_file, 'w')
|
|
||||||
|
|
||||||
def fake_rsync_then_merge(self, drive, db_file, args):
|
def fake_rsync_then_merge(self, drive, db_file, args):
|
||||||
return HTTPNoContent()
|
return HTTPNoContent()
|
||||||
|
|
||||||
@ -1307,12 +1301,6 @@ class TestContainerController(unittest.TestCase):
|
|||||||
self.assertEqual(resp.status_int, 204)
|
self.assertEqual(resp.status_int, 204)
|
||||||
|
|
||||||
def test_REPLICATE_complete_rsync_works(self):
|
def test_REPLICATE_complete_rsync_works(self):
|
||||||
mkdirs(os.path.join(self.testdir, 'sda1', 'containers', 'p', 'a', 'a'))
|
|
||||||
db_file = os.path.join(self.testdir, 'sda1',
|
|
||||||
storage_directory('containers', 'p', 'a'),
|
|
||||||
'a' + '.db')
|
|
||||||
open(db_file, 'w')
|
|
||||||
|
|
||||||
def fake_complete_rsync(self, drive, db_file, args):
|
def fake_complete_rsync(self, drive, db_file, args):
|
||||||
return HTTPNoContent()
|
return HTTPNoContent()
|
||||||
with mock.patch("swift.container.replicator.ContainerReplicatorRpc."
|
with mock.patch("swift.container.replicator.ContainerReplicatorRpc."
|
||||||
|
Loading…
Reference in New Issue
Block a user