summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorAntoine Pitrou <antoine@python.org>2020-04-20 18:54:55 (GMT)
committerGitHub <noreply@github.com>2020-04-20 18:54:55 (GMT)
commiteba9f6155df59c9beed97fb5764c9f01dd941af0 (patch)
treef07cef322962795cd4ed0d71f74f9069580b16a5 /Lib
parent5dd21f5d1c9b5a9316deca4535932675f04efeee (diff)
downloadcpython-eba9f6155df59c9beed97fb5764c9f01dd941af0.zip
cpython-eba9f6155df59c9beed97fb5764c9f01dd941af0.tar.gz
cpython-eba9f6155df59c9beed97fb5764c9f01dd941af0.tar.bz2
bpo-40330: Fix utf-8 size check in ShareableList (GH-19606)
The item size must be checked after encoding to bytes, not before. Automerge-Triggered-By: @pitrou
Diffstat (limited to 'Lib')
-rw-r--r--Lib/multiprocessing/shared_memory.py10
-rw-r--r--Lib/test/_test_multiprocessing.py16
2 files changed, 20 insertions, 6 deletions
diff --git a/Lib/multiprocessing/shared_memory.py b/Lib/multiprocessing/shared_memory.py
index 87e46cf..a3a5fcf 100644
--- a/Lib/multiprocessing/shared_memory.py
+++ b/Lib/multiprocessing/shared_memory.py
@@ -445,11 +445,14 @@ class ShareableList:
if not isinstance(value, (str, bytes)):
new_format = self._types_mapping[type(value)]
+ encoded_value = value
else:
allocated_length = self._allocated_offsets[position + 1] - item_offset
- if len(value) > allocated_length:
- raise ValueError("exceeds available storage for existing str")
+ encoded_value = (value.encode(_encoding)
+ if isinstance(value, str) else value)
+ if len(encoded_value) > allocated_length:
+ raise ValueError("bytes/str item exceeds available storage")
if current_format[-1] == "s":
new_format = current_format
else:
@@ -462,8 +465,7 @@ class ShareableList:
new_format,
value
)
- value = value.encode(_encoding) if isinstance(value, str) else value
- struct.pack_into(new_format, self.shm.buf, offset, value)
+ struct.pack_into(new_format, self.shm.buf, offset, encoded_value)
def __reduce__(self):
return partial(self.__class__, name=self.shm.name), ()
diff --git a/Lib/test/_test_multiprocessing.py b/Lib/test/_test_multiprocessing.py
index d00e928..d633e02 100644
--- a/Lib/test/_test_multiprocessing.py
+++ b/Lib/test/_test_multiprocessing.py
@@ -3995,9 +3995,21 @@ class _TestSharedMemory(BaseTestCase):
sl[4] = 'some' # Change type at a given position.
self.assertEqual(sl[4], 'some')
self.assertEqual(sl.format, '8s8sdq8sxxxxxxx?q')
- with self.assertRaises(ValueError):
- sl[4] = 'far too many' # Exceeds available storage.
+ with self.assertRaisesRegex(ValueError,
+ "exceeds available storage"):
+ sl[4] = 'far too many'
self.assertEqual(sl[4], 'some')
+ sl[0] = 'encodés' # Exactly 8 bytes of UTF-8 data
+ self.assertEqual(sl[0], 'encodés')
+ self.assertEqual(sl[1], b'HoWdY') # no spillage
+ with self.assertRaisesRegex(ValueError,
+ "exceeds available storage"):
+ sl[0] = 'encodées' # Exactly 9 bytes of UTF-8 data
+ self.assertEqual(sl[1], b'HoWdY')
+ with self.assertRaisesRegex(ValueError,
+ "exceeds available storage"):
+ sl[1] = b'123456789'
+ self.assertEqual(sl[1], b'HoWdY')
# Exercise count().
with warnings.catch_warnings():