blob: f15103ada859b5d12d6268a3b5efbf2deb811a02 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
cdef class UVRequest:
"""A base class for all libuv requests (uv_getaddrinfo_t, etc).
Important: it's a responsibility of the subclass to call the
"on_done" method in the request's callback.
If "on_done" isn't called, the request object will never die.
"""
def __cinit__(self, Loop loop, *_):
self.request = NULL
self.loop = loop
self.done = 0
Py_INCREF(self)
cdef on_done(self):
self.done = 1
Py_DECREF(self)
cdef cancel(self):
# Most requests are implemented using a threadpool. It's only
# possible to cancel a request when it's still in a threadpool's
# queue. Once it's started to execute, we have to wait until
# it finishes and calls its callback (and callback *must* call
# UVRequest.on_done).
cdef int err
if self.done == 1:
return
if UVLOOP_DEBUG:
if self.request is NULL:
raise RuntimeError(
'{}.cancel: .request is NULL'.format(
self.__class__.__name__))
if self.request.data is NULL:
raise RuntimeError(
'{}.cancel: .request.data is NULL'.format(
self.__class__.__name__))
if <UVRequest>self.request.data is not self:
raise RuntimeError(
'{}.cancel: .request.data is not UVRequest'.format(
self.__class__.__name__))
# We only can cancel pending requests. Let's try.
err = uv.uv_cancel(self.request)
if err < 0:
if err == uv.UV_EBUSY:
# Can't close the request -- it's executing (see the first
# comment). Loop will have to wait until the callback
# fires.
pass
elif err == uv.UV_EINVAL:
# From libuv docs:
#
# Only cancellation of uv_fs_t, uv_getaddrinfo_t,
# uv_getnameinfo_t and uv_work_t requests is currently
# supported.
return
else:
ex = convert_error(err)
self.loop._handle_exception(ex)
|
