Skip to content

gh-100344: Provide C implementation for asyncio.current_task #100345

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
kumaraditya303 merged 11 commits into from
Dec 22, 2022
Merged

gh-100344: Provide C implementation for asyncio.current_task #100345

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
76cbbc6
gh-100344: Provide C implementation for asyncio.current_task
itamaro Sep 18, 2022
c7af32b
Merge branch 'main' into asyncio-current-task-native-impl
itamaro Dec 20, 2022
5f33beb
Fix refleak in C impl of current_task
itamaro Dec 20, 2022
37072a1
Optimize also the common case of the Python implementation of asyncio…
itamaro Dec 20, 2022
5a8a8fd
Merge branch 'main' into asyncio-current-task-native-impl
itamaro Dec 20, 2022
8f0f80a
Catch more specific KeyError exception
itamaro Dec 21, 2022
04bf985
Merge branch 'main' into asyncio-current-task-native-impl
itamaro Dec 21, 2022
637dfa7
Merge branch 'main' into asyncio-current-task-native-impl
itamaro Dec 21, 2022
c96db2c
Adjust CurrentLoopTests to cover both C and Python implementations of…
itamaro Dec 21, 2022
bdeb553
Merge branch 'main' into asyncio-current-task-native-impl
itamaro Dec 22, 2022
391db59
Revert optimizations in Python implementation of asyncio.current_task
itamaro Dec 22, 2022
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
Prev Previous commit
Next Next commit
Merge branch 'main' into asyncio-current-task-native-impl
  • Loading branch information
@itamaro
itamaro committed Dec 21, 2022
commit 637dfa7b3870850395e4f97b394a81db16e81a94
73 changes: 0 additions & 73 deletions Modules/_asynciomodule.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3352,79 +3352,6 @@ _asyncio_current_task_impl(PyObject *module, PyObject *loop)
}


/*********************** PyRunningLoopHolder ********************/


static PyRunningLoopHolder *
new_running_loop_holder(asyncio_state *state, PyObject *loop)
{
PyRunningLoopHolder *rl = PyObject_GC_New(
PyRunningLoopHolder, state->PyRunningLoopHolder_Type);
if (rl == NULL) {
return NULL;
}

#if defined(HAVE_GETPID) && !defined(MS_WINDOWS)
rl->rl_pid = getpid();
#endif
rl->rl_loop = Py_NewRef(loop);

PyObject_GC_Track(rl);
return rl;
}


static int
PyRunningLoopHolder_clear(PyRunningLoopHolder *rl)
{
Py_CLEAR(rl->rl_loop);
return 0;
}


static int
PyRunningLoopHolder_traverse(PyRunningLoopHolder *rl, visitproc visit,
void *arg)
{
Py_VISIT(Py_TYPE(rl));
Py_VISIT(rl->rl_loop);
return 0;
}


static void
PyRunningLoopHolder_tp_dealloc(PyRunningLoopHolder *rl)
{
asyncio_state *state = get_asyncio_state_by_def((PyObject *)rl);
if (state->cached_running_holder == (PyObject *)rl) {
state->cached_running_holder = NULL;
}
PyTypeObject *tp = Py_TYPE(rl);
PyObject_GC_UnTrack(rl);
PyRunningLoopHolder_clear(rl);
PyObject_GC_Del(rl);
Py_DECREF(tp);
}


static PyType_Slot PyRunningLoopHolder_slots[] = {
{Py_tp_getattro, PyObject_GenericGetAttr},
{Py_tp_dealloc, (destructor)PyRunningLoopHolder_tp_dealloc},
{Py_tp_traverse, (traverseproc)PyRunningLoopHolder_traverse},
{Py_tp_clear, PyRunningLoopHolder_clear},
{0, NULL},
};


static PyType_Spec PyRunningLoopHolder_spec = {
.name = "_asyncio._RunningLoopHolder",
.basicsize = sizeof(PyRunningLoopHolder),
.slots = PyRunningLoopHolder_slots,
.flags = (Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
Py_TPFLAGS_IMMUTABLETYPE),
};


/*********************** Module **************************/


Expand Down
You are viewing a condensed version of this merge commit. You can view the full changes here.