Lines Matching defs:self
791 _asyncio_Future___init___impl(FutureObj *self, PyObject *loop)
795 return future_init(self, loop);
843 _asyncio_Future_result_impl(FutureObj *self)
848 if (!future_is_alive(self)) {
854 int res = future_get_result(self, &result);
883 _asyncio_Future_exception_impl(FutureObj *self)
886 if (!future_is_alive(self)) {
892 if (self->fut_state == STATE_CANCELLED) {
893 future_set_cancelled_error(self);
897 if (self->fut_state != STATE_FINISHED) {
902 if (self->fut_exception != NULL) {
903 self->fut_log_tb = 0;
904 Py_INCREF(self->fut_exception);
905 return self->fut_exception;
924 _asyncio_Future_set_result(FutureObj *self, PyObject *result)
927 ENSURE_FUTURE_ALIVE(self)
928 return future_set_result(self, result);
944 _asyncio_Future_set_exception(FutureObj *self, PyObject *exception)
947 ENSURE_FUTURE_ALIVE(self)
948 return future_set_exception(self, exception);
967 _asyncio_Future_add_done_callback_impl(FutureObj *self, PyObject *fn,
976 PyObject *res = future_add_done_callback(self, fn, context);
980 return future_add_done_callback(self, fn, context);
995 _asyncio_Future_remove_done_callback(FutureObj *self, PyObject *fn)
1002 ENSURE_FUTURE_ALIVE(self)
1004 if (self->fut_callback0 != NULL) {
1005 int cmp = PyObject_RichCompareBool(self->fut_callback0, fn, Py_EQ);
1011 Py_CLEAR(self->fut_callback0);
1012 Py_CLEAR(self->fut_context0);
1017 if (self->fut_callbacks == NULL) {
1021 len = PyList_GET_SIZE(self->fut_callbacks);
1023 Py_CLEAR(self->fut_callbacks);
1028 PyObject *cb_tup = PyList_GET_ITEM(self->fut_callbacks, 0);
1036 Py_CLEAR(self->fut_callbacks);
1051 self->fut_callbacks != NULL && i < PyList_GET_SIZE(self->fut_callbacks);
1054 PyObject *item = PyList_GET_ITEM(self->fut_callbacks, i);
1072 if (j == 0 || self->fut_callbacks == NULL) {
1073 Py_CLEAR(self->fut_callbacks);
1082 len = PyList_GET_SIZE(self->fut_callbacks);
1084 if (PyList_SetSlice(self->fut_callbacks, 0, len, newlist) < 0) {
1109 _asyncio_Future_cancel_impl(FutureObj *self, PyObject *msg)
1112 ENSURE_FUTURE_ALIVE(self)
1113 return future_cancel(self, msg);
1123 _asyncio_Future_cancelled_impl(FutureObj *self)
1126 if (future_is_alive(self) && self->fut_state == STATE_CANCELLED) {
1144 _asyncio_Future_done_impl(FutureObj *self)
1147 if (!future_is_alive(self) || self->fut_state == STATE_PENDING) {
1162 _asyncio_Future_get_loop_impl(FutureObj *self)
1165 ENSURE_FUTURE_ALIVE(self)
1166 Py_INCREF(self->fut_loop);
1167 return self->fut_loop;
1393 _asyncio_Future__make_cancelled_error_impl(FutureObj *self)
1396 return create_cancelled_error(self);
1508 static void FutureObj_dealloc(PyObject *self);
1532 FutureObj_dealloc(PyObject *self)
1534 FutureObj *fut = (FutureObj *)self;
1540 if (PyObject_CallFinalizerFromDealloc(self) < 0) {
1546 PyObject_GC_UnTrack(self);
1549 PyObject_ClearWeakRefs(self);
1644 FutureIter_send(futureiterobject *self, PyObject *unused)
1647 * generator, it just returns self.result().
1649 return FutureIter_iternext(self);
1653 FutureIter_throw(futureiterobject *self, PyObject *const *args, Py_ssize_t nargs)
1705 Py_CLEAR(self->future);
1719 FutureIter_close(futureiterobject *self, PyObject *arg)
1721 Py_CLEAR(self->future);
2005 _asyncio_Task___init___impl(TaskObj *self, PyObject *coro, PyObject *loop,
2010 if (future_init((FutureObj*)self, loop)) {
2019 self->task_log_destroy_pending = 0;
2027 Py_XSETREF(self->task_context, PyContext_CopyCurrent());
2028 if (self->task_context == NULL) {
2032 self->task_context = Py_NewRef(context);
2035 Py_CLEAR(self->task_fut_waiter);
2036 self->task_must_cancel = 0;
2037 self->task_log_destroy_pending = 1;
2038 self->task_num_cancels_requested = 0;
2040 Py_XSETREF(self->task_coro, coro);
2049 Py_XSETREF(self->task_name, name);
2050 if (self->task_name == NULL) {
2054 if (task_call_step_soon(self, NULL)) {
2057 return register_task((PyObject*)self);
2158 _asyncio_Task__make_cancelled_error_impl(TaskObj *self)
2161 FutureObj *fut = (FutureObj*)self;
2194 _asyncio_Task_cancel_impl(TaskObj *self, PyObject *msg)
2197 self->task_log_tb = 0;
2199 if (self->task_state != STATE_PENDING) {
2203 self->task_num_cancels_requested += 1;
2208 // if (self->task_num_cancels_requested > 1) {
2212 if (self->task_fut_waiter) {
2216 res = _PyObject_CallMethodIdOneArg(self->task_fut_waiter,
2233 self->task_must_cancel = 1;
2235 Py_XSETREF(self->task_cancel_msg, msg);
2249 _asyncio_Task_cancelling_impl(TaskObj *self)
2253 return PyLong_FromLong(self->task_num_cancels_requested);
2268 _asyncio_Task_uncancel_impl(TaskObj *self)
2272 if (self->task_num_cancels_requested > 0) {
2273 self->task_num_cancels_requested -= 1;
2275 return PyLong_FromLong(self->task_num_cancels_requested);
2306 _asyncio_Task_get_stack_impl(TaskObj *self, PyObject *limit)
2310 asyncio_task_get_stack_func, self, limit, NULL);
2330 _asyncio_Task_print_stack_impl(TaskObj *self, PyObject *limit,
2335 asyncio_task_print_stack_func, self, limit, file, NULL);
2346 _asyncio_Task_set_result(TaskObj *self, PyObject *result)
2362 _asyncio_Task_set_exception(TaskObj *self, PyObject *exception)
2375 _asyncio_Task_get_coro_impl(TaskObj *self)
2378 Py_INCREF(self->task_coro);
2379 return self->task_coro;
2387 _asyncio_Task_get_name_impl(TaskObj *self)
2390 if (self->task_name) {
2391 Py_INCREF(self->task_name);
2392 return self->task_name;
2406 _asyncio_Task_set_name(TaskObj *self, PyObject *value)
2418 Py_XSETREF(self->task_name, value);
2546 TaskObj_dealloc(PyObject *self)
2548 TaskObj *task = (TaskObj *)self;
2550 if (Task_CheckExact(self)) {
2554 if (PyObject_CallFinalizerFromDealloc(self) < 0) {
2560 PyObject_GC_UnTrack(self);
2563 PyObject_ClearWeakRefs(self);