diff options
author | Alistair Coles <alistairncoles@gmail.com> | 2023-04-26 11:20:42 +0100 |
---|---|---|
committer | Alistair Coles <alistairncoles@gmail.com> | 2023-04-26 11:33:41 +0100 |
commit | 50c4ea032d5d713583b6247f054c82f5cf540661 (patch) | |
tree | 0c2743f7b6df260ddb66a4b3d34e078d7bc82bd6 /test | |
parent | 0f95870c51c696b076b3c9b266e1d7cde52a30d4 (diff) | |
download | swift-50c4ea032d5d713583b6247f054c82f5cf540661.tar.gz |
ECFragGetter: assume policy.fragment_size is non-zero
Simplify ECFragGetter by removing code that guards against the policy
fragment_size being None or zero.
Policy fragment_size must be > 0: the fragment_size is based on the
ec_segment_size, which is verified as > 0 when constructing an EC
policy. This is asserted by test_parse_storage_policies in
test.unit.common.test_storage_policy.TestStoragePolicies.
Also, rename client_chunk_size to fragment_size for clarity.
Change-Id: Ie1efaab3bd0510275d534b5c023cb73c98bec90d
Diffstat (limited to 'test')
-rw-r--r-- | test/unit/proxy/controllers/test_obj.py | 21 |
1 files changed, 3 insertions, 18 deletions
diff --git a/test/unit/proxy/controllers/test_obj.py b/test/unit/proxy/controllers/test_obj.py index 8224a2f76..cbbaf2763 100644 --- a/test/unit/proxy/controllers/test_obj.py +++ b/test/unit/proxy/controllers/test_obj.py @@ -6715,27 +6715,12 @@ class TestECFragGetter(BaseObjectControllerMixin, unittest.TestCase): b''.join(it) self.assertEqual('9 seconds', str(cm.exception)) - def test_iter_bytes_from_response_part_null_chunk_size(self): - # we don't expect a policy to have fragment_size None or zero but - # verify that the getter is defensive - self.getter.client_chunk_size = None - part = FileLikeIter([b'some', b'thing', b'']) - it = self.getter.iter_bytes_from_response_part(part, nbytes=None) - self.assertEqual(b'something', b''.join(it)) - - self.getter.client_chunk_size = 0 - part = FileLikeIter([b'some', b'thing', b'']) - it = self.getter.iter_bytes_from_response_part(part, nbytes=None) - self.assertEqual(b'something', b''.join(it)) - - def test_iter_bytes_from_response_part_small_chunk_size(self): - # we don't expect a policy to have fragment_size None or zero but - # verify that the getter is defensive - self.getter.client_chunk_size = 4 + def test_iter_bytes_from_response_part_small_fragment_size(self): + self.getter.fragment_size = 4 part = FileLikeIter([b'some', b'thing', b'']) it = self.getter.iter_bytes_from_response_part(part, nbytes=None) self.assertEqual([b'some', b'thin', b'g'], [ch for ch in it]) - self.getter.client_chunk_size = 1 + self.getter.fragment_size = 1 part = FileLikeIter([b'some', b'thing', b'']) it = self.getter.iter_bytes_from_response_part(part, nbytes=None) self.assertEqual([c.encode() for c in 'something'], [ch for ch in it]) |