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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
|
# cython: language_level=3
from .includes cimport uv
from .includes cimport system
from libc.stdint cimport uint64_t, uint32_t, int64_t
include "includes/consts.pxi"
cdef extern from *:
ctypedef int vint "volatile int"
cdef class UVHandle
cdef class UVSocketHandle(UVHandle)
cdef class UVAsync(UVHandle)
cdef class UVTimer(UVHandle)
cdef class UVIdle(UVHandle)
cdef class UVBaseTransport(UVSocketHandle)
ctypedef object (*method_t)(object)
ctypedef object (*method1_t)(object, object)
ctypedef object (*method2_t)(object, object, object)
ctypedef object (*method3_t)(object, object, object, object)
cdef class Loop:
cdef:
uv.uv_loop_t *uvloop
bint _coroutine_debug_set
int _coroutine_origin_tracking_saved_depth
public slow_callback_duration
readonly bint _closed
bint _debug
bint _running
bint _stopping
uint64_t _thread_id
object _task_factory
object _exception_handler
object _default_executor
object _ready
set _queued_streams, _executing_streams
Py_ssize_t _ready_len
set _servers
object _transports
set _processes
dict _fd_to_reader_fileobj
dict _fd_to_writer_fileobj
set _signals
dict _signal_handlers
object _ssock
object _csock
bint _listening_signals
int _old_signal_wakeup_id
set _timers
dict _polls
UVProcess active_process_handler
UVAsync handler_async
UVIdle handler_idle
UVCheck handler_check__exec_writes
object _last_error
cdef object __weakref__
object _asyncgens
bint _asyncgens_shutdown_called
bint _executor_shutdown_called
char _recv_buffer[UV_STREAM_RECV_BUF_SIZE]
bint _recv_buffer_in_use
# DEBUG fields
# True when compiled with DEBUG.
# Used only in unittests.
readonly bint _debug_cc
readonly object _debug_handles_total
readonly object _debug_handles_closed
readonly object _debug_handles_current
readonly uint64_t _debug_uv_handles_total
readonly uint64_t _debug_uv_handles_freed
readonly uint64_t _debug_cb_handles_total
readonly uint64_t _debug_cb_handles_count
readonly uint64_t _debug_cb_timer_handles_total
readonly uint64_t _debug_cb_timer_handles_count
readonly uint64_t _debug_stream_shutdown_errors_total
readonly uint64_t _debug_stream_listen_errors_total
readonly uint64_t _debug_stream_read_cb_total
readonly uint64_t _debug_stream_read_cb_errors_total
readonly uint64_t _debug_stream_read_eof_total
readonly uint64_t _debug_stream_read_eof_cb_errors_total
readonly uint64_t _debug_stream_read_errors_total
readonly uint64_t _debug_stream_write_tries
readonly uint64_t _debug_stream_write_errors_total
readonly uint64_t _debug_stream_write_ctx_total
readonly uint64_t _debug_stream_write_ctx_cnt
readonly uint64_t _debug_stream_write_cb_errors_total
readonly uint64_t _poll_read_events_total
readonly uint64_t _poll_read_cb_errors_total
readonly uint64_t _poll_write_events_total
readonly uint64_t _poll_write_cb_errors_total
readonly uint64_t _sock_try_write_total
readonly uint64_t _debug_exception_handler_cnt
cdef _init_debug_fields(self)
cdef _on_wake(self)
cdef _on_idle(self)
cdef __run(self, uv.uv_run_mode)
cdef _run(self, uv.uv_run_mode)
cdef _close(self)
cdef _stop(self, exc)
cdef uint64_t _time(self)
cdef inline _queue_write(self, UVStream stream)
cdef _exec_queued_writes(self)
cdef inline _call_soon(self, object callback, object args, object context)
cdef inline _append_ready_handle(self, Handle handle)
cdef inline _call_soon_handle(self, Handle handle)
cdef _call_later(self, uint64_t delay, object callback, object args,
object context)
cdef void _handle_exception(self, object ex)
cdef inline _is_main_thread(self)
cdef inline _new_future(self)
cdef inline _check_signal(self, sig)
cdef inline _check_closed(self)
cdef inline _check_thread(self)
cdef _getaddrinfo(self, object host, object port,
int family, int type,
int proto, int flags,
int unpack)
cdef _getnameinfo(self, system.sockaddr *addr, int flags)
cdef _track_transport(self, UVBaseTransport transport)
cdef _fileobj_to_fd(self, fileobj)
cdef _ensure_fd_no_transport(self, fd)
cdef _track_process(self, UVProcess proc)
cdef _untrack_process(self, UVProcess proc)
cdef _add_reader(self, fd, Handle handle)
cdef _has_reader(self, fd)
cdef _remove_reader(self, fd)
cdef _add_writer(self, fd, Handle handle)
cdef _has_writer(self, fd)
cdef _remove_writer(self, fd)
cdef _sock_recv(self, fut, sock, n)
cdef _sock_recv_into(self, fut, sock, buf)
cdef _sock_sendall(self, fut, sock, data)
cdef _sock_accept(self, fut, sock)
cdef _sock_connect(self, sock, address)
cdef _sock_connect_cb(self, fut, sock, address)
cdef _sock_set_reuseport(self, int fd)
cdef _setup_or_resume_signals(self)
cdef _shutdown_signals(self)
cdef _pause_signals(self)
cdef _handle_signal(self, sig)
cdef _read_from_self(self)
cdef inline _ceval_process_signals(self)
cdef _invoke_signals(self, bytes data)
cdef _set_coroutine_debug(self, bint enabled)
cdef _print_debug_info(self)
include "cbhandles.pxd"
include "handles/handle.pxd"
include "handles/async_.pxd"
include "handles/idle.pxd"
include "handles/check.pxd"
include "handles/timer.pxd"
include "handles/poll.pxd"
include "handles/basetransport.pxd"
include "handles/stream.pxd"
include "handles/streamserver.pxd"
include "handles/tcp.pxd"
include "handles/pipe.pxd"
include "handles/process.pxd"
include "handles/fsevent.pxd"
include "request.pxd"
include "sslproto.pxd"
include "handles/udp.pxd"
include "server.pxd"
|
