2016-10-09 02:44:47 -03:00
|
|
|
#include "Python.h"
|
|
|
|
#include "structmember.h"
|
|
|
|
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
module _asyncio
|
|
|
|
[clinic start generated code]*/
|
|
|
|
/*[clinic end generated code: output=da39a3ee5e6b4b0d input=8fd17862aa989c69]*/
|
|
|
|
|
|
|
|
|
2016-10-09 02:44:47 -03:00
|
|
|
/* identifiers used from some functions */
|
2016-10-28 13:52:37 -03:00
|
|
|
_Py_IDENTIFIER(add_done_callback);
|
2016-10-09 02:44:47 -03:00
|
|
|
_Py_IDENTIFIER(call_soon);
|
2016-10-28 13:52:37 -03:00
|
|
|
_Py_IDENTIFIER(cancel);
|
|
|
|
_Py_IDENTIFIER(send);
|
|
|
|
_Py_IDENTIFIER(throw);
|
|
|
|
_Py_IDENTIFIER(_step);
|
|
|
|
_Py_IDENTIFIER(_schedule_callbacks);
|
|
|
|
_Py_IDENTIFIER(_wakeup);
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
|
2016-10-15 03:39:19 -03:00
|
|
|
/* State of the _asyncio module */
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *all_tasks;
|
2016-10-28 20:01:21 -03:00
|
|
|
static PyObject *current_tasks;
|
2016-10-09 02:44:47 -03:00
|
|
|
static PyObject *traceback_extract_stack;
|
|
|
|
static PyObject *asyncio_get_event_loop;
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *asyncio_future_repr_info_func;
|
|
|
|
static PyObject *asyncio_task_repr_info_func;
|
|
|
|
static PyObject *asyncio_task_get_stack_func;
|
|
|
|
static PyObject *asyncio_task_print_stack_func;
|
2016-10-09 02:44:47 -03:00
|
|
|
static PyObject *asyncio_InvalidStateError;
|
|
|
|
static PyObject *asyncio_CancelledError;
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *inspect_isgenerator;
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
|
|
|
|
typedef enum {
|
|
|
|
STATE_PENDING,
|
|
|
|
STATE_CANCELLED,
|
|
|
|
STATE_FINISHED
|
|
|
|
} fut_state;
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
#define FutureObj_HEAD(prefix) \
|
|
|
|
PyObject_HEAD \
|
|
|
|
PyObject *prefix##_loop; \
|
|
|
|
PyObject *prefix##_callbacks; \
|
|
|
|
PyObject *prefix##_exception; \
|
|
|
|
PyObject *prefix##_result; \
|
|
|
|
PyObject *prefix##_source_tb; \
|
|
|
|
fut_state prefix##_state; \
|
|
|
|
int prefix##_log_tb; \
|
|
|
|
int prefix##_blocking; \
|
|
|
|
PyObject *dict; \
|
|
|
|
PyObject *prefix##_weakreflist;
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
typedef struct {
|
2016-10-28 13:52:37 -03:00
|
|
|
FutureObj_HEAD(fut)
|
2016-10-09 02:44:47 -03:00
|
|
|
} FutureObj;
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
typedef struct {
|
|
|
|
FutureObj_HEAD(task)
|
|
|
|
PyObject *task_fut_waiter;
|
|
|
|
PyObject *task_coro;
|
|
|
|
int task_must_cancel;
|
|
|
|
int task_log_destroy_pending;
|
|
|
|
} TaskObj;
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
PyObject_HEAD
|
|
|
|
TaskObj *sw_task;
|
|
|
|
PyObject *sw_arg;
|
|
|
|
} TaskSendMethWrapper;
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
PyObject_HEAD
|
|
|
|
TaskObj *ww_task;
|
|
|
|
} TaskWakeupMethWrapper;
|
|
|
|
|
|
|
|
|
|
|
|
#include "clinic/_asynciomodule.c.h"
|
|
|
|
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
class _asyncio.Future "FutureObj *" "&Future_Type"
|
|
|
|
[clinic start generated code]*/
|
|
|
|
/*[clinic end generated code: output=da39a3ee5e6b4b0d input=00d3e4abca711e0f]*/
|
|
|
|
|
|
|
|
/* Get FutureIter from Future */
|
|
|
|
static PyObject* future_new_iter(PyObject *);
|
|
|
|
static inline int future_call_schedule_callbacks(FutureObj *);
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
static int
|
2016-10-28 13:52:37 -03:00
|
|
|
future_schedule_callbacks(FutureObj *fut)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
Py_ssize_t len;
|
|
|
|
PyObject* iters;
|
|
|
|
int i;
|
|
|
|
|
|
|
|
if (fut->fut_callbacks == NULL) {
|
|
|
|
PyErr_SetString(PyExc_RuntimeError, "NULL callbacks");
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
len = PyList_GET_SIZE(fut->fut_callbacks);
|
|
|
|
if (len == 0) {
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
iters = PyList_GetSlice(fut->fut_callbacks, 0, len);
|
|
|
|
if (iters == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
if (PyList_SetSlice(fut->fut_callbacks, 0, len, NULL) < 0) {
|
|
|
|
Py_DECREF(iters);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (i = 0; i < len; i++) {
|
|
|
|
PyObject *handle = NULL;
|
|
|
|
PyObject *cb = PyList_GET_ITEM(iters, i);
|
|
|
|
|
|
|
|
handle = _PyObject_CallMethodId(
|
|
|
|
fut->fut_loop, &PyId_call_soon, "OO", cb, fut, NULL);
|
|
|
|
|
|
|
|
if (handle == NULL) {
|
|
|
|
Py_DECREF(iters);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_DECREF(handle);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_DECREF(iters);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
2016-10-28 13:52:37 -03:00
|
|
|
future_init(FutureObj *fut, PyObject *loop)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
PyObject *res = NULL;
|
|
|
|
_Py_IDENTIFIER(get_debug);
|
|
|
|
|
|
|
|
if (loop == NULL || loop == Py_None) {
|
|
|
|
loop = PyObject_CallObject(asyncio_get_event_loop, NULL);
|
|
|
|
if (loop == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_INCREF(loop);
|
|
|
|
}
|
|
|
|
Py_CLEAR(fut->fut_loop);
|
|
|
|
fut->fut_loop = loop;
|
|
|
|
|
2016-10-29 04:05:39 -03:00
|
|
|
res = _PyObject_CallMethodId(fut->fut_loop, &PyId_get_debug, NULL);
|
2016-10-09 02:44:47 -03:00
|
|
|
if (res == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
if (PyObject_IsTrue(res)) {
|
|
|
|
Py_CLEAR(res);
|
|
|
|
fut->fut_source_tb = PyObject_CallObject(traceback_extract_stack, NULL);
|
|
|
|
if (fut->fut_source_tb == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_CLEAR(res);
|
|
|
|
}
|
|
|
|
|
|
|
|
fut->fut_callbacks = PyList_New(0);
|
|
|
|
if (fut->fut_callbacks == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
future_set_result(FutureObj *fut, PyObject *res)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
if (fut->fut_state != STATE_PENDING) {
|
|
|
|
PyErr_SetString(asyncio_InvalidStateError, "invalid state");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_INCREF(res);
|
|
|
|
fut->fut_result = res;
|
|
|
|
fut->fut_state = STATE_FINISHED;
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
if (future_call_schedule_callbacks(fut) == -1) {
|
2016-10-09 02:44:47 -03:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
future_set_exception(FutureObj *fut, PyObject *exc)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
PyObject *exc_val = NULL;
|
|
|
|
|
|
|
|
if (fut->fut_state != STATE_PENDING) {
|
|
|
|
PyErr_SetString(asyncio_InvalidStateError, "invalid state");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (PyExceptionClass_Check(exc)) {
|
|
|
|
exc_val = PyObject_CallObject(exc, NULL);
|
|
|
|
if (exc_val == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
exc_val = exc;
|
|
|
|
Py_INCREF(exc_val);
|
|
|
|
}
|
|
|
|
if (!PyExceptionInstance_Check(exc_val)) {
|
|
|
|
Py_DECREF(exc_val);
|
|
|
|
PyErr_SetString(PyExc_TypeError, "invalid exception object");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if ((PyObject*)Py_TYPE(exc_val) == PyExc_StopIteration) {
|
|
|
|
Py_DECREF(exc_val);
|
|
|
|
PyErr_SetString(PyExc_TypeError,
|
|
|
|
"StopIteration interacts badly with generators "
|
|
|
|
"and cannot be raised into a Future");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
fut->fut_exception = exc_val;
|
|
|
|
fut->fut_state = STATE_FINISHED;
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
if (future_call_schedule_callbacks(fut) == -1) {
|
2016-10-09 02:44:47 -03:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
fut->fut_log_tb = 1;
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static int
|
|
|
|
future_get_result(FutureObj *fut, PyObject **result)
|
|
|
|
{
|
|
|
|
PyObject *exc;
|
|
|
|
|
|
|
|
if (fut->fut_state == STATE_CANCELLED) {
|
|
|
|
exc = _PyObject_CallNoArg(asyncio_CancelledError);
|
|
|
|
if (exc == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
*result = exc;
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (fut->fut_state != STATE_FINISHED) {
|
|
|
|
PyObject *msg = PyUnicode_FromString("Result is not ready.");
|
|
|
|
if (msg == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
exc = _PyObject_CallArg1(asyncio_InvalidStateError, msg);
|
|
|
|
Py_DECREF(msg);
|
|
|
|
if (exc == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
*result = exc;
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
fut->fut_log_tb = 0;
|
|
|
|
if (fut->fut_exception != NULL) {
|
|
|
|
Py_INCREF(fut->fut_exception);
|
|
|
|
*result = fut->fut_exception;
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_INCREF(fut->fut_result);
|
|
|
|
*result = fut->fut_result;
|
|
|
|
return 0;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
future_add_done_callback(FutureObj *fut, PyObject *arg)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
if (fut->fut_state != STATE_PENDING) {
|
|
|
|
PyObject *handle = _PyObject_CallMethodId(
|
|
|
|
fut->fut_loop, &PyId_call_soon, "OO", arg, fut, NULL);
|
|
|
|
|
|
|
|
if (handle == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_DECREF(handle);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
int err = PyList_Append(fut->fut_callbacks, arg);
|
|
|
|
if (err != 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
future_cancel(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_state != STATE_PENDING) {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
fut->fut_state = STATE_CANCELLED;
|
|
|
|
|
|
|
|
if (future_call_schedule_callbacks(fut) == -1) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.__init__
|
|
|
|
|
|
|
|
*
|
|
|
|
loop: 'O' = NULL
|
|
|
|
|
|
|
|
This class is *almost* compatible with concurrent.futures.Future.
|
|
|
|
|
|
|
|
Differences:
|
|
|
|
|
|
|
|
- result() and exception() do not take a timeout argument and
|
|
|
|
raise an exception when the future isn't done yet.
|
|
|
|
|
|
|
|
- Callbacks registered with add_done_callback() are always called
|
|
|
|
via the event loop's call_soon_threadsafe().
|
|
|
|
|
|
|
|
- This class is not compatible with the wait() and as_completed()
|
|
|
|
methods in the concurrent.futures package.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static int
|
|
|
|
_asyncio_Future___init___impl(FutureObj *self, PyObject *loop)
|
|
|
|
/*[clinic end generated code: output=9ed75799eaccb5d6 input=8e1681f23605be2d]*/
|
|
|
|
|
|
|
|
{
|
|
|
|
return future_init(self, loop);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
FutureObj_clear(FutureObj *fut)
|
|
|
|
{
|
|
|
|
Py_CLEAR(fut->fut_loop);
|
|
|
|
Py_CLEAR(fut->fut_callbacks);
|
|
|
|
Py_CLEAR(fut->fut_result);
|
|
|
|
Py_CLEAR(fut->fut_exception);
|
|
|
|
Py_CLEAR(fut->fut_source_tb);
|
|
|
|
Py_CLEAR(fut->dict);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
FutureObj_traverse(FutureObj *fut, visitproc visit, void *arg)
|
|
|
|
{
|
|
|
|
Py_VISIT(fut->fut_loop);
|
|
|
|
Py_VISIT(fut->fut_callbacks);
|
|
|
|
Py_VISIT(fut->fut_result);
|
|
|
|
Py_VISIT(fut->fut_exception);
|
|
|
|
Py_VISIT(fut->fut_source_tb);
|
|
|
|
Py_VISIT(fut->dict);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.result
|
|
|
|
|
|
|
|
Return the result this future represents.
|
|
|
|
|
|
|
|
If the future has been cancelled, raises CancelledError. If the
|
|
|
|
future's result isn't yet available, raises InvalidStateError. If
|
|
|
|
the future is done and has an exception set, this exception is raised.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_result_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=f35f940936a4b1e5 input=49ecf9cf5ec50dc5]*/
|
|
|
|
{
|
|
|
|
PyObject *result;
|
|
|
|
int res = future_get_result(self, &result);
|
|
|
|
|
|
|
|
if (res == -1) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (res == 0) {
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
|
|
|
assert(res == 1);
|
|
|
|
|
|
|
|
PyErr_SetObject(PyExceptionInstance_Class(result), result);
|
|
|
|
Py_DECREF(result);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.exception
|
|
|
|
|
|
|
|
Return the exception that was set on this future.
|
|
|
|
|
|
|
|
The exception (or None if no exception was set) is returned only if
|
|
|
|
the future is done. If the future has been cancelled, raises
|
|
|
|
CancelledError. If the future isn't done yet, raises
|
|
|
|
InvalidStateError.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_exception_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=88b20d4f855e0710 input=733547a70c841c68]*/
|
|
|
|
{
|
|
|
|
if (self->fut_state == STATE_CANCELLED) {
|
|
|
|
PyErr_SetString(asyncio_CancelledError, "");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (self->fut_state != STATE_FINISHED) {
|
|
|
|
PyErr_SetString(asyncio_InvalidStateError, "Result is not ready.");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (self->fut_exception != NULL) {
|
|
|
|
self->fut_log_tb = 0;
|
|
|
|
Py_INCREF(self->fut_exception);
|
|
|
|
return self->fut_exception;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.set_result
|
|
|
|
|
|
|
|
res: 'O'
|
|
|
|
/
|
|
|
|
|
|
|
|
Mark the future done and set its result.
|
|
|
|
|
|
|
|
If the future is already done when this method is called, raises
|
|
|
|
InvalidStateError.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_set_result(FutureObj *self, PyObject *res)
|
|
|
|
/*[clinic end generated code: output=a620abfc2796bfb6 input=8619565e0503357e]*/
|
|
|
|
{
|
|
|
|
return future_set_result(self, res);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.set_exception
|
|
|
|
|
|
|
|
exception: 'O'
|
|
|
|
/
|
|
|
|
|
|
|
|
Mark the future done and set an exception.
|
|
|
|
|
|
|
|
If the future is already done when this method is called, raises
|
|
|
|
InvalidStateError.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_set_exception(FutureObj *self, PyObject *exception)
|
|
|
|
/*[clinic end generated code: output=f1c1b0cd321be360 input=1377dbe15e6ea186]*/
|
|
|
|
{
|
|
|
|
return future_set_exception(self, exception);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.add_done_callback
|
|
|
|
|
|
|
|
fn: 'O'
|
|
|
|
/
|
|
|
|
|
|
|
|
Add a callback to be run when the future becomes done.
|
|
|
|
|
|
|
|
The callback is called with a single argument - the future object. If
|
|
|
|
the future is already done when this is called, the callback is
|
|
|
|
scheduled with call_soon.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_add_done_callback(FutureObj *self, PyObject *fn)
|
|
|
|
/*[clinic end generated code: output=819e09629b2ec2b5 input=8cce187e32cec6a8]*/
|
|
|
|
{
|
|
|
|
return future_add_done_callback(self, fn);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.remove_done_callback
|
|
|
|
|
|
|
|
fn: 'O'
|
|
|
|
/
|
|
|
|
|
|
|
|
Remove all instances of a callback from the "call when done" list.
|
|
|
|
|
|
|
|
Returns the number of callbacks removed.
|
|
|
|
[clinic start generated code]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
_asyncio_Future_remove_done_callback(FutureObj *self, PyObject *fn)
|
|
|
|
/*[clinic end generated code: output=5ab1fb52b24ef31f input=3fedb73e1409c31c]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
PyObject *newlist;
|
|
|
|
Py_ssize_t len, i, j=0;
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
len = PyList_GET_SIZE(self->fut_callbacks);
|
2016-10-09 02:44:47 -03:00
|
|
|
if (len == 0) {
|
|
|
|
return PyLong_FromSsize_t(0);
|
|
|
|
}
|
|
|
|
|
|
|
|
newlist = PyList_New(len);
|
|
|
|
if (newlist == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (i = 0; i < len; i++) {
|
|
|
|
int ret;
|
2016-10-28 13:52:37 -03:00
|
|
|
PyObject *item = PyList_GET_ITEM(self->fut_callbacks, i);
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
if ((ret = PyObject_RichCompareBool(fn, item, Py_EQ)) < 0) {
|
2016-10-09 02:44:47 -03:00
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
if (ret == 0) {
|
|
|
|
Py_INCREF(item);
|
|
|
|
PyList_SET_ITEM(newlist, j, item);
|
|
|
|
j++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (PyList_SetSlice(newlist, j, len, NULL) < 0) {
|
|
|
|
goto fail;
|
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
if (PyList_SetSlice(self->fut_callbacks, 0, len, newlist) < 0) {
|
2016-10-09 02:44:47 -03:00
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
Py_DECREF(newlist);
|
|
|
|
return PyLong_FromSsize_t(len - j);
|
|
|
|
|
|
|
|
fail:
|
|
|
|
Py_DECREF(newlist);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.cancel
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
Cancel the future and schedule callbacks.
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
If the future is already done or cancelled, return False. Otherwise,
|
|
|
|
change the future's state to cancelled, schedule the callbacks and
|
|
|
|
return True.
|
|
|
|
[clinic start generated code]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future_cancel_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=e45b932ba8bd68a1 input=515709a127995109]*/
|
|
|
|
{
|
|
|
|
return future_cancel(self);
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.cancelled
|
|
|
|
|
|
|
|
Return True if the future was cancelled.
|
|
|
|
[clinic start generated code]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
_asyncio_Future_cancelled_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=145197ced586357d input=943ab8b7b7b17e45]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
if (self->fut_state == STATE_CANCELLED) {
|
2016-10-09 02:44:47 -03:00
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future.done
|
|
|
|
|
|
|
|
Return True if the future is done.
|
|
|
|
|
|
|
|
Done means either that a result / exception are available, or that the
|
|
|
|
future was cancelled.
|
|
|
|
[clinic start generated code]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
_asyncio_Future_done_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=244c5ac351145096 input=28d7b23fdb65d2ac]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
if (self->fut_state == STATE_PENDING) {
|
2016-10-09 02:44:47 -03:00
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_blocking(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_blocking) {
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
FutureObj_set_blocking(FutureObj *fut, PyObject *val)
|
|
|
|
{
|
|
|
|
int is_true = PyObject_IsTrue(val);
|
|
|
|
if (is_true < 0) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
fut->fut_blocking = is_true;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_log_traceback(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_log_tb) {
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_loop(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_loop == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut->fut_loop);
|
|
|
|
return fut->fut_loop;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_callbacks(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_callbacks == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut->fut_callbacks);
|
|
|
|
return fut->fut_callbacks;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_result(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_result == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut->fut_result);
|
|
|
|
return fut->fut_result;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_exception(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_exception == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut->fut_exception);
|
|
|
|
return fut->fut_exception;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_source_traceback(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (fut->fut_source_tb == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut->fut_source_tb);
|
|
|
|
return fut->fut_source_tb;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_get_state(FutureObj *fut)
|
|
|
|
{
|
|
|
|
_Py_IDENTIFIER(PENDING);
|
|
|
|
_Py_IDENTIFIER(CANCELLED);
|
|
|
|
_Py_IDENTIFIER(FINISHED);
|
|
|
|
PyObject *ret = NULL;
|
|
|
|
|
|
|
|
switch (fut->fut_state) {
|
|
|
|
case STATE_PENDING:
|
|
|
|
ret = _PyUnicode_FromId(&PyId_PENDING);
|
|
|
|
break;
|
|
|
|
case STATE_CANCELLED:
|
|
|
|
ret = _PyUnicode_FromId(&PyId_CANCELLED);
|
|
|
|
break;
|
|
|
|
case STATE_FINISHED:
|
|
|
|
ret = _PyUnicode_FromId(&PyId_FINISHED);
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
assert (0);
|
|
|
|
}
|
|
|
|
Py_INCREF(ret);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future._repr_info
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future__repr_info_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=fa69e901bd176cfb input=f21504d8e2ae1ca2]*/
|
|
|
|
{
|
|
|
|
return PyObject_CallFunctionObjArgs(
|
|
|
|
asyncio_future_repr_info_func, self, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Future._schedule_callbacks
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Future__schedule_callbacks_impl(FutureObj *self)
|
|
|
|
/*[clinic end generated code: output=5e8958d89ea1c5dc input=4f5f295f263f4a88]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
int ret = future_schedule_callbacks(self);
|
|
|
|
if (ret == -1) {
|
|
|
|
return NULL;
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_RETURN_NONE;
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureObj_repr(FutureObj *fut)
|
|
|
|
{
|
|
|
|
_Py_IDENTIFIER(_repr_info);
|
|
|
|
|
|
|
|
PyObject *_repr_info = _PyUnicode_FromId(&PyId__repr_info); // borrowed
|
|
|
|
if (_repr_info == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *rinfo = PyObject_CallMethodObjArgs((PyObject*)fut, _repr_info,
|
|
|
|
NULL);
|
|
|
|
if (rinfo == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *sp = PyUnicode_FromString(" ");
|
|
|
|
if (sp == NULL) {
|
|
|
|
Py_DECREF(rinfo);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *rinfo_s = PyUnicode_Join(sp, rinfo);
|
|
|
|
Py_DECREF(sp);
|
|
|
|
Py_DECREF(rinfo);
|
|
|
|
if (rinfo_s == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *rstr = NULL;
|
|
|
|
PyObject *type_name = PyObject_GetAttrString((PyObject*)Py_TYPE(fut),
|
|
|
|
"__name__");
|
|
|
|
if (type_name != NULL) {
|
|
|
|
rstr = PyUnicode_FromFormat("<%S %S>", type_name, rinfo_s);
|
|
|
|
Py_DECREF(type_name);
|
|
|
|
}
|
|
|
|
Py_DECREF(rinfo_s);
|
|
|
|
return rstr;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
FutureObj_finalize(FutureObj *fut)
|
|
|
|
{
|
|
|
|
_Py_IDENTIFIER(call_exception_handler);
|
|
|
|
_Py_IDENTIFIER(message);
|
|
|
|
_Py_IDENTIFIER(exception);
|
|
|
|
_Py_IDENTIFIER(future);
|
|
|
|
_Py_IDENTIFIER(source_traceback);
|
|
|
|
|
|
|
|
if (!fut->fut_log_tb) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
assert(fut->fut_exception != NULL);
|
|
|
|
fut->fut_log_tb = 0;;
|
|
|
|
|
|
|
|
PyObject *error_type, *error_value, *error_traceback;
|
|
|
|
/* Save the current exception, if any. */
|
|
|
|
PyErr_Fetch(&error_type, &error_value, &error_traceback);
|
|
|
|
|
|
|
|
PyObject *context = NULL;
|
|
|
|
PyObject *type_name = NULL;
|
|
|
|
PyObject *message = NULL;
|
|
|
|
PyObject *func = NULL;
|
|
|
|
PyObject *res = NULL;
|
|
|
|
|
|
|
|
context = PyDict_New();
|
|
|
|
if (context == NULL) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
type_name = PyObject_GetAttrString((PyObject*)Py_TYPE(fut), "__name__");
|
|
|
|
if (type_name == NULL) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
message = PyUnicode_FromFormat(
|
|
|
|
"%S exception was never retrieved", type_name);
|
|
|
|
if (message == NULL) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (_PyDict_SetItemId(context, &PyId_message, message) < 0 ||
|
|
|
|
_PyDict_SetItemId(context, &PyId_exception, fut->fut_exception) < 0 ||
|
|
|
|
_PyDict_SetItemId(context, &PyId_future, (PyObject*)fut) < 0) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
if (fut->fut_source_tb != NULL) {
|
|
|
|
if (_PyDict_SetItemId(context, &PyId_source_traceback,
|
|
|
|
fut->fut_source_tb) < 0) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func = _PyObject_GetAttrId(fut->fut_loop, &PyId_call_exception_handler);
|
|
|
|
if (func != NULL) {
|
|
|
|
res = _PyObject_CallArg1(func, context);
|
|
|
|
if (res == NULL) {
|
|
|
|
PyErr_WriteUnraisable(func);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
finally:
|
|
|
|
Py_CLEAR(context);
|
|
|
|
Py_CLEAR(type_name);
|
|
|
|
Py_CLEAR(message);
|
|
|
|
Py_CLEAR(func);
|
|
|
|
Py_CLEAR(res);
|
|
|
|
|
|
|
|
/* Restore the saved exception. */
|
|
|
|
PyErr_Restore(error_type, error_value, error_traceback);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
static PyAsyncMethods FutureType_as_async = {
|
2016-10-28 13:52:37 -03:00
|
|
|
(unaryfunc)future_new_iter, /* am_await */
|
2016-10-09 02:44:47 -03:00
|
|
|
0, /* am_aiter */
|
|
|
|
0 /* am_anext */
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyMethodDef FutureType_methods[] = {
|
2016-10-28 13:52:37 -03:00
|
|
|
_ASYNCIO_FUTURE_RESULT_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_EXCEPTION_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_SET_RESULT_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_SET_EXCEPTION_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_ADD_DONE_CALLBACK_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_REMOVE_DONE_CALLBACK_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_CANCEL_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_CANCELLED_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_DONE_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE__REPR_INFO_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE__SCHEDULE_CALLBACKS_METHODDEF
|
2016-10-09 02:44:47 -03:00
|
|
|
{NULL, NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
#define FUTURE_COMMON_GETSETLIST \
|
|
|
|
{"_state", (getter)FutureObj_get_state, NULL, NULL}, \
|
|
|
|
{"_asyncio_future_blocking", (getter)FutureObj_get_blocking, \
|
|
|
|
(setter)FutureObj_set_blocking, NULL}, \
|
|
|
|
{"_loop", (getter)FutureObj_get_loop, NULL, NULL}, \
|
|
|
|
{"_callbacks", (getter)FutureObj_get_callbacks, NULL, NULL}, \
|
|
|
|
{"_result", (getter)FutureObj_get_result, NULL, NULL}, \
|
|
|
|
{"_exception", (getter)FutureObj_get_exception, NULL, NULL}, \
|
|
|
|
{"_log_traceback", (getter)FutureObj_get_log_traceback, NULL, NULL}, \
|
2016-10-09 02:44:47 -03:00
|
|
|
{"_source_traceback", (getter)FutureObj_get_source_traceback, NULL, NULL},
|
2016-10-28 13:52:37 -03:00
|
|
|
|
|
|
|
static PyGetSetDef FutureType_getsetlist[] = {
|
|
|
|
FUTURE_COMMON_GETSETLIST
|
2016-10-09 02:44:47 -03:00
|
|
|
{NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
|
|
|
static void FutureObj_dealloc(PyObject *self);
|
|
|
|
|
|
|
|
static PyTypeObject FutureType = {
|
2016-10-28 14:13:52 -03:00
|
|
|
PyVarObject_HEAD_INIT(NULL, 0)
|
2016-10-15 03:39:19 -03:00
|
|
|
"_asyncio.Future",
|
2016-10-09 02:44:47 -03:00
|
|
|
sizeof(FutureObj), /* tp_basicsize */
|
|
|
|
.tp_dealloc = FutureObj_dealloc,
|
|
|
|
.tp_as_async = &FutureType_as_async,
|
|
|
|
.tp_repr = (reprfunc)FutureObj_repr,
|
|
|
|
.tp_flags = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC | Py_TPFLAGS_BASETYPE
|
|
|
|
| Py_TPFLAGS_HAVE_FINALIZE,
|
2016-10-28 13:52:37 -03:00
|
|
|
.tp_doc = _asyncio_Future___init____doc__,
|
2016-10-09 02:44:47 -03:00
|
|
|
.tp_traverse = (traverseproc)FutureObj_traverse,
|
|
|
|
.tp_clear = (inquiry)FutureObj_clear,
|
|
|
|
.tp_weaklistoffset = offsetof(FutureObj, fut_weakreflist),
|
2016-10-28 13:52:37 -03:00
|
|
|
.tp_iter = (getiterfunc)future_new_iter,
|
2016-10-09 02:44:47 -03:00
|
|
|
.tp_methods = FutureType_methods,
|
|
|
|
.tp_getset = FutureType_getsetlist,
|
|
|
|
.tp_dictoffset = offsetof(FutureObj, dict),
|
2016-10-28 13:52:37 -03:00
|
|
|
.tp_init = (initproc)_asyncio_Future___init__,
|
2016-10-09 02:44:47 -03:00
|
|
|
.tp_new = PyType_GenericNew,
|
|
|
|
.tp_finalize = (destructor)FutureObj_finalize,
|
|
|
|
};
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
#define Future_CheckExact(obj) (Py_TYPE(obj) == &FutureType)
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static inline int
|
|
|
|
future_call_schedule_callbacks(FutureObj *fut)
|
|
|
|
{
|
|
|
|
if (Future_CheckExact(fut)) {
|
|
|
|
return future_schedule_callbacks(fut);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
/* `fut` is a subclass of Future */
|
|
|
|
PyObject *ret = _PyObject_CallMethodId(
|
|
|
|
(PyObject*)fut, &PyId__schedule_callbacks, NULL);
|
|
|
|
if (ret == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_DECREF(ret);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
FutureObj_dealloc(PyObject *self)
|
|
|
|
{
|
|
|
|
FutureObj *fut = (FutureObj *)self;
|
|
|
|
|
|
|
|
if (Future_CheckExact(fut)) {
|
|
|
|
/* When fut is subclass of Future, finalizer is called from
|
2016-10-09 02:44:47 -03:00
|
|
|
* subtype_dealloc.
|
|
|
|
*/
|
|
|
|
if (PyObject_CallFinalizerFromDealloc(self) < 0) {
|
|
|
|
// resurrected.
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (fut->fut_weakreflist != NULL) {
|
|
|
|
PyObject_ClearWeakRefs(self);
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
(void)FutureObj_clear(fut);
|
2016-10-09 02:44:47 -03:00
|
|
|
Py_TYPE(fut)->tp_free(fut);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*********************** Future Iterator **************************/
|
|
|
|
|
|
|
|
typedef struct {
|
|
|
|
PyObject_HEAD
|
|
|
|
FutureObj *future;
|
|
|
|
} futureiterobject;
|
|
|
|
|
|
|
|
static void
|
|
|
|
FutureIter_dealloc(futureiterobject *it)
|
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
PyObject_GC_UnTrack(it);
|
2016-10-09 02:44:47 -03:00
|
|
|
Py_XDECREF(it->future);
|
|
|
|
PyObject_GC_Del(it);
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureIter_iternext(futureiterobject *it)
|
|
|
|
{
|
|
|
|
PyObject *res;
|
|
|
|
FutureObj *fut = it->future;
|
|
|
|
|
|
|
|
if (fut == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (fut->fut_state == STATE_PENDING) {
|
|
|
|
if (!fut->fut_blocking) {
|
|
|
|
fut->fut_blocking = 1;
|
|
|
|
Py_INCREF(fut);
|
|
|
|
return (PyObject *)fut;
|
|
|
|
}
|
|
|
|
PyErr_Format(PyExc_AssertionError,
|
|
|
|
"yield from wasn't used with future");
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
res = _asyncio_Future_result_impl(fut);
|
2016-10-09 02:44:47 -03:00
|
|
|
if (res != NULL) {
|
2016-10-20 16:54:20 -03:00
|
|
|
/* The result of the Future is not an exception.
|
|
|
|
|
2016-10-20 17:33:19 -03:00
|
|
|
We construct an exception instance manually with
|
2016-10-20 16:54:20 -03:00
|
|
|
PyObject_CallFunctionObjArgs and pass it to PyErr_SetObject
|
|
|
|
(similarly to what genobject.c does).
|
|
|
|
|
2016-10-20 17:33:19 -03:00
|
|
|
We do this to handle a situation when "res" is a tuple, in which
|
2016-10-20 16:54:20 -03:00
|
|
|
case PyErr_SetObject would set the value of StopIteration to
|
|
|
|
the first element of the tuple.
|
|
|
|
|
|
|
|
(See PyErr_SetObject/_PyErr_CreateException code for details.)
|
|
|
|
*/
|
|
|
|
PyObject *e = PyObject_CallFunctionObjArgs(
|
|
|
|
PyExc_StopIteration, res, NULL);
|
2016-10-09 02:44:47 -03:00
|
|
|
Py_DECREF(res);
|
2016-10-20 16:54:20 -03:00
|
|
|
if (e == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
PyErr_SetObject(PyExc_StopIteration, e);
|
|
|
|
Py_DECREF(e);
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
|
|
|
|
|
|
|
it->future = NULL;
|
|
|
|
Py_DECREF(fut);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
2016-10-25 07:00:45 -03:00
|
|
|
FutureIter_send(futureiterobject *self, PyObject *unused)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-25 07:00:45 -03:00
|
|
|
/* Future.__iter__ doesn't care about values that are pushed to the
|
|
|
|
* generator, it just returns "self.result().
|
|
|
|
*/
|
2016-10-09 02:44:47 -03:00
|
|
|
return FutureIter_iternext(self);
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureIter_throw(futureiterobject *self, PyObject *args)
|
|
|
|
{
|
|
|
|
PyObject *type=NULL, *val=NULL, *tb=NULL;
|
|
|
|
if (!PyArg_ParseTuple(args, "O|OO", &type, &val, &tb))
|
|
|
|
return NULL;
|
|
|
|
|
|
|
|
if (val == Py_None) {
|
|
|
|
val = NULL;
|
|
|
|
}
|
|
|
|
if (tb == Py_None) {
|
|
|
|
tb = NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_CLEAR(self->future);
|
|
|
|
|
|
|
|
if (tb != NULL) {
|
|
|
|
PyErr_Restore(type, val, tb);
|
|
|
|
}
|
|
|
|
else if (val != NULL) {
|
|
|
|
PyErr_SetObject(type, val);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
if (PyExceptionClass_Check(type)) {
|
|
|
|
val = PyObject_CallObject(type, NULL);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
val = type;
|
|
|
|
assert (PyExceptionInstance_Check(val));
|
|
|
|
type = (PyObject*)Py_TYPE(val);
|
|
|
|
assert (PyExceptionClass_Check(type));
|
|
|
|
}
|
|
|
|
PyErr_SetObject(type, val);
|
|
|
|
}
|
|
|
|
return FutureIter_iternext(self);
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
FutureIter_close(futureiterobject *self, PyObject *arg)
|
|
|
|
{
|
|
|
|
Py_CLEAR(self->future);
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
FutureIter_traverse(futureiterobject *it, visitproc visit, void *arg)
|
|
|
|
{
|
|
|
|
Py_VISIT(it->future);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyMethodDef FutureIter_methods[] = {
|
|
|
|
{"send", (PyCFunction)FutureIter_send, METH_O, NULL},
|
|
|
|
{"throw", (PyCFunction)FutureIter_throw, METH_VARARGS, NULL},
|
|
|
|
{"close", (PyCFunction)FutureIter_close, METH_NOARGS, NULL},
|
|
|
|
{NULL, NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyTypeObject FutureIterType = {
|
2016-10-28 14:13:52 -03:00
|
|
|
PyVarObject_HEAD_INIT(NULL, 0)
|
2016-10-15 03:39:19 -03:00
|
|
|
"_asyncio.FutureIter",
|
2016-10-28 13:52:37 -03:00
|
|
|
.tp_basicsize = sizeof(futureiterobject),
|
|
|
|
.tp_itemsize = 0,
|
|
|
|
.tp_dealloc = (destructor)FutureIter_dealloc,
|
|
|
|
.tp_getattro = PyObject_GenericGetAttr,
|
|
|
|
.tp_flags = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC,
|
|
|
|
.tp_traverse = (traverseproc)FutureIter_traverse,
|
|
|
|
.tp_iter = PyObject_SelfIter,
|
|
|
|
.tp_iternext = (iternextfunc)FutureIter_iternext,
|
|
|
|
.tp_methods = FutureIter_methods,
|
2016-10-09 02:44:47 -03:00
|
|
|
};
|
|
|
|
|
|
|
|
static PyObject *
|
2016-10-28 13:52:37 -03:00
|
|
|
future_new_iter(PyObject *fut)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
|
|
|
futureiterobject *it;
|
|
|
|
|
|
|
|
if (!PyObject_TypeCheck(fut, &FutureType)) {
|
|
|
|
PyErr_BadInternalCall();
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
it = PyObject_GC_New(futureiterobject, &FutureIterType);
|
|
|
|
if (it == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
Py_INCREF(fut);
|
|
|
|
it->future = (FutureObj*)fut;
|
2016-10-10 14:12:34 -03:00
|
|
|
PyObject_GC_Track(it);
|
2016-10-09 02:44:47 -03:00
|
|
|
return (PyObject*)it;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
|
|
|
|
/*********************** Task **************************/
|
|
|
|
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
class _asyncio.Task "TaskObj *" "&Task_Type"
|
|
|
|
[clinic start generated code]*/
|
|
|
|
/*[clinic end generated code: output=da39a3ee5e6b4b0d input=719dcef0fcc03b37]*/
|
|
|
|
|
|
|
|
static int task_call_step_soon(TaskObj *, PyObject *);
|
|
|
|
static inline PyObject * task_call_wakeup(TaskObj *, PyObject *);
|
|
|
|
static inline PyObject * task_call_step(TaskObj *, PyObject *);
|
|
|
|
static PyObject * task_wakeup(TaskObj *, PyObject *);
|
|
|
|
static PyObject * task_step(TaskObj *, PyObject *);
|
|
|
|
|
|
|
|
/* ----- Task._step wrapper */
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-17 23:48:14 -03:00
|
|
|
static int
|
2016-10-28 13:52:37 -03:00
|
|
|
TaskSendMethWrapper_clear(TaskSendMethWrapper *o)
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_CLEAR(o->sw_task);
|
|
|
|
Py_CLEAR(o->sw_arg);
|
|
|
|
return 0;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static void
|
|
|
|
TaskSendMethWrapper_dealloc(TaskSendMethWrapper *o)
|
|
|
|
{
|
|
|
|
PyObject_GC_UnTrack(o);
|
|
|
|
(void)TaskSendMethWrapper_clear(o);
|
|
|
|
Py_TYPE(o)->tp_free(o);
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskSendMethWrapper_call(TaskSendMethWrapper *o,
|
|
|
|
PyObject *args, PyObject *kwds)
|
|
|
|
{
|
|
|
|
return task_call_step(o->sw_task, o->sw_arg);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
TaskSendMethWrapper_traverse(TaskSendMethWrapper *o,
|
|
|
|
visitproc visit, void *arg)
|
|
|
|
{
|
|
|
|
Py_VISIT(o->sw_task);
|
|
|
|
Py_VISIT(o->sw_arg);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskSendMethWrapper_get___self__(TaskSendMethWrapper *o)
|
|
|
|
{
|
|
|
|
if (o->sw_task) {
|
|
|
|
Py_INCREF(o->sw_task);
|
|
|
|
return (PyObject*)o->sw_task;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyGetSetDef TaskSendMethWrapper_getsetlist[] = {
|
|
|
|
{"__self__", (getter)TaskSendMethWrapper_get___self__, NULL, NULL},
|
|
|
|
{NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
|
|
|
PyTypeObject TaskSendMethWrapper_Type = {
|
2016-10-28 14:13:52 -03:00
|
|
|
PyVarObject_HEAD_INIT(NULL, 0)
|
2016-10-28 13:52:37 -03:00
|
|
|
"TaskSendMethWrapper",
|
|
|
|
.tp_basicsize = sizeof(TaskSendMethWrapper),
|
|
|
|
.tp_itemsize = 0,
|
|
|
|
.tp_getset = TaskSendMethWrapper_getsetlist,
|
|
|
|
.tp_dealloc = (destructor)TaskSendMethWrapper_dealloc,
|
|
|
|
.tp_call = (ternaryfunc)TaskSendMethWrapper_call,
|
|
|
|
.tp_getattro = PyObject_GenericGetAttr,
|
|
|
|
.tp_flags = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC,
|
|
|
|
.tp_traverse = (traverseproc)TaskSendMethWrapper_traverse,
|
|
|
|
.tp_clear = (inquiry)TaskSendMethWrapper_clear,
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskSendMethWrapper_new(TaskObj *task, PyObject *arg)
|
|
|
|
{
|
|
|
|
TaskSendMethWrapper *o;
|
|
|
|
o = PyObject_GC_New(TaskSendMethWrapper, &TaskSendMethWrapper_Type);
|
|
|
|
if (o == NULL) {
|
|
|
|
return NULL;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_INCREF(task);
|
|
|
|
o->sw_task = task;
|
|
|
|
|
|
|
|
Py_XINCREF(arg);
|
|
|
|
o->sw_arg = arg;
|
|
|
|
|
|
|
|
PyObject_GC_Track(o);
|
|
|
|
return (PyObject*) o;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* ----- Task._wakeup wrapper */
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskWakeupMethWrapper_call(TaskWakeupMethWrapper *o,
|
|
|
|
PyObject *args, PyObject *kwds)
|
|
|
|
{
|
|
|
|
PyObject *fut;
|
|
|
|
|
|
|
|
if (!PyArg_ParseTuple(args, "O|", &fut)) {
|
|
|
|
return NULL;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
|
|
|
|
return task_call_wakeup(o->ww_task, fut);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
TaskWakeupMethWrapper_clear(TaskWakeupMethWrapper *o)
|
|
|
|
{
|
|
|
|
Py_CLEAR(o->ww_task);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
TaskWakeupMethWrapper_traverse(TaskWakeupMethWrapper *o,
|
|
|
|
visitproc visit, void *arg)
|
|
|
|
{
|
|
|
|
Py_VISIT(o->ww_task);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
TaskWakeupMethWrapper_dealloc(TaskWakeupMethWrapper *o)
|
|
|
|
{
|
|
|
|
PyObject_GC_UnTrack(o);
|
|
|
|
(void)TaskWakeupMethWrapper_clear(o);
|
|
|
|
Py_TYPE(o)->tp_free(o);
|
|
|
|
}
|
|
|
|
|
|
|
|
PyTypeObject TaskWakeupMethWrapper_Type = {
|
2016-10-28 14:13:52 -03:00
|
|
|
PyVarObject_HEAD_INIT(NULL, 0)
|
2016-10-28 13:52:37 -03:00
|
|
|
"TaskWakeupMethWrapper",
|
|
|
|
.tp_basicsize = sizeof(TaskWakeupMethWrapper),
|
|
|
|
.tp_itemsize = 0,
|
|
|
|
.tp_dealloc = (destructor)TaskWakeupMethWrapper_dealloc,
|
|
|
|
.tp_call = (ternaryfunc)TaskWakeupMethWrapper_call,
|
|
|
|
.tp_getattro = PyObject_GenericGetAttr,
|
|
|
|
.tp_flags = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC,
|
|
|
|
.tp_traverse = (traverseproc)TaskWakeupMethWrapper_traverse,
|
|
|
|
.tp_clear = (inquiry)TaskWakeupMethWrapper_clear,
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskWakeupMethWrapper_new(TaskObj *task)
|
|
|
|
{
|
|
|
|
TaskWakeupMethWrapper *o;
|
|
|
|
o = PyObject_GC_New(TaskWakeupMethWrapper, &TaskWakeupMethWrapper_Type);
|
|
|
|
if (o == NULL) {
|
|
|
|
return NULL;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_INCREF(task);
|
|
|
|
o->ww_task = task;
|
|
|
|
|
|
|
|
PyObject_GC_Track(o);
|
|
|
|
return (PyObject*) o;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* ----- Task */
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task.__init__
|
|
|
|
|
|
|
|
coro: 'O'
|
|
|
|
*
|
|
|
|
loop: 'O' = NULL
|
|
|
|
|
|
|
|
A coroutine wrapped in a Future.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static int
|
|
|
|
_asyncio_Task___init___impl(TaskObj *self, PyObject *coro, PyObject *loop)
|
|
|
|
/*[clinic end generated code: output=9f24774c2287fc2f input=71d8d28c201a18cd]*/
|
|
|
|
{
|
|
|
|
PyObject *res;
|
|
|
|
_Py_IDENTIFIER(add);
|
|
|
|
|
|
|
|
if (future_init((FutureObj*)self, loop)) {
|
|
|
|
return -1;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
|
|
|
|
self->task_fut_waiter = NULL;
|
|
|
|
self->task_must_cancel = 0;
|
|
|
|
self->task_log_destroy_pending = 1;
|
|
|
|
|
|
|
|
Py_INCREF(coro);
|
|
|
|
self->task_coro = coro;
|
|
|
|
|
|
|
|
if (task_call_step_soon(self, NULL)) {
|
|
|
|
return -1;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
res = _PyObject_CallMethodId(all_tasks, &PyId_add, "O", self, NULL);
|
|
|
|
if (res == NULL) {
|
|
|
|
return -1;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_DECREF(res);
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
TaskObj_clear(TaskObj *task)
|
|
|
|
{
|
|
|
|
(void)FutureObj_clear((FutureObj*) task);
|
|
|
|
Py_CLEAR(task->task_coro);
|
|
|
|
Py_CLEAR(task->task_fut_waiter);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
TaskObj_traverse(TaskObj *task, visitproc visit, void *arg)
|
|
|
|
{
|
|
|
|
Py_VISIT(task->task_coro);
|
|
|
|
Py_VISIT(task->task_fut_waiter);
|
|
|
|
(void)FutureObj_traverse((FutureObj*) task, visit, arg);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
TaskObj_get_log_destroy_pending(TaskObj *task)
|
|
|
|
{
|
|
|
|
if (task->task_log_destroy_pending) {
|
|
|
|
Py_RETURN_TRUE;
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
else {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static int
|
|
|
|
TaskObj_set_log_destroy_pending(TaskObj *task, PyObject *val)
|
|
|
|
{
|
|
|
|
int is_true = PyObject_IsTrue(val);
|
|
|
|
if (is_true < 0) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
task->task_log_destroy_pending = is_true;
|
2016-10-17 23:48:14 -03:00
|
|
|
return 0;
|
2016-10-28 13:52:37 -03:00
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
TaskObj_get_must_cancel(TaskObj *task)
|
|
|
|
{
|
|
|
|
if (task->task_must_cancel) {
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
TaskObj_get_coro(TaskObj *task)
|
|
|
|
{
|
|
|
|
if (task->task_coro) {
|
|
|
|
Py_INCREF(task->task_coro);
|
|
|
|
return task->task_coro;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
TaskObj_get_fut_waiter(TaskObj *task)
|
|
|
|
{
|
|
|
|
if (task->task_fut_waiter) {
|
|
|
|
Py_INCREF(task->task_fut_waiter);
|
|
|
|
return task->task_fut_waiter;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
/*[clinic input]
|
|
|
|
@classmethod
|
|
|
|
_asyncio.Task.current_task
|
|
|
|
|
|
|
|
loop: 'O' = NULL
|
|
|
|
|
|
|
|
Return the currently running task in an event loop or None.
|
|
|
|
|
|
|
|
By default the current task for the current event loop is returned.
|
|
|
|
|
|
|
|
None is returned when called not in the context of a Task.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task_current_task_impl(PyTypeObject *type, PyObject *loop)
|
|
|
|
/*[clinic end generated code: output=99fbe7332c516e03 input=cd784537f02cf833]*/
|
2016-10-09 02:44:47 -03:00
|
|
|
{
|
2016-10-28 13:52:37 -03:00
|
|
|
PyObject *res;
|
|
|
|
|
|
|
|
if (loop == NULL) {
|
|
|
|
loop = PyObject_CallObject(asyncio_get_event_loop, NULL);
|
|
|
|
if (loop == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2016-10-28 20:01:21 -03:00
|
|
|
res = PyDict_GetItem(current_tasks, loop);
|
2016-10-28 13:52:37 -03:00
|
|
|
Py_DECREF(loop);
|
2016-10-17 23:48:14 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
else {
|
2016-10-28 20:01:21 -03:00
|
|
|
res = PyDict_GetItem(current_tasks, loop);
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
|
|
|
|
if (res == NULL) {
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_INCREF(res);
|
|
|
|
return res;
|
2016-10-09 02:44:47 -03:00
|
|
|
}
|
2016-10-28 13:52:37 -03:00
|
|
|
}
|
2016-10-09 02:44:47 -03:00
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
static PyObject *
|
|
|
|
task_all_tasks(PyObject *loop)
|
|
|
|
{
|
|
|
|
PyObject *task;
|
|
|
|
PyObject *task_loop;
|
|
|
|
PyObject *set;
|
|
|
|
PyObject *iter;
|
|
|
|
|
|
|
|
assert(loop != NULL);
|
|
|
|
|
|
|
|
set = PySet_New(NULL);
|
|
|
|
if (set == NULL) {
|
2016-10-09 02:44:47 -03:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2016-10-28 13:52:37 -03:00
|
|
|
iter = PyObject_GetIter(all_tasks);
|
|
|
|
if (iter == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
while ((task = PyIter_Next(iter))) {
|
|
|
|
task_loop = PyObject_GetAttrString(task, "_loop");
|
|
|
|
if (task_loop == NULL) {
|
|
|
|
Py_DECREF(task);
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
if (task_loop == loop) {
|
|
|
|
if (PySet_Add(set, task) == -1) {
|
|
|
|
Py_DECREF(task_loop);
|
|
|
|
Py_DECREF(task);
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Py_DECREF(task_loop);
|
|
|
|
Py_DECREF(task);
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_DECREF(iter);
|
|
|
|
return set;
|
|
|
|
|
|
|
|
fail:
|
|
|
|
Py_XDECREF(set);
|
|
|
|
Py_XDECREF(iter);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
@classmethod
|
|
|
|
_asyncio.Task.all_tasks
|
|
|
|
|
|
|
|
loop: 'O' = NULL
|
|
|
|
|
|
|
|
Return a set of all tasks for an event loop.
|
|
|
|
|
|
|
|
By default all tasks for the current event loop are returned.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task_all_tasks_impl(PyTypeObject *type, PyObject *loop)
|
|
|
|
/*[clinic end generated code: output=11f9b20749ccca5d input=cd64aa5f88bd5c49]*/
|
|
|
|
{
|
|
|
|
PyObject *res;
|
|
|
|
|
|
|
|
if (loop == NULL) {
|
|
|
|
loop = PyObject_CallObject(asyncio_get_event_loop, NULL);
|
|
|
|
if (loop == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
res = task_all_tasks(loop);
|
|
|
|
Py_DECREF(loop);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
res = task_all_tasks(loop);
|
|
|
|
}
|
|
|
|
|
|
|
|
return res;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task._repr_info
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task__repr_info_impl(TaskObj *self)
|
|
|
|
/*[clinic end generated code: output=6a490eb66d5ba34b input=3c6d051ed3ddec8b]*/
|
|
|
|
{
|
|
|
|
return PyObject_CallFunctionObjArgs(
|
|
|
|
asyncio_task_repr_info_func, self, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task.cancel
|
|
|
|
|
|
|
|
Request that this task cancel itself.
|
|
|
|
|
|
|
|
This arranges for a CancelledError to be thrown into the
|
|
|
|
wrapped coroutine on the next cycle through the event loop.
|
|
|
|
The coroutine then has a chance to clean up or even deny
|
|
|
|
the request using try/except/finally.
|
|
|
|
|
|
|
|
Unlike Future.cancel, this does not guarantee that the
|
|
|
|
task will be cancelled: the exception might be caught and
|
|
|
|
acted upon, delaying cancellation of the task or preventing
|
|
|
|
cancellation completely. The task may also return a value or
|
|
|
|
raise a different exception.
|
|
|
|
|
|
|
|
Immediately after this method is called, Task.cancelled() will
|
|
|
|
not return True (unless the task was already cancelled). A
|
|
|
|
task will be marked as cancelled when the wrapped coroutine
|
|
|
|
terminates with a CancelledError exception (even if cancel()
|
|
|
|
was not called).
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task_cancel_impl(TaskObj *self)
|
|
|
|
/*[clinic end generated code: output=6bfc0479da9d5757 input=13f9bf496695cb52]*/
|
|
|
|
{
|
|
|
|
if (self->task_state != STATE_PENDING) {
|
|
|
|
Py_RETURN_FALSE;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (self->task_fut_waiter) {
|
|
|
|
PyObject *res;
|
|
|
|
int is_true;
|
|
|
|
|
|
|
|
res = _PyObject_CallMethodId(
|
|
|
|
self->task_fut_waiter, &PyId_cancel, NULL);
|
|
|
|
if (res == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
is_true = PyObject_IsTrue(res);
|
|
|
|
Py_DECREF(res);
|
|
|
|
if (is_true < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (is_true) {
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
self->task_must_cancel = 1;
|
|
|
|
Py_RETURN_TRUE;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task.get_stack
|
|
|
|
|
|
|
|
*
|
|
|
|
limit: 'O' = None
|
|
|
|
|
|
|
|
Return the list of stack frames for this task's coroutine.
|
|
|
|
|
|
|
|
If the coroutine is not done, this returns the stack where it is
|
|
|
|
suspended. If the coroutine has completed successfully or was
|
|
|
|
cancelled, this returns an empty list. If the coroutine was
|
|
|
|
terminated by an exception, this returns the list of traceback
|
|
|
|
frames.
|
|
|
|
|
|
|
|
The frames are always ordered from oldest to newest.
|
|
|
|
|
|
|
|
The optional limit gives the maximum number of frames to
|
|
|
|
return; by default all available frames are returned. Its
|
|
|
|
meaning differs depending on whether a stack or a traceback is
|
|
|
|
returned: the newest frames of a stack are returned, but the
|
|
|
|
oldest frames of a traceback are returned. (This matches the
|
|
|
|
behavior of the traceback module.)
|
|
|
|
|
|
|
|
For reasons beyond our control, only one stack frame is
|
|
|
|
returned for a suspended coroutine.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task_get_stack_impl(TaskObj *self, PyObject *limit)
|
|
|
|
/*[clinic end generated code: output=c9aeeeebd1e18118 input=b1920230a766d17a]*/
|
|
|
|
{
|
|
|
|
return PyObject_CallFunctionObjArgs(
|
|
|
|
asyncio_task_get_stack_func, self, limit, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task.print_stack
|
|
|
|
|
|
|
|
*
|
|
|
|
limit: 'O' = None
|
|
|
|
file: 'O' = None
|
|
|
|
|
|
|
|
Print the stack or traceback for this task's coroutine.
|
|
|
|
|
|
|
|
This produces output similar to that of the traceback module,
|
|
|
|
for the frames retrieved by get_stack(). The limit argument
|
|
|
|
is passed to get_stack(). The file argument is an I/O stream
|
|
|
|
to which the output is written; by default output is written
|
|
|
|
to sys.stderr.
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task_print_stack_impl(TaskObj *self, PyObject *limit,
|
|
|
|
PyObject *file)
|
|
|
|
/*[clinic end generated code: output=7339e10314cd3f4d input=19f1e99ab5400bc3]*/
|
|
|
|
{
|
|
|
|
return PyObject_CallFunctionObjArgs(
|
|
|
|
asyncio_task_print_stack_func, self, limit, file, NULL);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task._step
|
|
|
|
|
|
|
|
exc: 'O' = NULL
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task__step_impl(TaskObj *self, PyObject *exc)
|
|
|
|
/*[clinic end generated code: output=7ed23f0cefd5ae42 input=ada4b2324e5370af]*/
|
|
|
|
{
|
|
|
|
return task_step(self, exc == Py_None ? NULL : exc);
|
|
|
|
}
|
|
|
|
|
|
|
|
/*[clinic input]
|
|
|
|
_asyncio.Task._wakeup
|
|
|
|
|
|
|
|
fut: 'O'
|
|
|
|
[clinic start generated code]*/
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
_asyncio_Task__wakeup_impl(TaskObj *self, PyObject *fut)
|
|
|
|
/*[clinic end generated code: output=75cb341c760fd071 input=11ee4918a5bdbf21]*/
|
|
|
|
{
|
|
|
|
return task_wakeup(self, fut);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
TaskObj_finalize(TaskObj *task)
|
|
|
|
{
|
|
|
|
_Py_IDENTIFIER(call_exception_handler);
|
|
|
|
_Py_IDENTIFIER(task);
|
|
|
|
_Py_IDENTIFIER(message);
|
|
|
|
_Py_IDENTIFIER(source_traceback);
|
|
|
|
|
|
|
|
PyObject *message = NULL;
|
|
|
|
PyObject *context = NULL;
|
|
|
|
PyObject *func = NULL;
|
|
|
|
PyObject *res = NULL;
|
|
|
|
|
|
|
|
PyObject *error_type, *error_value, *error_traceback;
|
|
|
|
|
|
|
|
if (task->task_state != STATE_PENDING || !task->task_log_destroy_pending) {
|
|
|
|
goto done;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Save the current exception, if any. */
|
|
|
|
PyErr_Fetch(&error_type, &error_value, &error_traceback);
|
|
|
|
|
|
|
|
context = PyDict_New();
|
|
|
|
if (context == NULL) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
message = PyUnicode_FromString("Task was destroyed but it is pending!");
|
|
|
|
if (message == NULL) {
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (_PyDict_SetItemId(context, &PyId_message, message) < 0 ||
|
|
|
|
_PyDict_SetItemId(context, &PyId_task, (PyObject*)task) < 0)
|
|
|
|
{
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (task->task_source_tb != NULL) {
|
|
|
|
if (_PyDict_SetItemId(context, &PyId_source_traceback,
|
|
|
|
task->task_source_tb) < 0)
|
|
|
|
{
|
|
|
|
goto finally;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func = _PyObject_GetAttrId(task->task_loop, &PyId_call_exception_handler);
|
|
|
|
if (func != NULL) {
|
|
|
|
res = _PyObject_CallArg1(func, context);
|
|
|
|
if (res == NULL) {
|
|
|
|
PyErr_WriteUnraisable(func);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
finally:
|
|
|
|
Py_CLEAR(context);
|
|
|
|
Py_CLEAR(message);
|
|
|
|
Py_CLEAR(func);
|
|
|
|
Py_CLEAR(res);
|
|
|
|
|
|
|
|
/* Restore the saved exception. */
|
|
|
|
PyErr_Restore(error_type, error_value, error_traceback);
|
|
|
|
|
|
|
|
done:
|
|
|
|
FutureObj_finalize((FutureObj*)task);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void TaskObj_dealloc(PyObject *); /* Needs Task_CheckExact */
|
|
|
|
|
|
|
|
static PyMethodDef TaskType_methods[] = {
|
|
|
|
_ASYNCIO_FUTURE_RESULT_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_EXCEPTION_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_SET_RESULT_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_SET_EXCEPTION_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_ADD_DONE_CALLBACK_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_REMOVE_DONE_CALLBACK_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_CANCELLED_METHODDEF
|
|
|
|
_ASYNCIO_FUTURE_DONE_METHODDEF
|
|
|
|
_ASYNCIO_TASK_CURRENT_TASK_METHODDEF
|
|
|
|
_ASYNCIO_TASK_ALL_TASKS_METHODDEF
|
|
|
|
_ASYNCIO_TASK_CANCEL_METHODDEF
|
|
|
|
_ASYNCIO_TASK_GET_STACK_METHODDEF
|
|
|
|
_ASYNCIO_TASK_PRINT_STACK_METHODDEF
|
|
|
|
_ASYNCIO_TASK__WAKEUP_METHODDEF
|
|
|
|
_ASYNCIO_TASK__STEP_METHODDEF
|
|
|
|
_ASYNCIO_TASK__REPR_INFO_METHODDEF
|
|
|
|
{NULL, NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyGetSetDef TaskType_getsetlist[] = {
|
|
|
|
FUTURE_COMMON_GETSETLIST
|
|
|
|
{"_log_destroy_pending", (getter)TaskObj_get_log_destroy_pending,
|
|
|
|
(setter)TaskObj_set_log_destroy_pending, NULL},
|
|
|
|
{"_must_cancel", (getter)TaskObj_get_must_cancel, NULL, NULL},
|
|
|
|
{"_coro", (getter)TaskObj_get_coro, NULL, NULL},
|
|
|
|
{"_fut_waiter", (getter)TaskObj_get_fut_waiter, NULL, NULL},
|
|
|
|
{NULL} /* Sentinel */
|
|
|
|
};
|
|
|
|
|
|
|
|
static PyTypeObject TaskType = {
|
2016-10-28 14:13:52 -03:00
|
|
|
PyVarObject_HEAD_INIT(NULL, 0)
|
2016-10-28 13:52:37 -03:00
|
|
|
"_asyncio.Task",
|
|
|
|
sizeof(TaskObj), /* tp_basicsize */
|
|
|
|
.tp_base = &FutureType,
|
|
|
|
.tp_dealloc = TaskObj_dealloc,
|
|
|
|
.tp_as_async = &FutureType_as_async,
|
|
|
|
.tp_repr = (reprfunc)FutureObj_repr,
|
|
|
|
.tp_flags = Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC | Py_TPFLAGS_BASETYPE
|
|
|
|
| Py_TPFLAGS_HAVE_FINALIZE,
|
|
|
|
.tp_doc = _asyncio_Task___init____doc__,
|
|
|
|
.tp_traverse = (traverseproc)TaskObj_traverse,
|
|
|
|
.tp_clear = (inquiry)TaskObj_clear,
|
|
|
|
.tp_weaklistoffset = offsetof(TaskObj, task_weakreflist),
|
|
|
|
.tp_iter = (getiterfunc)future_new_iter,
|
|
|
|
.tp_methods = TaskType_methods,
|
|
|
|
.tp_getset = TaskType_getsetlist,
|
|
|
|
.tp_dictoffset = offsetof(TaskObj, dict),
|
|
|
|
.tp_init = (initproc)_asyncio_Task___init__,
|
|
|
|
.tp_new = PyType_GenericNew,
|
|
|
|
.tp_finalize = (destructor)TaskObj_finalize,
|
|
|
|
};
|
|
|
|
|
|
|
|
#define Task_CheckExact(obj) (Py_TYPE(obj) == &TaskType)
|
|
|
|
|
|
|
|
static void
|
|
|
|
TaskObj_dealloc(PyObject *self)
|
|
|
|
{
|
|
|
|
TaskObj *task = (TaskObj *)self;
|
|
|
|
|
|
|
|
if (Task_CheckExact(self)) {
|
|
|
|
/* When fut is subclass of Task, finalizer is called from
|
|
|
|
* subtype_dealloc.
|
|
|
|
*/
|
|
|
|
if (PyObject_CallFinalizerFromDealloc(self) < 0) {
|
|
|
|
// resurrected.
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (task->task_weakreflist != NULL) {
|
|
|
|
PyObject_ClearWeakRefs(self);
|
|
|
|
}
|
|
|
|
|
|
|
|
(void)TaskObj_clear(task);
|
|
|
|
Py_TYPE(task)->tp_free(task);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline PyObject *
|
|
|
|
task_call_wakeup(TaskObj *task, PyObject *fut)
|
|
|
|
{
|
|
|
|
if (Task_CheckExact(task)) {
|
|
|
|
return task_wakeup(task, fut);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
/* `task` is a subclass of Task */
|
|
|
|
return _PyObject_CallMethodId(
|
|
|
|
(PyObject*)task, &PyId__wakeup, "O", fut, NULL);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline PyObject *
|
|
|
|
task_call_step(TaskObj *task, PyObject *arg)
|
|
|
|
{
|
|
|
|
if (Task_CheckExact(task)) {
|
|
|
|
return task_step(task, arg);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
/* `task` is a subclass of Task */
|
|
|
|
if (arg == NULL) {
|
|
|
|
arg = Py_None;
|
|
|
|
}
|
|
|
|
return _PyObject_CallMethodId(
|
|
|
|
(PyObject*)task, &PyId__step, "O", arg, NULL);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
task_call_step_soon(TaskObj *task, PyObject *arg)
|
|
|
|
{
|
|
|
|
PyObject *handle;
|
|
|
|
|
|
|
|
PyObject *cb = TaskSendMethWrapper_new(task, arg);
|
|
|
|
if (cb == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
handle = _PyObject_CallMethodId(
|
|
|
|
task->task_loop, &PyId_call_soon, "O", cb, NULL);
|
|
|
|
Py_DECREF(cb);
|
|
|
|
if (handle == NULL) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_DECREF(handle);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
task_set_error_soon(TaskObj *task, PyObject *et, const char *format, ...)
|
|
|
|
{
|
|
|
|
PyObject* msg;
|
|
|
|
|
|
|
|
va_list vargs;
|
|
|
|
#ifdef HAVE_STDARG_PROTOTYPES
|
|
|
|
va_start(vargs, format);
|
|
|
|
#else
|
|
|
|
va_start(vargs);
|
|
|
|
#endif
|
|
|
|
msg = PyUnicode_FromFormatV(format, vargs);
|
|
|
|
va_end(vargs);
|
|
|
|
|
|
|
|
if (msg == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *e = PyObject_CallFunctionObjArgs(et, msg, NULL);
|
|
|
|
Py_DECREF(msg);
|
|
|
|
if (e == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (task_call_step_soon(task, e) == -1) {
|
|
|
|
Py_DECREF(e);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_DECREF(e);
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
task_step_impl(TaskObj *task, PyObject *exc)
|
|
|
|
{
|
|
|
|
int res;
|
|
|
|
int clear_exc = 0;
|
|
|
|
PyObject *result = NULL;
|
|
|
|
PyObject *coro = task->task_coro;
|
|
|
|
PyObject *o;
|
|
|
|
|
|
|
|
if (task->task_state != STATE_PENDING) {
|
|
|
|
PyErr_Format(PyExc_AssertionError,
|
|
|
|
"_step(): already done: %R %R",
|
|
|
|
task,
|
|
|
|
exc ? exc : Py_None);
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (task->task_must_cancel) {
|
|
|
|
assert(exc != Py_None);
|
|
|
|
|
|
|
|
if (exc) {
|
|
|
|
/* Check if exc is a CancelledError */
|
|
|
|
res = PyObject_IsInstance(exc, asyncio_CancelledError);
|
|
|
|
if (res == -1) {
|
|
|
|
/* An error occurred, abort */
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
if (res == 0) {
|
|
|
|
/* exc is not CancelledError; reset it to NULL */
|
|
|
|
exc = NULL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!exc) {
|
|
|
|
/* exc was not a CancelledError */
|
|
|
|
exc = PyObject_CallFunctionObjArgs(asyncio_CancelledError, NULL);
|
|
|
|
if (!exc) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
clear_exc = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
task->task_must_cancel = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_CLEAR(task->task_fut_waiter);
|
|
|
|
|
|
|
|
if (exc == NULL) {
|
|
|
|
if (PyGen_CheckExact(coro) || PyCoro_CheckExact(coro)) {
|
|
|
|
result = _PyGen_Send((PyGenObject*)coro, Py_None);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
result = _PyObject_CallMethodIdObjArgs(
|
|
|
|
coro, &PyId_send, Py_None, NULL);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
result = _PyObject_CallMethodIdObjArgs(
|
|
|
|
coro, &PyId_throw, exc, NULL);
|
|
|
|
if (clear_exc) {
|
|
|
|
/* We created 'exc' during this call */
|
|
|
|
Py_CLEAR(exc);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (result == NULL) {
|
|
|
|
PyObject *et, *ev, *tb;
|
|
|
|
|
|
|
|
if (_PyGen_FetchStopIterationValue(&o) == 0) {
|
|
|
|
/* The error is StopIteration and that means that
|
|
|
|
the underlying coroutine has resolved */
|
|
|
|
PyObject *res = future_set_result((FutureObj*)task, o);
|
|
|
|
Py_DECREF(o);
|
|
|
|
if (res == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
Py_DECREF(res);
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (PyErr_ExceptionMatches(asyncio_CancelledError)) {
|
|
|
|
/* CancelledError */
|
|
|
|
PyErr_Clear();
|
|
|
|
return future_cancel((FutureObj*)task);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Some other exception; pop it and call Task.set_exception() */
|
|
|
|
PyErr_Fetch(&et, &ev, &tb);
|
|
|
|
assert(et);
|
|
|
|
if (!ev || !PyObject_TypeCheck(ev, (PyTypeObject *) et)) {
|
|
|
|
PyErr_NormalizeException(&et, &ev, &tb);
|
|
|
|
}
|
|
|
|
o = future_set_exception((FutureObj*)task, ev);
|
|
|
|
if (!o) {
|
|
|
|
/* An exception in Task.set_exception() */
|
|
|
|
Py_XDECREF(et);
|
|
|
|
Py_XDECREF(tb);
|
|
|
|
Py_XDECREF(ev);
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
assert(o == Py_None);
|
|
|
|
Py_CLEAR(o);
|
|
|
|
|
|
|
|
if (!PyErr_GivenExceptionMatches(et, PyExc_Exception)) {
|
|
|
|
/* We've got a BaseException; re-raise it */
|
|
|
|
PyErr_Restore(et, ev, tb);
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_XDECREF(et);
|
|
|
|
Py_XDECREF(tb);
|
|
|
|
Py_XDECREF(ev);
|
|
|
|
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (result == (PyObject*)task) {
|
|
|
|
/* We have a task that wants to await on itself */
|
|
|
|
goto self_await;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check if `result` is FutureObj or TaskObj (and not a subclass) */
|
|
|
|
if (Future_CheckExact(result) || Task_CheckExact(result)) {
|
|
|
|
PyObject *wrapper;
|
|
|
|
PyObject *res;
|
|
|
|
FutureObj *fut = (FutureObj*)result;
|
|
|
|
|
|
|
|
/* Check if `result` future is attached to a different loop */
|
|
|
|
if (fut->fut_loop != task->task_loop) {
|
|
|
|
goto different_loop;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (fut->fut_blocking) {
|
|
|
|
fut->fut_blocking = 0;
|
|
|
|
|
|
|
|
/* result.add_done_callback(task._wakeup) */
|
|
|
|
wrapper = TaskWakeupMethWrapper_new(task);
|
|
|
|
if (wrapper == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
res = future_add_done_callback((FutureObj*)result, wrapper);
|
|
|
|
Py_DECREF(wrapper);
|
|
|
|
if (res == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
Py_DECREF(res);
|
|
|
|
|
|
|
|
/* task._fut_waiter = result */
|
|
|
|
task->task_fut_waiter = result; /* no incref is necessary */
|
|
|
|
|
|
|
|
if (task->task_must_cancel) {
|
|
|
|
PyObject *r;
|
|
|
|
r = future_cancel(fut);
|
|
|
|
if (r == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if (r == Py_True) {
|
|
|
|
task->task_must_cancel = 0;
|
|
|
|
}
|
|
|
|
Py_DECREF(r);
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
goto yield_insteadof_yf;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check if `result` is a Future-compatible object */
|
|
|
|
o = PyObject_GetAttrString(result, "_asyncio_future_blocking");
|
|
|
|
if (o == NULL) {
|
|
|
|
if (PyErr_ExceptionMatches(PyExc_AttributeError)) {
|
|
|
|
PyErr_Clear();
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
if (o == Py_None) {
|
|
|
|
Py_CLEAR(o);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
/* `result` is a Future-compatible object */
|
|
|
|
PyObject *wrapper;
|
|
|
|
PyObject *res;
|
|
|
|
|
|
|
|
int blocking = PyObject_IsTrue(o);
|
|
|
|
Py_CLEAR(o);
|
|
|
|
if (blocking < 0) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check if `result` future is attached to a different loop */
|
|
|
|
PyObject *oloop = PyObject_GetAttrString(result, "_loop");
|
|
|
|
if (oloop == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
if (oloop != task->task_loop) {
|
|
|
|
Py_DECREF(oloop);
|
|
|
|
goto different_loop;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_DECREF(oloop);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (blocking) {
|
|
|
|
/* result._asyncio_future_blocking = False */
|
|
|
|
if (PyObject_SetAttrString(
|
|
|
|
result, "_asyncio_future_blocking", Py_False) == -1) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* result.add_done_callback(task._wakeup) */
|
|
|
|
wrapper = TaskWakeupMethWrapper_new(task);
|
|
|
|
if (wrapper == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
res = _PyObject_CallMethodId(
|
|
|
|
result, &PyId_add_done_callback, "O", wrapper, NULL);
|
|
|
|
Py_DECREF(wrapper);
|
|
|
|
if (res == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
Py_DECREF(res);
|
|
|
|
|
|
|
|
/* task._fut_waiter = result */
|
|
|
|
task->task_fut_waiter = result; /* no incref is necessary */
|
|
|
|
|
|
|
|
if (task->task_must_cancel) {
|
|
|
|
PyObject *r;
|
|
|
|
int is_true;
|
|
|
|
r = _PyObject_CallMethodId(result, &PyId_cancel, NULL);
|
|
|
|
if (r == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
is_true = PyObject_IsTrue(r);
|
|
|
|
Py_DECREF(r);
|
|
|
|
if (is_true < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
else if (is_true) {
|
|
|
|
task->task_must_cancel = 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_RETURN_NONE;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
goto yield_insteadof_yf;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check if `result` is None */
|
|
|
|
if (result == Py_None) {
|
|
|
|
/* Bare yield relinquishes control for one event loop iteration. */
|
|
|
|
if (task_call_step_soon(task, NULL)) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check if `result` is a generator */
|
|
|
|
o = PyObject_CallFunctionObjArgs(inspect_isgenerator, result, NULL);
|
|
|
|
if (o == NULL) {
|
|
|
|
/* An exception in inspect.isgenerator */
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
res = PyObject_IsTrue(o);
|
|
|
|
Py_CLEAR(o);
|
|
|
|
if (res == -1) {
|
|
|
|
/* An exception while checking if 'val' is True */
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
if (res == 1) {
|
|
|
|
/* `result` is a generator */
|
|
|
|
PyObject *ret;
|
|
|
|
ret = task_set_error_soon(
|
|
|
|
task, PyExc_RuntimeError,
|
|
|
|
"yield was used instead of yield from for "
|
|
|
|
"generator in task %R with %S", task, result);
|
|
|
|
Py_DECREF(result);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* The `result` is none of the above */
|
|
|
|
Py_DECREF(result);
|
|
|
|
return task_set_error_soon(
|
|
|
|
task, PyExc_RuntimeError, "Task got bad yield: %R", result);
|
|
|
|
|
|
|
|
self_await:
|
|
|
|
o = task_set_error_soon(
|
|
|
|
task, PyExc_RuntimeError,
|
|
|
|
"Task cannot await on itself: %R", task);
|
|
|
|
Py_DECREF(result);
|
|
|
|
return o;
|
|
|
|
|
|
|
|
yield_insteadof_yf:
|
|
|
|
o = task_set_error_soon(
|
|
|
|
task, PyExc_RuntimeError,
|
|
|
|
"yield was used instead of yield from "
|
|
|
|
"in task %R with %R",
|
|
|
|
task, result);
|
|
|
|
Py_DECREF(result);
|
|
|
|
return o;
|
|
|
|
|
|
|
|
different_loop:
|
|
|
|
o = task_set_error_soon(
|
|
|
|
task, PyExc_RuntimeError,
|
|
|
|
"Task %R got Future %R attached to a different loop",
|
|
|
|
task, result);
|
|
|
|
Py_DECREF(result);
|
|
|
|
return o;
|
|
|
|
|
|
|
|
fail:
|
|
|
|
Py_XDECREF(result);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
task_step(TaskObj *task, PyObject *exc)
|
|
|
|
{
|
|
|
|
PyObject *res;
|
|
|
|
PyObject *ot;
|
|
|
|
|
2016-10-28 20:01:21 -03:00
|
|
|
if (PyDict_SetItem(current_tasks,
|
2016-10-28 13:52:37 -03:00
|
|
|
task->task_loop, (PyObject*)task) == -1)
|
|
|
|
{
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
res = task_step_impl(task, exc);
|
|
|
|
|
|
|
|
if (res == NULL) {
|
|
|
|
PyObject *et, *ev, *tb;
|
|
|
|
PyErr_Fetch(&et, &ev, &tb);
|
|
|
|
ot = _PyDict_Pop(current_tasks, task->task_loop, NULL);
|
|
|
|
if (ot == NULL) {
|
|
|
|
Py_XDECREF(et);
|
|
|
|
Py_XDECREF(tb);
|
|
|
|
Py_XDECREF(ev);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
Py_DECREF(ot);
|
|
|
|
PyErr_Restore(et, ev, tb);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
ot = _PyDict_Pop(current_tasks, task->task_loop, NULL);
|
|
|
|
if (ot == NULL) {
|
|
|
|
Py_DECREF(res);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_DECREF(ot);
|
|
|
|
return res;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
static PyObject *
|
|
|
|
task_wakeup(TaskObj *task, PyObject *o)
|
|
|
|
{
|
|
|
|
assert(o);
|
|
|
|
|
|
|
|
if (Future_CheckExact(o) || Task_CheckExact(o)) {
|
|
|
|
PyObject *fut_result = NULL;
|
|
|
|
int res = future_get_result((FutureObj*)o, &fut_result);
|
|
|
|
PyObject *result;
|
|
|
|
|
|
|
|
switch(res) {
|
|
|
|
case -1:
|
|
|
|
assert(fut_result == NULL);
|
|
|
|
return NULL;
|
|
|
|
case 0:
|
|
|
|
Py_DECREF(fut_result);
|
|
|
|
return task_call_step(task, NULL);
|
|
|
|
default:
|
|
|
|
assert(res == 1);
|
|
|
|
result = task_call_step(task, fut_result);
|
|
|
|
Py_DECREF(fut_result);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *fut_result = PyObject_CallMethod(o, "result", NULL);
|
|
|
|
if (fut_result == NULL) {
|
|
|
|
PyObject *et, *ev, *tb;
|
|
|
|
PyObject *res;
|
|
|
|
|
|
|
|
PyErr_Fetch(&et, &ev, &tb);
|
|
|
|
if (!ev || !PyObject_TypeCheck(ev, (PyTypeObject *) et)) {
|
|
|
|
PyErr_NormalizeException(&et, &ev, &tb);
|
|
|
|
}
|
|
|
|
|
|
|
|
res = task_call_step(task, ev);
|
|
|
|
|
|
|
|
Py_XDECREF(et);
|
|
|
|
Py_XDECREF(tb);
|
|
|
|
Py_XDECREF(ev);
|
|
|
|
|
|
|
|
return res;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
Py_DECREF(fut_result);
|
|
|
|
return task_call_step(task, NULL);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*********************** Module **************************/
|
|
|
|
|
|
|
|
|
|
|
|
static void
|
|
|
|
module_free(void *m)
|
|
|
|
{
|
|
|
|
Py_CLEAR(current_tasks);
|
|
|
|
Py_CLEAR(all_tasks);
|
|
|
|
Py_CLEAR(traceback_extract_stack);
|
|
|
|
Py_CLEAR(asyncio_get_event_loop);
|
|
|
|
Py_CLEAR(asyncio_future_repr_info_func);
|
|
|
|
Py_CLEAR(asyncio_task_repr_info_func);
|
|
|
|
Py_CLEAR(asyncio_task_get_stack_func);
|
|
|
|
Py_CLEAR(asyncio_task_print_stack_func);
|
|
|
|
Py_CLEAR(asyncio_InvalidStateError);
|
|
|
|
Py_CLEAR(asyncio_CancelledError);
|
|
|
|
Py_CLEAR(inspect_isgenerator);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
module_init(void)
|
|
|
|
{
|
|
|
|
PyObject *module = NULL;
|
|
|
|
PyObject *cls;
|
|
|
|
|
|
|
|
#define WITH_MOD(NAME) \
|
|
|
|
Py_CLEAR(module); \
|
|
|
|
module = PyImport_ImportModule(NAME); \
|
|
|
|
if (module == NULL) { \
|
|
|
|
return -1; \
|
|
|
|
}
|
|
|
|
|
|
|
|
#define GET_MOD_ATTR(VAR, NAME) \
|
|
|
|
VAR = PyObject_GetAttrString(module, NAME); \
|
|
|
|
if (VAR == NULL) { \
|
|
|
|
goto fail; \
|
|
|
|
}
|
|
|
|
|
|
|
|
WITH_MOD("asyncio.events")
|
|
|
|
GET_MOD_ATTR(asyncio_get_event_loop, "get_event_loop")
|
|
|
|
|
|
|
|
WITH_MOD("asyncio.base_futures")
|
|
|
|
GET_MOD_ATTR(asyncio_future_repr_info_func, "_future_repr_info")
|
|
|
|
GET_MOD_ATTR(asyncio_InvalidStateError, "InvalidStateError")
|
|
|
|
GET_MOD_ATTR(asyncio_CancelledError, "CancelledError")
|
|
|
|
|
|
|
|
WITH_MOD("asyncio.base_tasks")
|
|
|
|
GET_MOD_ATTR(asyncio_task_repr_info_func, "_task_repr_info")
|
|
|
|
GET_MOD_ATTR(asyncio_task_get_stack_func, "_task_get_stack")
|
|
|
|
GET_MOD_ATTR(asyncio_task_print_stack_func, "_task_print_stack")
|
|
|
|
|
|
|
|
WITH_MOD("inspect")
|
|
|
|
GET_MOD_ATTR(inspect_isgenerator, "isgenerator")
|
|
|
|
|
|
|
|
WITH_MOD("traceback")
|
|
|
|
GET_MOD_ATTR(traceback_extract_stack, "extract_stack")
|
|
|
|
|
|
|
|
WITH_MOD("weakref")
|
|
|
|
GET_MOD_ATTR(cls, "WeakSet")
|
|
|
|
all_tasks = PyObject_CallObject(cls, NULL);
|
|
|
|
Py_CLEAR(cls);
|
|
|
|
if (all_tasks == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
2016-10-28 20:01:21 -03:00
|
|
|
current_tasks = PyDict_New();
|
2016-10-28 13:52:37 -03:00
|
|
|
if (current_tasks == NULL) {
|
|
|
|
goto fail;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_CLEAR(module);
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
fail:
|
|
|
|
Py_CLEAR(module);
|
|
|
|
module_free(NULL);
|
|
|
|
return -1;
|
|
|
|
|
|
|
|
#undef WITH_MOD
|
|
|
|
#undef GET_MOD_ATTR
|
|
|
|
}
|
|
|
|
|
|
|
|
PyDoc_STRVAR(module_doc, "Accelerator module for asyncio");
|
|
|
|
|
|
|
|
static struct PyModuleDef _asynciomodule = {
|
|
|
|
PyModuleDef_HEAD_INIT, /* m_base */
|
|
|
|
"_asyncio", /* m_name */
|
|
|
|
module_doc, /* m_doc */
|
|
|
|
-1, /* m_size */
|
|
|
|
NULL, /* m_methods */
|
|
|
|
NULL, /* m_slots */
|
|
|
|
NULL, /* m_traverse */
|
|
|
|
NULL, /* m_clear */
|
|
|
|
(freefunc)module_free /* m_free */
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
PyMODINIT_FUNC
|
|
|
|
PyInit__asyncio(void)
|
|
|
|
{
|
|
|
|
if (module_init() < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if (PyType_Ready(&FutureType) < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if (PyType_Ready(&FutureIterType) < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if (PyType_Ready(&TaskSendMethWrapper_Type) < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if(PyType_Ready(&TaskWakeupMethWrapper_Type) < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
if (PyType_Ready(&TaskType) < 0) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
PyObject *m = PyModule_Create(&_asynciomodule);
|
|
|
|
if (m == NULL) {
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_INCREF(&FutureType);
|
|
|
|
if (PyModule_AddObject(m, "Future", (PyObject *)&FutureType) < 0) {
|
|
|
|
Py_DECREF(&FutureType);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
Py_INCREF(&TaskType);
|
|
|
|
if (PyModule_AddObject(m, "Task", (PyObject *)&TaskType) < 0) {
|
|
|
|
Py_DECREF(&TaskType);
|
2016-10-09 02:44:47 -03:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
return m;
|
|
|
|
}
|