File tree Expand file tree Collapse file tree 2 files changed +8
-7
lines changed Expand file tree Collapse file tree 2 files changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -30,11 +30,12 @@ cdef class UVStream(UVBaseTransport):
30
30
cdef inline __reading_started(self )
31
31
cdef inline __reading_stopped(self )
32
32
33
- # The user API firstly calls _buffer_write() to buffer up user data chunks,
34
- # potentially multiple times in writelines(), and then call _start_write()
35
- # to start writing either immediately or in the next iteration.
33
+ # The user API write() and writelines() firstly call _buffer_write() to
34
+ # buffer up user data chunks, potentially multiple times in writelines(),
35
+ # and then call _initiate_write() to start writing either immediately or in
36
+ # the next iteration (loop._queue_write()).
36
37
cdef inline _buffer_write(self , object data)
37
- cdef inline _start_write (self )
38
+ cdef inline _initiate_write (self )
38
39
39
40
# _exec_write() is the method that does the actual send, and _try_write()
40
41
# is a fast-path used in _exec_write() to send a single chunk.
Original file line number Diff line number Diff line change @@ -420,7 +420,7 @@ cdef class UVStream(UVBaseTransport):
420
420
self ._buffer_size += dlen
421
421
self ._buffer.append(data)
422
422
423
- cdef inline _start_write (self ):
423
+ cdef inline _initiate_write (self ):
424
424
if (not self ._protocol_paused and
425
425
(< uv.uv_stream_t* > self ._handle).write_queue_size == 0 and
426
426
self ._buffer_size > self ._high_water):
@@ -681,7 +681,7 @@ cdef class UVStream(UVBaseTransport):
681
681
self ._conn_lost += 1
682
682
return
683
683
self ._buffer_write(buf)
684
- self ._start_write ()
684
+ self ._initiate_write ()
685
685
686
686
def writelines (self , bufs ):
687
687
self ._ensure_alive()
@@ -693,7 +693,7 @@ cdef class UVStream(UVBaseTransport):
693
693
return
694
694
for buf in bufs:
695
695
self ._buffer_write(buf)
696
- self ._start_write ()
696
+ self ._initiate_write ()
697
697
698
698
def write_eof (self ):
699
699
self ._ensure_alive()
You can’t perform that action at this time.
0 commit comments