File tree Expand file tree Collapse file tree 1 file changed +0
-16
lines changed Expand file tree Collapse file tree 1 file changed +0
-16
lines changed Original file line number Diff line number Diff line change @@ -44,22 +44,6 @@ cdef class Transport:
44
44
bint _full_packet_size
45
45
bint _is_async
46
46
47
- cdef int _get_data(self , ReadBuffer buf, object obj,
48
- ssize_t bytes_requested, ssize_t * bytes_read) except - 1 :
49
- """
50
- Simple function that performs a socket read while verifying that the
51
- server has not reset the connection. If it has, the dead connection
52
- error is raised instead.
53
- """
54
- try :
55
- bytes_read[0 ] = self ._transport.recv_into(obj, bytes_requested)
56
- except ConnectionResetError as e:
57
- errors._raise_err(errors.ERR_CONNECTION_CLOSED, str (e), cause = e)
58
- if bytes_read[0 ] == 0 :
59
- self .disconnect()
60
- buf._transport = None
61
- errors._raise_err(errors.ERR_CONNECTION_CLOSED)
62
-
63
47
cdef str _get_debugging_header(self , str operation):
64
48
"""
65
49
Returns the header line used for debugging packets.
You can’t perform that action at this time.
0 commit comments