From ab16cc347ee7eaae973d792579ab3dded1c0a722 Mon Sep 17 00:00:00 2001 From: taras Date: Sat, 7 Sep 2024 18:07:56 +0200 Subject: [PATCH] Undo some changes --- uvloop/sslproto.pyx | 18 +++++++----------- 1 file changed, 7 insertions(+), 11 deletions(-) diff --git a/uvloop/sslproto.pyx b/uvloop/sslproto.pyx index 5dc66796..9015ba57 100644 --- a/uvloop/sslproto.pyx +++ b/uvloop/sslproto.pyx @@ -548,7 +548,6 @@ cdef class SSLProtocol: if self._app_state == STATE_INIT: self._app_state = STATE_CON_MADE self._app_protocol.connection_made(self._get_app_transport()) - self._wakeup_waiter() # We should wakeup user code before sending the first data below. In @@ -561,7 +560,7 @@ cdef class SSLProtocol: new_MethodHandle(self._loop, "SSLProtocol._do_read", self._do_read, - None, # current context is good + None, # current context is good self)) # Shutdown flow @@ -761,7 +760,7 @@ cdef class SSLProtocol: new_MethodHandle(self._loop, "SSLProtocol._do_read", self._do_read, - None, # current context is good + None, # current context is good self)) except ssl_SSLAgainErrors as exc: pass @@ -797,12 +796,10 @@ cdef class SSLProtocol: data.append(chunk) except ssl_SSLAgainErrors as exc: pass - if one: self._app_protocol.data_received(first) elif not zero: self._app_protocol.data_received(b''.join(data)) - if not chunk: # close_notify self._call_eof_received() @@ -892,12 +889,11 @@ cdef class SSLProtocol: self._app_reading_paused = False if self._state == WRAPPED: self._loop._call_soon_handle( - new_MethodHandle1(self._loop, - "SSLProtocol._do_read", - self._do_read, - context, - self, - context)) + new_MethodHandle(self._loop, + "SSLProtocol._do_read", + self._do_read, + context, + self)) # Flow control for reads from SSL socket