python (3.12.0)
ϑeR- b d dl mZ d dlmZ G d dej Z G d d Zd Zy) )deque)asyncorec e Zd Z dZdZdZdZddZd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zy)
async_chati r zlatin-1Nc d| _ g | _ t | _ t j
j
| || y N ) ac_in_bufferincomingr
producer_fifor
dispatcher__init__)selfsockmaps I/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/support/asynchat.pyr zasync_chat.__init__J s7
#W$$T45r c t d Nz must be implemented in subclassNotImplementedErrorr datas r collect_incoming_dataz async_chat.collect_incoming_dataX !"CDDr c : | j j | y N)r appendr s r _collect_incoming_dataz!async_chat._collect_incoming_data[ s
T"r c Z dj | j }| j d d = |S r )joinr )r ds r _get_datazasync_chat._get_data^ s% HHT]] # MM! r c t d r r r s r found_terminatorzasync_chat.found_terminatorc r r c t |t r*| j r t || j }|| _ y t |t
r|dk r t
d || _ y )Nr z-the number of received bytes must be positive)
isinstancestr use_encodingbytesencodingint
ValueError
terminator)r terms r set_terminatorzasync_chat.set_terminatorf sY dC T%6%6t}}-D c
"tax LM M r c | j S r )r. r$ s r get_terminatorzasync_chat.get_terminatorq s r c | j | j }t |t r&| j rt t | j }| j |z | _
| j rt | j }| j }|s$| j | j d| _
nt |t r|}||k r8| j | j d| _
| j |z
| _ n4| j | j d | | j |d | _
d| _ | j! nt | }| j j# | }|dk7 rK|dkD r | j | j d | | j ||z d | _
| j! ntt% | j | }|r:||k7 r4| j | j d | | j | d | _
y | j | j d| _
| j ry y # t $ r Y y t $ r | j Y y w xY w)Nr r )recvac_in_buffer_sizeBlockingIOErrorOSError handle_errorr' r( r) r* r+ r
lenr2 r r, r. r% findfind_prefix_at_end)r r lbr. nterminator_lenindexs r handle_readzasync_chat.handle_ready s> 99T 3 34D dC T%6%6dmm,D - - 4 T&&'B ,,.J **4+<+<=$'!J, 6..t/@/@A(+D%&*oo&:DO..t/@/@!/DE(,(9(9!"(=D%&'DO))+ "%Z ))..z:B; qy 2243D3DVe3LM(,(9(9%:N:O(PD% ))+ /t/@/@* ME B; 6 6t7H7H5&7Q R040A0A5&'0JD - 2243D3DE,/)g s I I8 I87I8c $ | j y r )
initiate_sendr$ s r handle_writezasync_chat.handle_write s r c $ | j y r )closer$ s r handle_closezasync_chat.handle_close s
r c h t |t t t f st dt | | j }t | |kD r=t dt | | D ]# }| j j ||||z % n| j j | | j y )Nz#data argument must be byte-ish (%r)r ) r' r* bytearray
memoryview TypeErrortypeac_out_buffer_sizer: ranger r rC )r r sabsis r pushzasync_chat.push s $ : >? A J(
(&& t9t 1c$i.
:""))$q4.9
:
% %d + r c Z | j j | | j y r )r r rC )r producers r push_with_producerz async_chat.push_with_producer s" !!(+ r c yN r$ s r readablezasync_chat.readable s
>
r c : | j xs
| j S r )r connectedr$ s r writablezasync_chat.writable s >!!9$..&89r c < | j j d y r )r r r$ s r close_when_donezasync_chat.close_when_done s K !!$'r c | j r| j r| j d }|s | j d= || j y | j } |d | }t |t r"| j rt || j } | j | }|r<|t | k s|t | k r||d | j d< y | j d= y y y # t $ r? |j }|r | j j
| n
| j d= Y 'w xY w# t $ r | j Y y w xY w)Nr )r r[ rG rM rK more
appendleftr' r( r) r* r+ sendr8 r9 r: )r firstobsr num_sents r rC zasync_chat.initiate_send sP T^^&&q)E&&q)=%%' ))C
Tc{ $$):): T4==1
99T?
c$i'3U+;,1(),<D&&q)
**1- K &4
zz|&&11$7 **1-
!!#
s% C! D, !AD)(D),EEc d d| _ | j d d = | j j y r )r
r r clearr$ s r discard_bufferszasync_chat.discard_buffers s( MM! "r )NN)__name__
__module__ __qualname__r6 rM r) r+ r r r r" r% r0 r2 rA rD rG rQ rT rY r\ r^ rC rh rX r r r r ; s| F
LH 6 E#
E F0P
:(&P#r r c e Zd ZddZd Zy)simple_producerc || _ || _ y r )r buffer_size)r r ro s r r zsimple_producer.__init__ s &r c t | j | j kD r9| j d | j }| j | j d | _ |S | j }d| _ |S r )r: r ro )r results r r` zsimple_producer.more sb tyy>D , , ,YY 0 0 01F $"2"2"34DIMYYFDIMr N)i )ri rj rk r r` rX r r rm rm s 'r rm c t | dz
}|r0| j |d | s |dz }|r| j |d | s |S rV )r: endswith)haystackneedlels r r< r< 6 sK F aA
H%%fRaj1 Q H%%fRaj1 Hr N) collectionsr test.supportr r
r rm r< rX r r <module>ry s8 B* !X#$$ X#v @
r 
Browse
Usage
Versions