+
V@i
^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIH t ^ RI
H t ^ RI H
t
Ht ^ RIHt ^ RIHtHt ^ RIHt ^ RIHt ^ R IHt ^ R
IHtH t ^ R I H t H t H t H!t! ^ R I"H#t#H$t$ ^ RI%t
^ R
I&H't' ^ RI%H*t*H+t+H,t,H-t- ^ RI
H.t. ! R R]*4 t/ ! R R]/4 t0 ! R R]/4 t1 ! R R]/4 t2 ! R R]/4 t3 ! R R]$4 t4 ! R R ]$4 t5 ! R R ]/4 t6 ! R R!]/4 t7 ! R" R#]/4 t8 ! R$ R%]/4 t9 ! R& R']/4 t: ! R( R)]/4 t; ! R* R+]/4 t< ! R, R-]/4 t= ! R. R/]/4 t> ! R0 R1]/4 t? ! R2 R3] 4 t@ ! R4 R5]@4 tA ! R6 R7]/4 tB ! R8 R9]@4 tC] ! R: R;]@4 4 tD] ! R< R=]D4 4 tE ! R> R?]E4 tF ! R@ RA]E4 tG ! RB RC]E4 tH ! RD RE]D4 tI] ! RF RG]P 4 4 tK ! RH RI]K4 tL]P ! ].RJ RJ4 ! RK RL]K4 4 tN ! RM RN]@4 tO ! RO RP]@4 tP ! RQ RR]@4 tQ ! RS RT]P 4 tR ! RU RV]@4 tS ! RW RX]@4 tTR# ]( d ]PR ! 4 h i ; i ]( d Rt. ELi ; i)Y N)Future)gen) HTTPError HTTPRequest)Event)gen_logapp_log)ResolverSimpleAsyncHTTPClient)
DictLoader)abstract_base_testignore_deprecation)AsyncHTTPTestCasegen_testbind_unused_port ExpectLog) ApplicationRequestHandler_websocket_mask_python)WebSocketHandlerwebsocket_connectWebSocketErrorWebSocketClosedError)speedupsc : a ] tR t^.t o RtRR ltR tR tRtV t R# )TestWebSocketHandlerzBase class for testing handlers that exposes the on_close event.
This allows for tests to see the close code and reason on the
server side.
Nc Wn W n R # N close_futurecompression_options)selfr" r# s &&&=/usr/lib/python3/dist-packages/tornado/test/websocket_test.py
initialize TestWebSocketHandler.initialize6 s (#6 c V P # r r# r$ s &r% get_compression_options,TestWebSocketHandler.get_compression_options: s '''r( c V P e4 V P P V P V P 34 R # R # r )r"
set_result
close_code close_reasonr+ s &r% on_close TestWebSocketHandler.on_close= s6 ( ( ($//4;L;L)M N )r( r! NN)
__name__
__module__ __qualname____firstlineno____doc__r& r, r2 __static_attributes____classdictcell__
__classdict__s @r% r r . s 7(O Or( r c D a ] tR t^Bt o ]P
R 4 tRtV tR# ) EchoHandlerc # " V P V\ V\ 4 4 x R # \ P d R # \
d R # i ; i5ir )
write_message
isinstancebytesasyncioCancelledErrorr r$ messages &&r%
on_messageEchoHandler.on_messageC sF $$Wj%.HI I%% # s6 A"( AAA A A
A
AA N) r5 r6 r7 r8 r coroutinerH r: r; r< s @r% r? r? B s ]] r( r? c & a ] tR t^Mt o R tRtV tR# )ErrorInOnMessageHandlerc ^^ , R# ) NrJ rF s &&r% rH "ErrorInOnMessageHandler.on_messageN s Ar( rJ Nr5 r6 r7 r8 rH r: r; r< s @r% rM rM M s r( rM c & a ] tR t^Rt o R tRtV tR# )
HeaderHandlerc < \ P ! V P R 4 \ P ! V P R4 \ P ! V P RR4 \ P ! V P
RR4 \ P ! V P R4 V P V P .pV F p V! 4 \ R4 h V P V P P P RR4 4 R# \ d K] i ; i) zThis should not workzhttp://localhost/elsewhereX-Test ChocolateChipi z did not get expected exceptionN) functoolspartialwriteredirect
set_header
set_cookie
set_statusflushfinish Exception RuntimeErrorrA requestheadersget)r$ methods_to_testmethods & r% openHeaderHandler.openS s djj*@ A dmm-I J doox < doo{F C doos 3 JJ KK
&F
@AA &
4<<//33HbAB
s D DDrJ Nr5 r6 r7 r8 ri r: r; r< s @r% rS rS R s C Cr( rS c , a ] tR t^ht o R tR tRtV tR# )HeaderEchoHandlerc * V P R R4 R# )X-Extra-Response-HeaderExtra-Response-ValueN)r] r+ s &r% set_default_headers%HeaderEchoHandler.set_default_headersi s 13IJr( c V P P P 4 F= w rVP 4 P R 4 ' g K, V P W4 K? R# )zx-testN)rd re get_alllower
startswithr] )r$ kvs & r% prepareHeaderEchoHandler.preparel sD LL((002DAwwy##H--% 3r( rJ N)r5 r6 r7 r8 rq ry r: r; r< s @r% rm rm h s K& &r( rm c & a ] tR t^rt o R tRtV tR# )NonWebSocketHandlerc ( V P R 4 R# )okN)r[ r+ s &r% rf NonWebSocketHandler.gets s
4r( rJ Nr5 r6 r7 r8 rf r: r; r< s @r% r| r| r s r( r| c & a ] tR t^wt o R tRtV tR# )RedirectHandlerc ( V P R 4 R# )/echoN)r\ r+ s &r% rf RedirectHandler.getx s
g r( rJ Nr r< s @r% r r w s r( r c & a ] tR t^|t o R tRtV tR# )CloseReasonHandlerc 8 R V n V P RR4 R# )F goodbyeN)on_close_calledcloser+ s &r% ri CloseReasonHandler.open} s $
4#r( )r Nrk r< s @r% r r | $ $r( r c J a ] tR t^t o ]P
R 4 tR tRtV t R# )AsyncPrepareHandlerc # 2 " \ P x R # 5ir )r momentr+ s &r% ry AsyncPrepareHandler.prepare s jjs c ( V P V4 R # r rA rF s &&r% rH AsyncPrepareHandler.on_message s 7#r( rJ N)
r5 r6 r7 r8 r rK ry rH r: r; r< s @r% r r s% ]] $ $r( r c & a ] tR t^t o R tRtV tR# )PathArgsHandlerc ( V P V4 R # r r )r$ args &&r% ri PathArgsHandler.open s 3 r( rJ Nrk r< s @r% r r r( r c V a a ] tR t^t oV 3R lt]P R 4 tRtVt V ;t
# )CoroutineOnMessageHandlerc 6 < \ SV ` ! R/ VB ^ V n R# r NrJ superr& sleepingr$ kwargs __class__s &,r% r& $CoroutineOnMessageHandler.initialize
$V$
r( c # " V P ^ 8 d V P R4 V ;P ^,
un \ P ! R4 x V ;P ^, un V P V4 R# 5ir z%another coroutine is already sleeping{Gz?Nr rA r sleeprF s &&r% rH $CoroutineOnMessageHandler.on_message sX ==1 F G
iio
7#s B Br ) r5 r6 r7 r8 r& r rK rH r: r;
__classcell__r r= s @@r% r r s' ]]$ $ $r( r c & a ] tR t^t o R tRtV tR# )RenderMessageHandlerc J V P V P R VR7 4 R# ) message.html)rG N)rA
render_stringrF s &&r% rH RenderMessageHandler.on_message s 4--ng-NOr( rJ NrQ r< s @r% r r s P Pr( r c > a a ] tR t^t oV 3R ltR tR tRtVtV ;t # )SubprotocolHandlerc 6 < \ SV ` ! R/ VB R V n R# FNrJ )r r& select_subprotocol_calledr s &,r% r& SubprotocolHandler.initialize s
$V$).&r( c ` V P ' d \ R 4 hRV n RV9 d R# R# )z select_subprotocol called twiceT goodprotoN)r rb )r$ subprotocolss &&r% select_subprotocol%SubprotocolHandler.select_subprotocol s0 ) ) ) => >)-& , & r( c V P ' g \ R 4 hV P RV P , 4 R# )z select_subprotocol not calledzsubprotocol=%sN)r rb rA selected_subprotocolr+ s &r% ri SubprotocolHandler.open s4 --- ;< < +d.G.GGHr( )r )
r5 r6 r7 r8 r& r ri r: r; r r s @@r% r r s /I Ir( r c \ a a ] tR t^t oV 3R lt]P R 4 tR tRt Vt
V ;t # )OpenCoroutineHandlerc B < \ SV ` ! R/ VB Wn R V n R# r )r r& test
open_finished)r$ r r r s &&,r% r& OpenCoroutineHandler.initialize s
$V$ "r( c # " V P P P 4 x \ P ! R 4 x RV n R# 5i)r TN)r message_sentwaitr r r r+ s &r% ri OpenCoroutineHandler.open s5 ii$$))++ii !s AA
c b V P ' g \ R 4 hV P R4 R# )z&on_message called before open finishedr~ N)r rb rA rF s &&r% rH OpenCoroutineHandler.on_message s( !!! DE E 4 r( )r r ) r5 r6 r7 r8 r& r rK ri rH r: r; r r s @@r% r r s, #
]]" "
! !r( r c & a ] tR t^t o R tRtV tR# )ErrorInOpenHandlerc \ R 4 h)boom)rb r+ s &r% ri ErrorInOpenHandler.open s
r( rJ Nrk r< s @r% r r r r( r c & a ] tR t^t o R tRtV tR# )ErrorInAsyncOpenHandlerc ` " \ P ! ^ 4 G Rj xL
\ R4 h L5i)r Nr )rD r rb r+ s &r% ri ErrorInAsyncOpenHandler.open s' mmA s .,.rJ Nrk r< s @r% r r s r( r c & a ] tR t^t o R tRtV tR# )NoDelayHandlerc J V P R 4 V P R4 R# )ThelloN) set_nodelayrA r+ s &r% ri NoDelayHandler.open s 7#r( rJ Nrk r< s @r% r r r r( r c b a a ] tR t^t oV 3R ltV 3R lt]P R 4 tRt Vt
V ;t # )WebSocketBaseTestCasec 2 < \ SV ` 4 . V n R # r )r setUpconns_to_closer$ r s &r% r WebSocketBaseTestCase.setUp s
r( c j < V P F pVP 4 K \ SV `
4 R # r )r r r tearDown)r$ connr s & r% r WebSocketBaseTestCase.tearDown s' ''D JJL (
r( c + " \ R V P 4 V3, 3/ VB x pV P P V4 \ P
! V4 h5i)zws://127.0.0.1:%d%s)r
get_http_portr appendr Return)r$ pathr wss &&, r%
ws_connect WebSocketBaseTestCase.ws_connect sV $ !T%7%7%94$@ @
DJ
""2&jjn s AA)r ) r5 r6 r7 r8 r r r rK r r: r; r r s @@r% r r s, !
]] r( r c 6 a a ] tR t^t oR tR tV 3R ltR tR tR t ]
R 4 t R t ]
R 4 t
]
R
4 t]
R 4 t]
R 4 t]
R
4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t]
R 4 t ]
R 4 t ]
R 4 t ]
R 4 t ]
R 4 t ]
R 4 t!]
R 4 t"]
R 4 t#]
R 4 t$]
R! 4 t%]
R" 4 t&]
R# 4 t']
R$ 4 t(]
R% 4 t)R&t*Vt+V ;t,# )'
WebSocketTestc \ 4 V n \ R \ \ V P R7 3R\
3R\ 3R\ \ V P R7 3R\ \ V P R7 3R\ \ V P R7 3R\ \ V P R7 3R\ \ V P R7 3R \ \ V P R7 3R
\ \ V P R7 3R \ \ V P R7 3R \ \ V P R7 3R
\ \ V P V R7 3R\" 3R\$ 3R\& 3.\) RR/4 R7 # )r )r" /non_ws /redirectz/headerz /header_echo
/close_reason/error_in_on_message/async_preparez/path_args/(.*)
/coroutine/render /subprotocol/open_coroutine)r" r /error_in_open/error_in_async_open/nodelayr z{{ message }})template_loader)r r" r r? dictr| r rS rm r rM r r r r r r r r r r
r+ s &r% get_appWebSocketTest.get_app sv "H+t9J9J'KL /0 o.M4T=N=N+OP"%d&7&78 $&d&7&78 ++d&7&78 %'d&7&78 &#d&7&78 !-d&7&78
0$DDUDU2VW"&d&7&78 &(d&7&7dC
"#56')@A^,a1
d '8N'O Pg4
4
r( c \ 4 # r r r+ s &r% get_http_client WebSocketTest.get_http_client& s $&&r( c ` < \ SV ` 4 \ P P 4 R # r )r r r _template_loadersclearr s &r% r WebSocketTest.tearDown* s
((..0r( c ` V P R 4 pV P VP R4 R# )r Nfetch assertEqualcoder$ responses & r% test_http_request WebSocketTest.test_http_request. s$ ::g& ,r( c p V P R RRRRRR/R7 pV P VP R4 R# ) r
ConnectionUpgrade WebSocketSec-WebSocket-Version13re r Nr r s & r% test_missing_websocket_key(WebSocketTest.test_missing_websocket_key3 B :: i;'
,r( c p V P R RRRRRR/R7 pV P VP R4 R# ) r r r r r 12r i Nr r s & r% test_bad_websocket_version(WebSocketTest.test_bad_websocket_version> r! r( c # " V P R 4 x pVP R4 x VP 4 x pV P VR4 R# 5i)r r Nr rA read_messager r$ r r s & r% test_websocket_gen WebSocketTest.test_websocket_genI sF ??7+
+ w'' ** 7+ A
Ac . a \ 4 ;_uu_ 4 \ R S P 4 , S P R7 RRR4 S P 4 P 4 pVP
R4 VP S P 4 S P 4 P 4 pS P VR4 S P P V 3R l4 VP 4 S P 4 R# + ' g i L; i)ws://127.0.0.1:%d/echo)callbackNr c $ < SP 4 # r )stop)fr$ s &r% 8WebSocketTest.test_websocket_callbacks..Z s diikr( ) r r r r1 r resultrA r( r r" add_done_callbackr r) s f r% test_websocket_callbacks&WebSocketTest.test_websocket_callbacksP s
!
! (4+=+=+??$))
" YY[
!
!
"99;%%' 7+ ++,AB
"
!s -D D c # " V P R 4 x pVP RRR7 VP 4 x pV P VR4 R# 5i)r s hello TbinaryNr' r) s & r% test_binary_message!WebSocketTest.test_binary_message^ sH ??7+
+
t4 ** =1r, c # " V P R 4 x pVP R4 VP 4 x pV P VR4 R# 5ir u hello éNr' r) s & r% test_unicode_message"WebSocketTest.test_unicode_messagee sC ??7+
+
( ** >2 A A
c # " V P R 4 x pVP 4 V P \ 4 ;_uu_ 4 VP R4 RRR4 R# + ' g i R# ; i5ir? )r r assertRaisesr rA r$ r s & r% )test_error_in_closed_client_write_message7WebSocketTest.test_error_in_closed_client_write_messagel sM ??7+
+
3
4
4 ^ , 5
4
4
4s AA3A
A3 A0 * A3c # " V P R 4 x pVP R4 VP 4 x pV P VR4 R# 5i)r r z helloNr' r) s & r% test_render_message!WebSocketTest.test_render_messages sC ??9-
-
! ** >2rB c # " V P R 4 x pVP R4 \ \ R4 ;_uu_ 4 VP 4 x pRRR4 V P X4 R# + ' g i L#; i5i)r r Uncaught exceptionN)r rA r r r( assertIsNoner) s & r% test_error_in_on_message&WebSocketTest.test_error_in_on_messagez s] ??#9:
:
!
w 4
5
5 __ ..H 6 (# 6
5s =B A-B - A= 8B c # " V P \ 4 ;_uu_ 4 pV P R 4 x RRR4 V P XP P
R4 R# + ' g i L8; i5i)z /notfoundNi )rD r r r exceptionr )r$ cms & r% test_websocket_http_fail&WebSocketTest.test_websocket_http_fail sN
y
)
)R//+. . * **C0 *
)s A7A$0A7$ A4 /A7c # " V P \ 4 ;_uu_ 4 V P R 4 x RRR4 R# + ' g i R# ; i5i)r N)rD r r r+ s &r% test_websocket_http_success)WebSocketTest.test_websocket_http_success s3
~
.
.//), , /
.
.
. A>
A A Ac # " V P \ 4 ;_uu_ 4 V P R 4 x RRR4 R# + ' g i R# ; i5i)r N)rD r r r+ s &r% test_websocket_http_redirect*WebSocketTest.test_websocket_http_redirect s3
y
)
)//+. . *
)
)
)rX c # R " \ 4 w rVP 4 V P \ 4 ;_uu_ 4 \ \
R RR7 ;_uu_ 4 \
RV, RR7 x RRR4 RRR4 R# + ' g i L; i + ' g i R# ; i5i)z.*F)requiredzws://127.0.0.1:%d/i )connect_timeoutN)r r rD IOErrorr r r )r$ sockports & r% test_websocket_network_fail)WebSocketTest.test_websocket_network_fail sn %'
w
'
'7D599'(4/ : (
'99 (
'
's4 :B'BB .B6
B' B
B B$ B'c # < " \ P ! \ R V P 4 , 4 x 4 ;_uu_ 4 pVP R4 VP R4 VP
P
4 RRR4 R# + ' g i R# ; i5i)r. r worldN)
contextlibclosingr r rA streamr rE s & r% "test_websocket_close_buffered_data0WebSocketTest.test_websocket_close_buffered_data ss
$%=@R@R@T%TU
U
W % W % IIOO
s ?B =B>
B B B c # & " \ P ! \ \ R V P 4 , RR/R7 4 x 4 ;_uu_ 4 pVP 4 x pV P
VR4 RRR4 R# + ' g i R# ; i5i)zws://127.0.0.1:%d/headerrU r r N)rf rg r r r r( r r) s & r% test_websocket_headers$WebSocketTest.test_websocket_headers s
' 2T5G5G5II!)7 3
__ ..H Xw /
s A B%A=3
B= B Bc # " \ P ! \ \ R V P 4 , RR/R7 4 x 4 ;_uu_ 4 pV P VP P R4 R4 V P VP P R4 R4 RRR4 R# + ' g i R# ; i5i)z ws://127.0.0.1:%d/header_echoz X-Test-Hellor r ro rp N)rf rg r r r r re rf rE s & r% test_websocket_header_echo(WebSocketTest.test_websocket_header_echo s
' 7$:L:L:NN!/ 9
RZZ^^N ;W E
89;Q
s A CAB/%
C/ C : Cc # 0 " V P R 4 x pVP 4 x pV P VR4 V P VP R4 V P VP
R4 V P x w r4V P VR4 R# 5i)r Nr r )r r( assertIsr r0 r1 r" )r$ r msgr reasons & r% test_server_close_reason&WebSocketTest.test_server_close_reason s} ???3
3OO%%
c4 - )4 ! . ..
t$s BBc # " V P R 4 x pVP RR4 V P x w r#V P VR4 V P VR4 R# 5i)r r r N)r r r" r )r$ r r rt s & r% test_client_close_reason&WebSocketTest.test_client_close_reason sT ??7+
+
y! ! . .. t$ +s A A c # " V P R 4 x pVP 4 x pV P VR4 V P \ 4 ;_uu_ 4 VP R4 RRR4 R# + ' g i R# ; i5i)r Nr )r r( rr rD r rA )r$ r rs s & r% test_write_after_close$WebSocketTest.test_write_after_close sa ???3
3OO%%
c4
3
4
4 W % 5
4
4
4s ABA3)
B3 B > Bc # " V P R 4 x pVP R4 VP 4 x pV P VR4 R# 5i)r r Nr' r$ r ress & r% test_async_prepare WebSocketTest.test_async_prepare sF ??#34
4
!OO%% g&rB c # | " V P R 4 x pVP 4 x pV P VR4 R# 5i)z/path_args/hellor Nr r( r r~ s & r% test_path_args WebSocketTest.test_path_args s6 ??#56
6OO%% g& :<c # " V P R 4 x pVP R4 x VP R4 x VP 4 x pV P VR4 VP 4 x pV P VR4 R# 5i)r hello1hello2Nr' r~ s & r% test_coroutine WebSocketTest.test_coroutine sv ??<0
0 x(( x((OO%% h'OO%% h' BBc # ` " V P 4 pR V, pRRV, /p\ P ! \ \ W#R7 4 x 4 ;_uu_ 4 pVP R4 VP
4 x pV P VR4 RRR4 R# + ' g i R# ; i5i)r. Originzhttp://127.0.0.1:%dr r Nr rf rg r r rA r( r r$ ra urlre r r s & r% test_check_origin_valid_no_path-WebSocketTest.test_check_origin_valid_no_path s !!#&- 2T 9:
$[%FG
G
W % __ ..H Xw /
AB.6B
B. B+ % B.c # ` " V P 4 pR V, pRRV, /p\ P ! \ \ W#R7 4 x 4 ;_uu_ 4 pVP R4 VP
4 x pV P VR4 RRR4 R# + ' g i R# ; i5i)r. r z http://127.0.0.1:%d/somethingr r Nr r s & r% !test_check_origin_valid_with_path/WebSocketTest.test_check_origin_valid_with_path s !!#&- >(01GG1 >> ) MM> ? &- 9:
y
)
)R#K$EF F *
**C0 2 *
)s) 1C8C AC8C%05C8% C5 0C8c # " V P R RR.R7 x pV P VP R4 VP 4 x pV P VR4 R# 5i)r badprotor )r zsubprotocol=goodprotoN)r r r r( r~ s & r% test_subprotocols WebSocketTest.test_subprotocolsO s_ ?? *k)B #
00+>OO%% 56s AA c # " V P R 4 x pV P VP R4 VP 4 x pV P VR4 R# 5i)r Nzsubprotocol=None)r rr r r( r r~ s & r% test_subprotocols_not_offered+WebSocketTest.test_subprotocols_not_offeredX sJ ??>2
2
b--t4OO%% 01s AAc # " \ 4 V n V P R 4 x pVP R4 x V P P 4 VP 4 x pV P
VR4 R# 5i)r r r~ N)r r r rA setr( r r~ s & r% test_open_coroutine!WebSocketTest.test_open_coroutine_ sc !G??#45
5 w'' OO%% d#s A6A8c # " \ \ R 4 ;_uu_ 4 V P R4 x pVP 4 x pRRR4 V P X4 R# + ' g i L#; i5i)rL r Nr r r r( rM r~ s & r% test_error_in_open WebSocketTest.test_error_in_openh sQ
w 4
5
5'788B))C 6
# 6
5 A/&A A/ A, 'A/c # " \ \ R 4 ;_uu_ 4 V P R4 x pVP 4 x pRRR4 V P X4 R# + ' g i L#; i5i)rL r Nr r~ s & r% test_error_in_async_open&WebSocketTest.test_error_in_async_openo sQ
w 4
5
5'=>>B))C 6
# 6
5r c # | " V P R 4 x pVP 4 x pV P VR4 R# 5i)r r Nr r~ s & r% test_nodelayWebSocketTest.test_nodelayv s5 ??:.
.OO%% g&r )r" r )-r5 r6 r7 r8 r r r r r r$ r r* r7 r< r@ rF rI rN rS rV rZ rb ri rl ro ru rx r{ r r r r r r r r r r r r r r r: r; r r s @@r% r r s 6
p'1-
- - , , 2 2 3 3 - - 3 3 $ $ 1 1
- - / /
0
0 & % % , , & & ' ' ' '
( ( 0 0 0 0 1 1 1 1 1 1, 7 7 2 2 $ $ ' ' 'r( r c 8 a a ] tR tRt oV 3R ltR tRtVtV ;t# ) NativeCoroutineOnMessageHandleri} c 6 < \ SV ` ! R/ VB ^ V n R# r r r s &,r% r& *NativeCoroutineOnMessageHandler.initialize~ r r( c " V P ^ 8 d V P R4 V ;P ^,
un \ P ! R4 G Rj xL
V ;P ^, un V P V4 R# L05ir r rF s &&r% rH *NativeCoroutineOnMessageHandler.on_message s` ==1 F G
iio
7# s AB
B1B
r ) r5 r6 r7 r8 r& rH r: r; r r s @@r% r r } s $ $r( r c 6 a ] tR tRt o R t]R 4 tRtV tR# ) WebSocketNativeCoroutineTesti c & \ R \ 3.4 # )/native)r r r+ s &r% r $WebSocketNativeCoroutineTest.get_app s Y(G HIJJr( c # " V P R 4 x pVP R4 x VP R4 x VP 4 x pV P VR4 VP 4 x pV P VR4 R# 5i)r r r Nr' r~ s & r% test_native_coroutine2WebSocketNativeCoroutineTest.test_native_coroutine sv ??9-
- x(( x((OO%% h'OO%% h'r rJ N) r5 r6 r7 r8 r r r r: r; r< s @r% r r s K ( (r( r c h a ] tR tRt o RtR tR tR tV 3R lR lt] R 4 t
] R 4 t R
t V t
R # ) CompressionTestMixini z Hello world. Testing 123 123c ! R R\ 4 p\ R\ \ V P 4 R7 3RV\ V P 4 R7 3.4 # )c 6 a ] tR tRt o ]R 4 tR tRtV tR# )4CompressionTestMixin.get_app..LimitedHandleri c R # ) rJ r+ s &r% max_message_sizeECompressionTestMixin.get_app..LimitedHandler.max_message_size s r( c L V P \ \ V4 4 4 R # r )rA strlenrF s &&r% rH ?CompressionTestMixin.get_app..LimitedHandler.on_message s ""3s7|#45r( rJ N) r5 r6 r7 r8 propertyr rH r: r; r< s @r% LimitedHandlerr s!
6
6r( r r r* /limited)r r r? r get_server_compression_options)r$ r s & r% r CompressionTestMixin.get_app s_ 6 1 6 T-P-P-RS "T-P-P-RS
r( c R # r rJ r+ s &r% r 3CompressionTestMixin.get_server_compression_options r( c R # r rJ r+ s &r% get_client_compression_options3CompressionTestMixin.get_client_compression_options r r( c * < V ^8 d QhRS[ RS[ RR/# ) bytes_in bytes_outreturnN)int)formatr= s "r% __annotate__!CompressionTestMixin.__annotate__ s" $ $# $# $$ $r( c \ 4 hr NotImplementedErrorr$ r r s &&&r% verify_wire_bytes&CompressionTestMixin.verify_wire_bytes !##r( c # | " V P R V P 4 R7 x p\ ^4 FK pVP V P 4 VP 4 x pV P
W0P 4 KM V P
VP P \ V P 4 ^, 4 V P
VP P \ V P 4 ^, 4 V P VP P VP P 4 R# 5i)r r* N)r r rangerA MESSAGEr( r protocol_message_bytes_outr _message_bytes_inr _wire_bytes_in_wire_bytes_outr$ r ir s & r% test_message_sizes'CompressionTestMixin.test_message_sizes s ?? )L)L)N #
qA T\\ * __ ..H X|| 4
77T\\9JQ9NO 66DLL8IA8MN r{{ 9 92;;;V;VWs D:D<c # & " V P R V P 4 R7 x pVP R4 VP 4 x pV P VR4 VP R4 VP 4 x pV P V4 R# 5i)r r* 128Nڀaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r r rA r( r rM r) s & r% test_size_limit$CompressionTestMixin.test_size_limit s ?? D,O,O,Q #
# ** 5) $ ** (#s BBrJ N)r5 r6 r7 r8 r r r r r r r r r: r; r< s @r% r r sM ,G
0$ $ X X $ $r( r c * a ] tR tRt o RtR tRtV tR# )UncompressedTestMixini zESpecialization of CompressionTestMixin when we expect no compression.c V P V^\ V P 4 ^, , 4 V P V^\ V P 4 ^, , 4 R# N)r r r r s &&&r% r 'UncompressedTestMixin.verify_wire_bytes sH AT\\):Q)>$?@ 1DLL(9A(=#>?r( rJ N)r5 r6 r7 r8 r9 r r: r; r< s @r% r r s O@ @r( r c ] tR tRtRtR# )NoCompressionTesti rJ N)r5 r6 r7 r8 r: rJ r( r% r r s r( r c & a ] tR tRt o R tRtV tR# )ServerOnlyCompressionTesti c / # r rJ r+ s &r% r 8ServerOnlyCompressionTest.get_server_compression_options r( rJ N)r5 r6 r7 r8 r r: r; r< s @r% r r r( r c & a ] tR tRt o R tRtV tR# )ClientOnlyCompressionTesti c / # r rJ r+ s &r% r 8ClientOnlyCompressionTest.get_client_compression_options r r( rJ N)r5 r6 r7 r8 r r: r; r< s @r% r r r r( r c 2 a ] tR tRt o R tR tR tRtV tR# )DefaultCompressionTesti c / # r rJ r+ s &r% r 5DefaultCompressionTest.get_server_compression_options r r( c / # r rJ r+ s &r% r 5DefaultCompressionTest.get_client_compression_options r r( c V P V^\ V P 4 ^, , 4 V P V^\ V P 4 ^, , 4 V P W!^ , 4 R# r
)
assertLessr r r r s &&&r% r (DefaultCompressionTest.verify_wire_bytes sV 1DLL(9A(=#>? !s4<<'81'<"=> rM2r( rJ N) r5 r6 r7 r8 r r r r: r; r< s @r% r r s 3 3r( r c D a ] tR tRt o V 3R lR ltV 3R lR ltRtV tR# )MaskFunctionMixini c , < V ^8 d QhRS[ RS[ RS[ /# )r maskdatar )rC )r r= s "r% r MaskFunctionMixin.__annotate__ s" $ $ $e $ $r( c \ 4 hr r r$ r( r) s &&&r% r( MaskFunctionMixin.mask r r( c 4 < V ^8 d QhRS[ P /# )r r$ )typingAny)r r= s "r% r r* s
r( c V P V P R R4 R4 V P V P R R4 R4 V P V P R R4 R4 V P V P RR4 R4 V P V P R R
4 R 4 V P V P R R
4 R4 R# )s abcdr( b s 54321s TVPVPs ZXCVs 98765432s c`t`olpds s s s s s N)r r( r+ s &r% test_maskMaskFunctionMixin.test_mask s 7C0#6 7D17; 7H5x@ 7K8+F
II)+F G '
II)+F G '
r( rJ N)r5 r6 r7 r8 r( r4 r: r; r< s @r% r& r& s $ $
r( r& c & a ] tR tRt o R tRtV tR# )PythonMaskFunctionTesti c \ W4 # r r r, s &&&r% r( PythonMaskFunctionTest.mask s
%d11r( rJ Nr5 r6 r7 r8 r( r: r; r< s @r% r7 r7 s 2 2r( r7 z#tornado.speedups module not presentc & a ] tR tRt o R tRtV tR# )CythonMaskFunctionTesti# c . \ P ! W4 # r )r websocket_maskr, s &&&r% r( CythonMaskFunctionTest.mask% s &&t22r( rJ Nr: r< s @r% r< r< # s 3 3r( r< c 6 a ] tR tRt o R t]R 4 tRtV tR# )ServerPeriodicPingTesti) c B ! R R\ 4 p\ RV3.R^ R7 # )c & a ] tR tRt o R tRtV tR# )3ServerPeriodicPingTest.get_app..PingHandleri+ c ( V P R 4 R# )got pongNr r$ r) s &&r% on_pong;ServerPeriodicPingTest.get_app..PingHandler.on_pong, "":.r( rJ N)r5 r6 r7 r8 rH r: r; r< s @r% PingHandlerrD +
/
/r( rK /r )websocket_ping_intervalwebsocket_ping_timeoutr r r$ rK s & r% r ServerPeriodicPingTest.get_app* s/ /. / ;
$(#$
r( c # " V P R 4 x p\ ^4 F' pVP 4 x pV P VR4 K) R# 5i)rM rF N)r r r( r r s & r% test_server_ping'ServerPeriodicPingTest.test_server_ping5 sC ??3'
'qA __ ..H Xz 2 s A ArJ N) r5 r6 r7 r8 r r rT r: r; r< s @r% rA rA ) s
3 3r( rA c 6 a ] tR tRt o R t]R 4 tRtV tR# )ClientPeriodicPingTesti> c < ! R R\ 4 p\ RV3.4 # )c & a ] tR tRt o R tRtV tR# )3ClientPeriodicPingTest.get_app..PingHandleri@ c ( V P R 4 R# )got pingNr rG s &&r% on_ping;ClientPeriodicPingTest.get_app..PingHandler.on_pingA rJ r( rJ Nr5 r6 r7 r8 r] r: r; r< s @r% rK rZ @ rL r( rK rM rP rQ s & r% r ClientPeriodicPingTest.get_app? s$ /. / S+ ./00r( c # " V P R R^ R7 x p\ ^4 F' pVP 4 x pV P VR4 K) VP 4 R# 5i)rM r
ping_interval ping_timeoutr\ N)r r r( r r r s & r% test_client_ping'ClientPeriodicPingTest.test_client_pingF sT ??3d?K
KqA __ ..H Xz 2
s A A!rJ N) r5 r6 r7 r8 r r re r: r; r< s @r% rW rW > s 1 r( rW c F a ] tR tRt o R t]R 4 t]R 4 tRt V t
R# )ServerPingTimeoutTestiO c Z a . V n V o ! V3R lR\ 4 p\ RV3.4 pV# )c : <a a ] tR tRt oRV V3R lltRtVtV ;t# )2ServerPingTimeoutTest.get_app..PingHandleriT c | < SP V n V P P V 4 \ SV `
WR 7 # )r! )handlersr r r& )r$ r" r# r r s &&&r% r& =ServerPingTimeoutTest.get_app..PingHandler.initializeU s: $
$$T* w)!- * r( rm r4 )r5 r6 r7 r8 r& r: r; r )r r= r s @@r% rK rk T s
r( rK rM )rm r r )r$ rK appr s & @r% r ServerPingTimeoutTest.get_appP s5 02
. C-./
r( c a RS n ^ S n V 3R lpV! S P P 4 S P n R# )z1Optionally suppress the client's "pong" response.Fc <a R V V3R llpV# )c 0 V ^8 d QhR\ R\ /# )r opcoder) )r rC )r s "r% r IServerPingTimeoutTest.install_hook..wrapper..__annotate__h s
)
)s
)%
)r( c | < V ^
8X d. S;P ^,
un SP ' d R# S! W4 # )
N)pongs_received
drop_pongs)ru r) fcnr s &&r% _innerCServerPingTimeoutTest.install_hook..wrapper.._innerh s2 S=%%*%}}} 6((r( rJ )r{ r| r s f r% wrapper3ServerPingTimeoutTest.install_hook..wrapperg s
)
) Mr( N)rz ry r _handle_message)r r~ s f r% install_hook"ServerPingTimeoutTest.install_hook` s6
'.bkk.I.I&J #r( c # " R pV P RW^, R7 x pV P V4 V P ^ , p\ ^4 Fk p\ P
! V4 x V P
VP 4 V P
VP 4 VP P f Kk Q h V P VP ^4 RVn \ P
! VR, 4 x V P VP R4 V P VP R4 V P VP P R4 R# 5i)g?rM rb NTg ?i zping timed out)r r rm r r r rM r0 r1 r assertGreaterEqualry rz r )r$ intervalr handler_s & r% test_client_ping_timeout.ServerPingTimeoutTest.test_client_ping_timeoutu s- ?? xl #
" --"qA))H% %
g 0 0 1 g 2 2 3 ;;))1 11
1 115
ii3''
++T2 --/?@
//6s
B4E!;B&E!ro N) r5 r6 r7 r8 r staticmethodr r r r: r; r< s @r% rh rh O s4 K K( %7 %7r( rh c & a ] tR tRt o R tRtV tR# )PingCalculationTesti c
n ^ RI Hp \ P ! R^^^ ^ ^ \ P P R7 p^
p\ P ! R^^^ ^;^6\ P P R7 pVP VP
4 VVP
4 R7 pV P V^4 R# )r )WebSocketProtocol13i )tzinfo)last_ping_timer nowN)tornado.websocketr datetimetimezoneutcping_sleep_time timestampr )r$ r r r r
sleep_times & r% test_ping_sleep_time(PingCalculationTest.test_ping_sleep_time s 9 aB1X=N=N=R=RS!** !QB8+<+<+@+@
)88)335
9
Q'r( rJ N)r5 r6 r7 r8 r r: r; r< s @r% r r s
(
(r( r c 6 a ] tR tRt o R t]R 4 tRtV tR# )ManualPingTesti c < ! R R\ 4 p\ RV3.4 # )c & a ] tR tRt o R tRtV tR# )+ManualPingTest.get_app..PingHandleri c H V P V\ V\ 4 R 7 R# )r: N)rA rB rC rG s &&r% r] 3ManualPingTest.get_app..PingHandler.on_ping s ""4
40G"Hr( rJ Nr_ r< s @r% rK r s
I
Ir( rK rM rP rQ s & r% r ManualPingTest.get_app s& I. I S+ ./00r( c # J " V P R 4 x pV P \ VP R4 VP R4 VP 4 x pV P VR4 VP R4 VP 4 x pV P VR4 R# 5i)rM r s hellos binary helloN~aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r rD
ValueErrorpingr( r )r$ r resps & r% test_manual_ping ManualPingTest.test_manual_ping s ??3'
' *bggy9
__&& x(
__&& /s B!B#rJ N) r5 r6 r7 r8 r r r r: r; r< s @r% r r s 1 0 0r( r c 6 a ] tR tRt o R t]R 4 tRtV tR# )MaxMessageSizeTesti c * \ R \ 3.RR7 # )rM r )websocket_max_message_size)r r? r+ s &r% r MaxMessageSizeTest.get_app s S+ ./DQQr( c # " V P R 4 x pRpVP V4 VP 4 x pV P W24 VP VR, 4 VP 4 x pV P VR4 V P VP
R4 V P VP R4 R# 5i)rM bNi zmessage too big aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r rA r( r rr r0 r1 )r$ r rs r s & r% test_large_message%MaxMessageSizeTest.test_large_message s ??3'
'
__&& # s#__&&
dD! - *;r s
% 5 ( $ ; ' D T T 3
3
O+ O(& 2
C( C,&, &.
n
$- $ $. $ *
$ 4 $ P/ P
I- I&!/ !$ -
2 $) $ - &M') M'` $&: $
(#8
( @$0 @$ @$F @ 0 @ @ -
5
5
3 1 3
))
.2 . 2
T!#HI3 . 3 J3
3 2 3* 2 "L7 1 L7^((++ ("0* 00=. =]
" Hs 2
I I5 I25 JJ