Ë
|
¸^i- ã óæ U d Z ddlZddlZddlZddlmZ ddlmZmZm Z m
|
Z
|
ddl m Z ddl mZ ddlmZmZ d d
|
lmZmZmZmZmZmZmZmZ d d lm Z m Z d Z ee e d < dZ!ee e d< dZ" G d d« Z#y)z%WebSocket protocol versions 13 and 8.é N)Úpartial)ÚFinalÚOptionalÚSetÚUnioné )Ú BaseProtocol)ÚClientConnectionResetError)Ú ZLibBackendÚZLibCompressoré )ÚMASK_LENÚMSG_SIZEÚPACK_CLOSE_CODEÚ PACK_LEN1Ú PACK_LEN2Ú PACK_LEN3Ú PACK_RANDBITSÚwebsocket_mask)ÚWS_DEFLATE_TRAILINGÚ WSMsgTypeé Ú DEFAULT_LIMITé ÚWS_CONTROL_FRAME_OPCODEi @ c ó8 e Zd ZdZde ej « ddddedej de
|
de d ej d
|
e d e
|
d d fdZ dde de d
|
ee d d fdZde de de d d fdZd
|
ee d efdZde de d
|
ee d d fdZde de d
|
ee d d fdZdde dee ef d d fdZy )ÚWebSocketWritera3 WebSocket writer.
|
|
The writer is responsible for sending messages to the client. It is
|
created by the protocol when a connection is established. The writer
|
should avoid implementing any application logic and should only be
|
concerned with the low-level details of the WebSocket protocol.
|
Fr )Úuse_maskÚlimitÚrandomÚcompressÚ
|
notakeoverÚprotocolÚ transportr r r r! r" ÚreturnNc ó || _ || _ || _ t |j d« | _ || _ || _ d| _ || _ d| _
|
d| _ t j « | _ t « | _ y)z Initialize a WebSocket writer.é Fr N)r# r$ r r Ú getrandbitsÚget_random_bitsr! r" Ú_closingÚ_limitÚ _output_sizeÚ _compressobjÚasyncioÚLockÚ
|
_send_lockÚsetÚ_background_tasks)Úselfr# r$ r r r r! r" s õl H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/_websocket/writer.pyÚ__init__zWebSocketWriter.__init__1 sq ð ! Ø"Ø Ü & v×'9Ñ'9¸2Ó >Ô Ø Ø$Ø Ø Ø ÔØ6:ÔÜ!,,.Ü:=»%Õ ó ÚmessageÚopcodec ó K | j r |t j z s t d« |s | j r |t
|
k\ r| j ||d« n t |« t k r9| j 4 d{ | j |||« ddd« d{ nÁt j « }| j |||« }t j dk\ rt j ||d¬« }n|j# |« }| j$ j' |« |j) | j$ j* « t j, |« d{ | j. | j0 kD rAd| _ | j2 j4 r#| j2 j7 « d{ yyy7 E7 %# 1 d{ 7 sw Y sxY w7 z7 $w)z<Send a frame over the websocket with message as its payload.ú!Cannot write to closing transportr N)é é T)ÚloopÚ eager_start) r* r ÚCLOSEr
|
r! r Ú_write_websocket_frameÚlenÚ WEBSOCKET_MAX_SYNC_CHUNK_SIZEr0 Ú_send_compressed_frame_syncr. Úget_running_loopÚ#_send_compressed_frame_async_lockedÚsysÚ version_infoÚTaskÚ create_taskr2 ÚaddÚadd_done_callbackÚdiscardÚshieldr, r+ r# Ú_pausedÚ _drain_helper)r3 r7 r8 r! r= ÚcoroÚ send_tasks r4 Ú
|
send_framezWebSocketWriter.send_frameJ s è ø ð == &¬9¯?©?Ò":Ü,Ð-PÓQÐ QáDMM¨fÔ8OÒ.Oà × 'Ñ '¨°¸Ö ;Ü \Ô :Ò :ð
|
÷ Lñ LØ×0Ñ0°¸&À(ÔK÷ L÷ Lð Lô ×+Ñ+Ó-DØ×;Ñ;¸GÀVÈXÓVDÜ× Ñ 7Ò*Ü #LL¨°DÀdÔ K à × ,Ñ ,¨TÓ 2 à × "Ñ "× &Ñ & yÔ 1Ø × 'Ñ '¨×(>Ñ(>×(FÑ(FÔ GÜ.. Ó+× +Ð +ð × Ñ t{{Ò *Ø !DÔ Ø}}×$Ò$Ømm×1Ñ1Ó3×3Ñ3ð %ð +ð= Lùð Lù÷ L÷ Lñ Lúð* ,øð 4úsh A9G Á;G Á<G Á?G G  G CG Å GÅ!AG Æ8G Æ9G ÇG ÇGÇ G Ç GÇG Ç G Úrsvc óà t |« }| j }|rdnd}d|z |z }|dk rt |||z « }d} n*|dk rt |d|z |« }d} nt |d|z |« }d} | j
|
j « r t d « |rkt | j « « }
|
t |« }t |
|
|« | j
|
j ||
|
z |z « | xj t z c_ n^|t kD r7| j
|
j |« | j
|
j |« n | j
|
j ||z « | xj | |z z c_ y
|
) a
|
Write a websocket frame to the transport.
|
|
This method handles frame header construction, masking, and writing to transport.
|
It does not handle compression or flow control - those are the responsibility
|
of the caller.
|
é r é~ r r é é é
|
r: N)rA r r r r r$ Ú
|
is_closingr
|
r r) Ú bytearrayr Úwriter, r r ) r3 r7 r8 rS Ú
|
msg_lengthr Úmask_bitÚ
|
first_byteÚheaderÚ
|
header_lenÚmasks r4 r@ z&WebSocketWriter._write_websocket_frame| sP ô \
|
à==Ù#4¨ð CZ &Ñ(
|
Ø Ò Ü z¨:¸Ñ+@ÓAFØJØ %Ò Ü z¨3°©>¸:ÓFFØJä z¨3°©>¸:ÓFFØJà >>× $Ñ $Ô &Ü,Ð-PÓQÐ Qñ Ü ×!5Ñ!5Ó!7Ó8DÜ Ó(GÜ 4 Ô )Ø NN× Ñ ¨$¡ °Ñ!8Ô 9Ø × Ò ¤Ñ )Ö Ø (Ò "Ø NN× Ñ Ô (Ø NN× Ñ Õ )à NN× Ñ ¨'Ñ!1Ô 2à ×ÒZ¨*Ñ 4Ñ4Ör6 c óØ |r!t t j | t ¬« S | j s0t t j | j
|
t ¬« | _ | j S )zBGet or create a compressor object for the given compression level.)ÚlevelÚwbitsÚmax_sync_chunk_size)r r Ú Z_BEST_SPEEDrB r- r! )r3 r! s r4 Ú_get_compressorz WebSocketWriter._get_compressor® s^ á ä!Ü!×.Ñ.Ø iÜ$Aôð ð
|
× Ò Ü .Ü!×.Ñ.Ø}}nÜ$Aô!DÔ ð
|
× Ñ Ð r6 c ó | j |« }| j |j |« |j | j rt
|
j nt
|
j « z j t « |d« y)zñ
|
Synchronous send for small compressed frames.
|
|
This is used for small compressed payloads that compress synchronously in the event loop.
|
Since there are no await points, this is inherently cancellation-safe.
|
é@ N)
|
rh r@ Ú compress_syncÚflushr" r Ú Z_FULL_FLUSHÚ Z_SYNC_FLUSHÚ removesuffixr ©r3 r7 r8 r! Ú compressobjs r4 rC z+WebSocketWriter._send_compressed_frame_sync¿ ss ð ×*Ñ*¨8Ó4 ð ×#Ñ#à×)Ñ)¨'Ó2Ø ×#Ñ#àô ×,Ò,ä$×1Ñ1óñ÷ lÔ.Ó/Ø Ø õ
|
r6 c ó K | j 4 d{ | j |« }| j |j |« d{ |j | j
|
rt j nt j « z j t « |d« ddd« d{ y7 7 l7 # 1 d{ 7 sw Y yxY ww)aç
|
Async send for large compressed frames with lock.
|
|
Acquires the lock and compresses large payloads asynchronously in
|
the executor. The lock is held for the entire operation to ensure
|
the compressor state is not corrupted by concurrent sends.
|
|
MUST be run shielded from cancellation. If cancelled after
|
compression but before sending, the compressor state would be
|
advanced but data not sent, corrupting subsequent frames.
|
Nrj ) r0 rh r@ r! rl r" r rm rn ro r rp s r4 rE z3WebSocketWriter._send_compressed_frame_async_lockedÛ s¸ è ø ð ??÷ ñ ð ×.Ñ.¨xÓ8Kð × 'Ñ 'à%×.Ñ.¨wÓ7×7Ø!×'Ñ'à ??ô $×0Ò0ä (× 5Ñ 5óñ÷ ,Ô 2Ó3ØØô ÷ ÷ ñ øð 8øð ø÷ ÷ ñ üsW CB3C1B9ÁB5
|
Á AB9Â" CÂ-B7Â.CÂ5B9Â7CÂ9C Â?C Ã C ÃCÚcodec óä K t |t « r|j d« } | j t |« |z t
|
j ¬« d{ d| _ y7 # d| _ w xY ww)z<Close the websocket, sending the specified code and message.zutf-8)r8 NT)Ú
|
isinstanceÚstrÚencoderR r r r? r* )r3 rs r7 s r4 ÚclosezWebSocketWriter.closeý si è ø ä gsÔ #Ø nn WÓ-Gð !Ø//Ü Ó%¨Ñ/¼ ¿¹ð "ó ÷ ð ð !DMð ùð !DMüs. "A0¥0A$ ÁA"ÁA$ ÁA0Á"A$ Á$ A-Á-A0)N)iè r6 )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r ÚRandomr r. Ú TransportÚboolÚintr5 Úbytesr rR r@ r rh rC rE r rv rx © r6 r4 r r ( sg ñð Ø"Ø - § ¡ £ØØ ò@à ð@ð ×$Ñ$ð@ð
|
ð @ð ð @ð ð@ð ð@ð ð@ð
|
ó@ð4 FJñ04Ø ð04Ø&)ð04Ø5=¸c±]ð04à ó04ðd05¨eð 05¸Sð 05Àsð 05Ètó 05ðd!¨°© ð !¸.ó !ð"
|
Ø ð
|
Ø&)ð
|
Ø5=¸c±]ð
|
à ó
|
ð8 Ø ð Ø&)ð Ø5=¸c±]ð à ó ñD ! ð !°U¸5À#¸:Ñ5Fð !ÐQUô !r6 r )$r| r. r rF Ú functoolsr Útypingr r r r Ú base_protocolr Úclient_exceptionsr
|
Úcompression_utilsr r Úhelpersr r r r r r r r Úmodelsr r r r Ú__annotations__r rB r r r6 r4 ú<module>r sj ðÚ +ã Û Û
|
Ý ß .Ó .å (Ý :ß ;÷ ÷ ó ÷ 3à ! uSzÓ !ð '(Ð sÓ 'ð !*Ð ÷^!ò ^!r6
|
