mirror of https://github.com/python/cpython
gh-125608: Trigger dictionary watchers when inline values change (#125611)
Dictionary watchers on an object's attributes dictionary (`object.__dict__`) were not triggered when the managed dictionary used the object's inline values.
This commit is contained in:
parent
0cd21406bf
commit
5989eb7446
|
@ -97,6 +97,23 @@ class TestDictWatchers(unittest.TestCase):
|
||||||
del d
|
del d
|
||||||
self.assert_events(["dealloc"])
|
self.assert_events(["dealloc"])
|
||||||
|
|
||||||
|
def test_object_dict(self):
|
||||||
|
class MyObj: pass
|
||||||
|
o = MyObj()
|
||||||
|
|
||||||
|
with self.watcher() as wid:
|
||||||
|
self.watch(wid, o.__dict__)
|
||||||
|
o.foo = "bar"
|
||||||
|
o.foo = "baz"
|
||||||
|
del o.foo
|
||||||
|
self.assert_events(["new:foo:bar", "mod:foo:baz", "del:foo"])
|
||||||
|
|
||||||
|
with self.watcher() as wid:
|
||||||
|
self.watch(wid, o.__dict__)
|
||||||
|
for _ in range(100):
|
||||||
|
o.foo = "bar"
|
||||||
|
self.assert_events(["new:foo:bar"] + ["mod:foo:bar"] * 99)
|
||||||
|
|
||||||
def test_unwatch(self):
|
def test_unwatch(self):
|
||||||
d = {}
|
d = {}
|
||||||
with self.watcher() as wid:
|
with self.watcher() as wid:
|
||||||
|
|
|
@ -0,0 +1,3 @@
|
||||||
|
Fix a bug where dictionary watchers (e.g., :c:func:`PyDict_Watch`) on an
|
||||||
|
object's attribute dictionary (:attr:`~object.__dict__`) were not triggered
|
||||||
|
when the object's attributes were modified.
|
|
@ -6835,15 +6835,24 @@ store_instance_attr_lock_held(PyObject *obj, PyDictValues *values,
|
||||||
}
|
}
|
||||||
|
|
||||||
PyObject *old_value = values->values[ix];
|
PyObject *old_value = values->values[ix];
|
||||||
FT_ATOMIC_STORE_PTR_RELEASE(values->values[ix], Py_XNewRef(value));
|
if (old_value == NULL && value == NULL) {
|
||||||
|
|
||||||
if (old_value == NULL) {
|
|
||||||
if (value == NULL) {
|
|
||||||
PyErr_Format(PyExc_AttributeError,
|
PyErr_Format(PyExc_AttributeError,
|
||||||
"'%.100s' object has no attribute '%U'",
|
"'%.100s' object has no attribute '%U'",
|
||||||
Py_TYPE(obj)->tp_name, name);
|
Py_TYPE(obj)->tp_name, name);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (dict) {
|
||||||
|
PyInterpreterState *interp = _PyInterpreterState_GET();
|
||||||
|
PyDict_WatchEvent event = (old_value == NULL ? PyDict_EVENT_ADDED :
|
||||||
|
value == NULL ? PyDict_EVENT_DELETED :
|
||||||
|
PyDict_EVENT_MODIFIED);
|
||||||
|
_PyDict_NotifyEvent(interp, event, dict, name, value);
|
||||||
|
}
|
||||||
|
|
||||||
|
FT_ATOMIC_STORE_PTR_RELEASE(values->values[ix], Py_XNewRef(value));
|
||||||
|
|
||||||
|
if (old_value == NULL) {
|
||||||
_PyDictValues_AddToInsertionOrder(values, ix);
|
_PyDictValues_AddToInsertionOrder(values, ix);
|
||||||
if (dict) {
|
if (dict) {
|
||||||
assert(dict->ma_values == values);
|
assert(dict->ma_values == values);
|
||||||
|
|
Loading…
Reference in New Issue