@@ -16,16 +16,18 @@ cdef class _StreamWriteContext:
16
16
17
17
uv.uv_buf_t* uv_bufs
18
18
Py_buffer* py_bufs
19
- ssize_t py_bufs_len
19
+ size_t py_bufs_len
20
20
21
21
uv.uv_buf_t* uv_bufs_start
22
- ssize_t uv_bufs_len
22
+ size_t uv_bufs_len
23
23
24
24
UVStream stream
25
25
26
26
bint closed
27
27
28
28
cdef free_bufs(self ):
29
+ cdef size_t i
30
+
29
31
if self .uv_bufs is not NULL :
30
32
PyMem_Free(self .uv_bufs)
31
33
self .uv_bufs = NULL
@@ -61,7 +63,7 @@ cdef class _StreamWriteContext:
61
63
self .free_bufs()
62
64
Py_DECREF(self )
63
65
64
- cdef advance_uv_buf(self , int sent):
66
+ cdef advance_uv_buf(self , size_t sent):
65
67
# Advance the pointer to first uv_buf and the
66
68
# pointer to first byte in that buffer.
67
69
#
@@ -72,7 +74,7 @@ cdef class _StreamWriteContext:
72
74
73
75
cdef:
74
76
uv.uv_buf_t* buf
75
- int idx
77
+ size_t idx
76
78
77
79
for idx from 0 <= idx < self .uv_bufs_len:
78
80
buf = & self .uv_bufs_start[idx]
@@ -96,7 +98,7 @@ cdef class _StreamWriteContext:
96
98
cdef:
97
99
_StreamWriteContext ctx
98
100
int uv_bufs_idx = 0
99
- int py_bufs_len = 0
101
+ size_t py_bufs_len = 0
100
102
int i
101
103
102
104
Py_buffer* p_pybufs
@@ -481,7 +483,7 @@ cdef class UVStream(UVBaseTransport):
481
483
if err > 0 :
482
484
# Some data was successfully sent.
483
485
484
- if err == self ._buffer_size:
486
+ if < size_t > err == self ._buffer_size:
485
487
# Everything was sent.
486
488
ctx.close()
487
489
self ._buffer.clear()
@@ -494,7 +496,7 @@ cdef class UVStream(UVBaseTransport):
494
496
# Advance pointers to uv_bufs in `ctx`,
495
497
# we will reuse it soon for a uv_write
496
498
# call.
497
- ctx.advance_uv_buf(err)
499
+ ctx.advance_uv_buf(< ssize_t > err)
498
500
except Exception as ex: # This should never happen.
499
501
# Let's try to close the `ctx` anyways.
500
502
ctx.close()
0 commit comments