summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorNikolaus Rath <Nikolaus@rath.org>2017-08-19 14:37:50 +0200
committerNikolaus Rath <Nikolaus@rath.org>2017-08-19 14:37:50 +0200
commita5eebe2087e42d511efd3f03738a3d5688684b5c (patch)
tree207e15d361c5c1febc3e2b2455c5575ef1c06edb /tests
parent6491fdcd035d05feee3f5e7d8f3d46aec37fb8ec (diff)
Import s3ql_2.23+dfsg.orig.tar.gz
Diffstat (limited to 'tests')
-rwxr-xr-xtests/t2_block_cache.py30
1 files changed, 15 insertions, 15 deletions
diff --git a/tests/t2_block_cache.py b/tests/t2_block_cache.py
index bede753..d521725 100755
--- a/tests/t2_block_cache.py
+++ b/tests/t2_block_cache.py
@@ -231,7 +231,7 @@ class cache_tests(unittest.TestCase):
# We want to expire 4 entries, 2 of which are already flushed
self.cache.cache.max_entries = 16
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=2)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=2)
self.cache.expire()
self.cache.backend_pool.verify()
self.assertEqual(len(self.cache.cache), 16)
@@ -254,7 +254,7 @@ class cache_tests(unittest.TestCase):
data3 = self.random_data(datalen)
# Case 1: create new object
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
with self.cache.get(inode, blockno1) as fh:
fh.seek(0)
fh.write(data1)
@@ -263,7 +263,7 @@ class cache_tests(unittest.TestCase):
self.cache.backend_pool.verify()
# Case 2: Link new object
- self.cache.backend_pool = TestBackendPool(self.backend_pool)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool)
with self.cache.get(inode, blockno2) as fh:
fh.seek(0)
fh.write(data1)
@@ -272,7 +272,7 @@ class cache_tests(unittest.TestCase):
self.cache.backend_pool.verify()
# Case 3: Upload old object, still has references
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
with self.cache.get(inode, blockno1) as fh:
fh.seek(0)
fh.write(data2)
@@ -280,7 +280,7 @@ class cache_tests(unittest.TestCase):
self.cache.backend_pool.verify()
# Case 4: Upload old object, no references left
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_del=1, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_del=1, no_write=1)
with self.cache.get(inode, blockno2) as fh:
fh.seek(0)
fh.write(data3)
@@ -288,7 +288,7 @@ class cache_tests(unittest.TestCase):
self.cache.backend_pool.verify()
# Case 5: Link old object, no references left
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_del=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_del=1)
with self.cache.get(inode, blockno2) as fh:
fh.seek(0)
fh.write(data2)
@@ -297,7 +297,7 @@ class cache_tests(unittest.TestCase):
# Case 6: Link old object, still has references
# (Need to create another object first)
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
with self.cache.get(inode, blockno3) as fh:
fh.seek(0)
fh.write(data1)
@@ -305,7 +305,7 @@ class cache_tests(unittest.TestCase):
self.cache.upload(el3)
self.cache.backend_pool.verify()
- self.cache.backend_pool = TestBackendPool(self.backend_pool)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool)
with self.cache.get(inode, blockno1) as fh:
fh.seek(0)
fh.write(data1)
@@ -320,7 +320,7 @@ class cache_tests(unittest.TestCase):
blockno2 = 24
data = self.random_data(datalen)
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
with self.cache.get(inode, blockno1) as fh:
fh.seek(0)
fh.write(data)
@@ -330,7 +330,7 @@ class cache_tests(unittest.TestCase):
self.cache.clear()
self.cache.backend_pool.verify()
- self.cache.backend_pool = TestBackendPool(self.backend_pool)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool)
self.cache.remove(inode, blockno1)
self.cache.backend_pool.verify()
@@ -450,10 +450,10 @@ class cache_tests(unittest.TestCase):
with self.cache.get(inode, 1) as fh:
fh.seek(0)
fh.write(data1)
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
commit(self.cache, inode)
self.cache.backend_pool.verify()
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_del=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_del=1)
self.cache.remove(inode, 1)
self.cache.backend_pool.verify()
@@ -470,10 +470,10 @@ class cache_tests(unittest.TestCase):
with self.cache.get(inode, 1) as fh:
fh.seek(0)
fh.write(data1)
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_write=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_write=1)
self.cache.clear()
self.cache.backend_pool.verify()
- self.cache.backend_pool = TestBackendPool(self.backend_pool, no_del=1)
+ self.cache.backend_pool = MockBackendPool(self.backend_pool, no_del=1)
self.cache.remove(inode, 1)
self.cache.backend_pool.verify()
with self.cache.get(inode, 1) as fh:
@@ -481,7 +481,7 @@ class cache_tests(unittest.TestCase):
self.assertEqual(fh.read(42), b'')
-class TestBackendPool(AbstractBackend):
+class MockBackendPool(AbstractBackend):
has_native_rename = False
def __init__(self, backend_pool, no_read=0, no_write=0, no_del=0):