Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 16 additions & 0 deletions Include/internal/pycore_bytesobject.h
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,22 @@ _PyBytes_Repeat(char* dest, Py_ssize_t len_dest,
*/
#define _PyBytesObject_SIZE (offsetof(PyBytesObject, ob_sval) + 1)


// Return the cached hash value, or -1 if not cached yet.
static inline Py_hash_t
_PyBytes_GET_CACHED_HASH(PyBytesObject *self)
{
_Py_COMP_DIAG_PUSH
_Py_COMP_DIAG_IGNORE_DEPR_DECLS
#ifdef Py_GIL_DISABLED
return _Py_atomic_load_ssize_relaxed(&self->ob_shash);
#else
return self->ob_shash;
#endif
_Py_COMP_DIAG_POP
}


/* --- PyBytesWriter ------------------------------------------------------ */

struct PyBytesWriter {
Expand Down
30 changes: 27 additions & 3 deletions Lib/test/test_bytes.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,14 @@
"""

import array
import codecs
import copy
import functools
import operator
import os
import pickle
import re
import sys
import copy
import functools
import pickle
import tempfile
import textwrap
import threading
Expand Down Expand Up @@ -1645,6 +1646,29 @@ def test_take_bytes_optimization(self):
bytes_header_size = sys.getsizeof(b'')
self.assertEqual(ba.__alloc__(), 499 + bytes_header_size)

def test_take_bytes_hash(self):
# gh-158219: bytearray constructor must not use a bytes object
# if its hash value is already cached.

def encode(string, errors='strict'):
encoded = string.encode('utf-8')
hash(encoded) # a codec may hash its own output
return encoded, len(string)

def hashing_codec(name):
if name != 'test_take_bytes_hash':
return None
return codecs.CodecInfo(encode, None, name=name)

codecs.register(hashing_codec)
self.addCleanup(codecs.unregister, hashing_codec)

ba = bytearray('hello', 'test_take_bytes_hash')
ba[0] = ord('H')
taken = ba.take_bytes()
self.assertEqual(taken, b'Hello')
self.assertEqual(hash(taken), hash(b'Hello'))

def test_take_bytes_reentrant_resize(self):
# gh-153570: n.__index__() can resize the bytearray, so take_bytes()
# must re-read the size afterwards. It cached the size before the
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
Fix :class:`bytearray` constructor: do not use a bytes object if its hash
value is already computed. Patch by Cody Maloney and Victor Stinner.
3 changes: 2 additions & 1 deletion Objects/bytearrayobject.c
Original file line number Diff line number Diff line change
Expand Up @@ -989,7 +989,8 @@ bytearray___init___impl(PyByteArrayObject *self, PyObject *arg,

/* Most encodes return a new unique bytes, just use it as buffer. */
if (_PyObject_IsUniquelyReferenced(encoded)
&& PyBytes_CheckExact(encoded))
&& PyBytes_CheckExact(encoded)
&& _PyBytes_GET_CACHED_HASH((PyBytesObject*)encoded) == -1)
{
Py_ssize_t size = Py_SIZE(encoded);
self->ob_bytes_object = encoded;
Expand Down
13 changes: 1 addition & 12 deletions Objects/bytesobject.c
Original file line number Diff line number Diff line change
Expand Up @@ -62,18 +62,7 @@ _Py_COMP_DIAG_IGNORE_DEPR_DECLS
_Py_COMP_DIAG_POP
}

static inline Py_hash_t
get_ob_shash(PyBytesObject *a)
{
_Py_COMP_DIAG_PUSH
_Py_COMP_DIAG_IGNORE_DEPR_DECLS
#ifdef Py_GIL_DISABLED
return _Py_atomic_load_ssize_relaxed(&a->ob_shash);
#else
return a->ob_shash;
#endif
_Py_COMP_DIAG_POP
}
#define get_ob_shash(op) _PyBytes_GET_CACHED_HASH(op)


/*
Expand Down
Loading