@@ -548,7 +548,6 @@ cdef class SSLProtocol:
548
548
if self ._app_state == STATE_INIT:
549
549
self ._app_state = STATE_CON_MADE
550
550
self ._app_protocol.connection_made(self ._get_app_transport())
551
-
552
551
self ._wakeup_waiter()
553
552
554
553
# We should wakeup user code before sending the first data below. In
@@ -561,7 +560,7 @@ cdef class SSLProtocol:
561
560
new_MethodHandle(self ._loop,
562
561
" SSLProtocol._do_read" ,
563
562
< method_t> self ._do_read,
564
- None , # current context is good
563
+ None , # current context is good
565
564
self ))
566
565
567
566
# Shutdown flow
@@ -761,7 +760,7 @@ cdef class SSLProtocol:
761
760
new_MethodHandle(self ._loop,
762
761
" SSLProtocol._do_read" ,
763
762
< method_t> self ._do_read,
764
- None , # current context is good
763
+ None , # current context is good
765
764
self ))
766
765
except ssl_SSLAgainErrors as exc:
767
766
pass
@@ -797,12 +796,10 @@ cdef class SSLProtocol:
797
796
data.append(chunk)
798
797
except ssl_SSLAgainErrors as exc:
799
798
pass
800
-
801
799
if one:
802
800
self ._app_protocol.data_received(first)
803
801
elif not zero:
804
802
self ._app_protocol.data_received(b' ' .join(data))
805
-
806
803
if not chunk:
807
804
# close_notify
808
805
self ._call_eof_received()
@@ -892,12 +889,11 @@ cdef class SSLProtocol:
892
889
self ._app_reading_paused = False
893
890
if self ._state == WRAPPED:
894
891
self ._loop._call_soon_handle(
895
- new_MethodHandle1(self ._loop,
896
- " SSLProtocol._do_read" ,
897
- < method1_t> self ._do_read,
898
- context,
899
- self ,
900
- context))
892
+ new_MethodHandle(self ._loop,
893
+ " SSLProtocol._do_read" ,
894
+ < method_t> self ._do_read,
895
+ context,
896
+ self ))
901
897
902
898
# Flow control for reads from SSL socket
903
899
0 commit comments