blob: 8ca87437429dd3c3f474cb54712f43afffd1b7c5 (
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
|
cdef class UVStream(UVBaseTransport):
cdef:
uv.uv_shutdown_t _shutdown_req
bint __shutting_down
bint __reading
bint __read_error_close
bint __buffered
object _protocol_get_buffer
object _protocol_buffer_updated
bint _eof
list _buffer
size_t _buffer_size
Py_buffer _read_pybuf
bint _read_pybuf_acquired
# All "inline" methods are final
cdef inline _init(self, Loop loop, object protocol, Server server,
object waiter, object context)
cdef inline _shutdown(self)
cdef inline _accept(self, UVStream server)
cdef inline _close_on_read_error(self)
cdef inline __reading_started(self)
cdef inline __reading_stopped(self)
# The user API write() and writelines() firstly call _buffer_write() to
# buffer up user data chunks, potentially multiple times in writelines(),
# and then call _initiate_write() to start writing either immediately or in
# the next iteration (loop._queue_write()).
cdef inline _buffer_write(self, object data)
cdef inline _initiate_write(self)
# _exec_write() is the method that does the actual send, and _try_write()
# is a fast-path used in _exec_write() to send a single chunk.
cdef inline _exec_write(self)
cdef inline _try_write(self, object data)
cdef _close(self)
cdef inline _on_accept(self)
cdef inline _on_eof(self)
cdef inline _on_write(self)
cdef inline _on_connect(self, object exc)
|
