Skip to content
Merged
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
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
Defer GC tracking of :meth:`set.intersection`, :meth:`set.difference` and
:meth:`set.symmetric_difference`. Patch by Donghee Na.
44 changes: 34 additions & 10 deletions Objects/setobject.c
Original file line number Diff line number Diff line change
Expand Up @@ -1137,14 +1137,14 @@ set_update_impl(PySetObject *so, PyObject * const *others,
can be retrieved or updated in a single cache line.
*/

// Build a set/frozenset left GC-untracked; the caller must _PyObject_GC_TRACK()
// it once fully built, so a half-built set is never exposed during filling.
static PyObject *
make_new_set(PyTypeObject *type, PyObject *iterable)
make_new_set_untracked(PyTypeObject *type, PyObject *iterable)
{
assert(PyType_Check(type));
PySetObject *so;

// Allocate untracked: the fill below runs user code, and a half-built
// set must not be reachable from another thread via gc.get_objects().
so = (PySetObject *)_PyType_AllocNoTrack(type, 0);
if (so == NULL)
return NULL;
Expand All @@ -1164,21 +1164,39 @@ make_new_set(PyTypeObject *type, PyObject *iterable)
}
}

// Track only once fully built.
_PyObject_GC_TRACK(so);
return (PyObject *)so;
}

static PyObject *
make_new_set_basetype(PyTypeObject *type, PyObject *iterable)
make_new_set(PyTypeObject *type, PyObject *iterable)
{
PyObject *so = make_new_set_untracked(type, iterable);
if (so != NULL) {
_PyObject_GC_TRACK(so);
}
return so;
}

static PyObject *
make_new_set_basetype_untracked(PyTypeObject *type, PyObject *iterable)
{
if (type != &PySet_Type && type != &PyFrozenSet_Type) {
if (PyType_IsSubtype(type, &PySet_Type))
type = &PySet_Type;
else
type = &PyFrozenSet_Type;
}
return make_new_set(type, iterable);
return make_new_set_untracked(type, iterable);
}

static PyObject *
make_new_set_basetype(PyTypeObject *type, PyObject *iterable)
{
PyObject *so = make_new_set_basetype_untracked(type, iterable);
if (so != NULL) {
_PyObject_GC_TRACK(so);
}
return so;
}

static PyObject *
Expand Down Expand Up @@ -1423,7 +1441,7 @@ set_intersection(PySetObject *so, PyObject *other)
if ((PyObject *)so == other)
return set_copy_impl(so);

result = (PySetObject *)make_new_set_basetype(Py_TYPE(so), NULL);
result = (PySetObject *)make_new_set_basetype_untracked(Py_TYPE(so), NULL);
if (result == NULL)
return NULL;

Expand Down Expand Up @@ -1456,6 +1474,7 @@ set_intersection(PySetObject *so, PyObject *other)
}
Py_DECREF(key);
}
_PyObject_GC_TRACK(result);
return (PyObject *)result;
}

Expand Down Expand Up @@ -1487,6 +1506,7 @@ set_intersection(PySetObject *so, PyObject *other)
Py_DECREF(result);
return NULL;
}
_PyObject_GC_TRACK(result);
return (PyObject *)result;
error:
Py_DECREF(it);
Expand Down Expand Up @@ -1801,7 +1821,7 @@ set_difference(PySetObject *so, PyObject *other)
return set_copy_and_difference(so, other);
}

result = make_new_set_basetype(Py_TYPE(so), NULL);
result = make_new_set_basetype_untracked(Py_TYPE(so), NULL);
if (result == NULL)
return NULL;

Expand All @@ -1825,6 +1845,7 @@ set_difference(PySetObject *so, PyObject *other)
}
Py_DECREF(key);
}
_PyObject_GC_TRACK(result);
return result;
}

Expand All @@ -1848,6 +1869,7 @@ set_difference(PySetObject *so, PyObject *other)
}
Py_DECREF(key);
}
_PyObject_GC_TRACK(result);
return result;
}

Expand Down Expand Up @@ -2037,7 +2059,8 @@ static PyObject *
set_symmetric_difference_impl(PySetObject *so, PyObject *other)
/*[clinic end generated code: output=270ee0b5d42b0797 input=624f6e7bbdf70db1]*/
{
PySetObject *result = (PySetObject *)make_new_set_basetype(Py_TYPE(so), NULL);
PySetObject *result =
(PySetObject *)make_new_set_basetype_untracked(Py_TYPE(so), NULL);
if (result == NULL) {
return NULL;
}
Expand All @@ -2049,6 +2072,7 @@ set_symmetric_difference_impl(PySetObject *so, PyObject *other)
Py_DECREF(result);
return NULL;
}
_PyObject_GC_TRACK(result);
return (PyObject *)result;
}

Expand Down
Loading