Skip to content

Commit

Permalink
pythongh-121546: Disable contextvar caching on free-threading build (p…
Browse files Browse the repository at this point in the history
  • Loading branch information
Fidget-Spinner committed Jul 15, 2024
1 parent 6b98b27 commit e904300
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 0 deletions.
2 changes: 2 additions & 0 deletions Include/internal/pycore_context.h
Original file line number Diff line number Diff line change
Expand Up @@ -35,9 +35,11 @@ struct _pycontextvarobject {
PyObject_HEAD
PyObject *var_name;
PyObject *var_default;
#ifndef Py_GIL_DISABLED
PyObject *var_cached;
uint64_t var_cached_tsid;
uint64_t var_cached_tsver;
#endif
Py_hash_t var_hash;
};

Expand Down
14 changes: 14 additions & 0 deletions Python/context.c
Original file line number Diff line number Diff line change
Expand Up @@ -203,13 +203,15 @@ PyContextVar_Get(PyObject *ovar, PyObject *def, PyObject **val)
goto not_found;
}

#ifndef Py_GIL_DISABLED
if (var->var_cached != NULL &&
var->var_cached_tsid == ts->id &&
var->var_cached_tsver == ts->context_ver)
{
*val = var->var_cached;
goto found;
}
#endif

assert(PyContext_CheckExact(ts->context));
PyHamtObject *vars = ((PyContext *)ts->context)->ctx_vars;
Expand All @@ -221,9 +223,11 @@ PyContextVar_Get(PyObject *ovar, PyObject *def, PyObject **val)
}
if (res == 1) {
assert(found != NULL);
#ifndef Py_GIL_DISABLED
var->var_cached = found; /* borrow */
var->var_cached_tsid = ts->id;
var->var_cached_tsver = ts->context_ver;
#endif

*val = found;
goto found;
Expand Down Expand Up @@ -723,8 +727,10 @@ PyTypeObject PyContext_Type = {
static int
contextvar_set(PyContextVar *var, PyObject *val)
{
#ifndef Py_GIL_DISABLED
var->var_cached = NULL;
PyThreadState *ts = _PyThreadState_GET();
#endif

PyContext *ctx = context_get();
if (ctx == NULL) {
Expand All @@ -739,16 +745,20 @@ contextvar_set(PyContextVar *var, PyObject *val)

Py_SETREF(ctx->ctx_vars, new_vars);

#ifndef Py_GIL_DISABLED
var->var_cached = val; /* borrow */
var->var_cached_tsid = ts->id;
var->var_cached_tsver = ts->context_ver;
#endif
return 0;
}

static int
contextvar_del(PyContextVar *var)
{
#ifndef Py_GIL_DISABLED
var->var_cached = NULL;
#endif

PyContext *ctx = context_get();
if (ctx == NULL) {
Expand Down Expand Up @@ -823,9 +833,11 @@ contextvar_new(PyObject *name, PyObject *def)

var->var_default = Py_XNewRef(def);

#ifndef Py_GIL_DISABLED
var->var_cached = NULL;
var->var_cached_tsid = 0;
var->var_cached_tsver = 0;
#endif

if (_PyObject_GC_MAY_BE_TRACKED(name) ||
(def != NULL && _PyObject_GC_MAY_BE_TRACKED(def)))
Expand Down Expand Up @@ -863,9 +875,11 @@ contextvar_tp_clear(PyContextVar *self)
{
Py_CLEAR(self->var_name);
Py_CLEAR(self->var_default);
#ifndef Py_GIL_DISABLED
self->var_cached = NULL;
self->var_cached_tsid = 0;
self->var_cached_tsver = 0;
#endif
return 0;
}

Expand Down

0 comments on commit e904300

Please sign in to comment.