init repo

ronnie

2022-10-14 1504bb53e29d3d46222c0b3ea994fc494b48e153

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
ó 
K\¬Qc@s dZd
dl
Z
d
dlZd
dlmZ
d
dlmZ
d
dlmZm    Z    
dej
f
d„ƒYZdd d    „ƒYZd
dd„ƒYZ d„ZdS(s¥A class supporting chat-style (command/response) protocols.
 
This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).
 
The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.
 
for example:
Say you build an async nntp client using this class.  At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting.  Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'.  The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
iÿÿÿÿN(
tdeque(
tpy3kwarning(tfilterwarningstcatch_warningst
async_chatcBs¹eZ
dZd
Zd
Zddd„Zd„Zd„Zd„Z    d„Z
d„Zd„Zd    „Z d
„Zd„Zd„Zd „Zd„Zd„Zd„Zd„Zd„ZRS(s‡This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()icCs8d
|_g|_
tƒ|_tjj||
|ƒ
dS(Nt(tac_in_buffertincomingRt producer_fifotasyncoret
dispatchert__init__(tselftsocktmap((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR@s        
cCstd
ƒ
‚
dS(Nsmust be implemented in subclass(
tNotImplementedError(Rtdata((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytcollect_incoming_dataQs
cCs|jj
|
ƒ

dS(
N(Rtappend(RR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyt_collect_incoming_dataTs
c
Csd
j|j
ƒ
}
|j
2|
S(NR(tjoinR(Rt
d((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyt    _get_dataWs


c

Cstd
ƒ
‚
dS(Nsmust be implemented in subclass(
R(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytfound_terminator\s
cCs |
|_d
S(sRSet the input delimiter.  Can be a fixed string of any length, an integer, or NoneN(
t
terminator(Rtterm((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytset_terminator_sc


Cs|jS(
N(
R(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytget_terminatorcs
c
Cs    y|j|j
ƒ
}
Wn!tjk
r9
}
|jƒ
dSX|j|
|_x¸
|jrt|jƒ
}|jƒ}|s“|j|jƒ

d
|_qMt    |t
ƒs±t    |tƒr)
|}||krï|j|jƒ

d
|_|j||_q
|j|j| ƒ

|j||_d|_|j ƒ
qMt|ƒ
}|jj|ƒ
}|dkr—
|dkrv
|j|j| ƒ

n|j|||_|j ƒ
qMt|j|ƒ}|rè
||krä
|j|j| ƒ

|j||_nPqM|j|jƒ

d
|_qMWdS(NRiiÿÿÿÿ(trecvtac_in_buffer_sizetsocketterrorthandle_errorRtlenRRt
isinstancetinttlongRRtfindtfind_prefix_at_end(RRtwhytlbRt
ntterminator_lentindex((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pythandle_readksJ












    


    
     


 




c


Cs|jƒ
dS(
N(
t initiate_send(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pythandle_write­s
c


Cs|jƒ
dS(
N(
tclose(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pythandle_close°s
cCsz|j}t
|
ƒ
|kr\xNtd
t
|
ƒ
|ƒD]!}|jj|
|||!ƒ

q4Wn|jj|
ƒ

|jƒ
dS(Ni(tac_out_buffer_sizeR!txrangeRRR-(RRtsabst
i((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytpush³s
    


"
cCs|jj
|
ƒ

|jƒ
dS(
N(RRR-(Rtproducer((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytpush_with_producer¼s

c


Csd
S(s4predicate for inclusion in the readable for select()i
((
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytreadableÀsc

Cs|jp|j
S(
s4predicate for inclusion in the writable for select()(Rt    connected(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytwritableÈsc

Cs|jj
d
ƒ

d
S(sAautomatically close this channel once the outgoing queue is emptyN(RRtNone(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytclose_when_doneÌsc
    Csf
x_
|jra
|j
ra
|jd
}
|
sO|jd
=|
dkrO|jƒ
dSn|j}y?tƒ0
tr~tddtƒ
nt    |
d
|ƒ}WdQXWnCt
k
rÜ


|
jƒ}|rÌ|jj|ƒ

q|jd
=qn
Xy|j |ƒ
}Wntjk
r



|jƒ
dSX|r]
|t|ƒ
ks<
|t|
ƒ
krP
|
||jd
<q]
|jd
=ndSWdS(Nitignores.*buffer(RR9R;R0R1RR
RtDeprecationWarningtbuffert    TypeErrortmoret
appendlefttsendRRR R!(RtfirsttobsRtnum_sent((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR-Ðs:

 

 

    


 
 


$
 c

Cs!d
|_|j
2|jjƒ
dS(NR(RRRtclear(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytdiscard_buffersøs    

N(t__name__t
__module__t__doc__RR1R;RRRRRRRR,R.R0R5R7R8R:R<R-RH(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR7s(
                            B                                    (tsimple_producercBseZ
dd
„
Zd„ZRS(icCs|
|_||_
dS(
N(Rtbuffer_size(RRRM((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR
s
    
c
CsYt|j
ƒ
|jkr?|j
|j }
|j
|j|_
|
S|j
}
d
|_
|
SdS(NR(R!RRM(Rtresult((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyRA
s



    
    
(RIRJRRA(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyRLþstfifocBsAeZ
dd„
Zd
„Zd„Zd„Zd„Zd„ZRS(cCs(|
stƒ|_
nt|
ƒ
|_
dS(
N(Rtlist(RRP((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR
s

c

Cs t|j
ƒ
S(
N(R!RP(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyt__len__
s
c


Cs|jS(
N(
RP(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytis_empty
s
c

Cs|jd
S(Ni(
RP(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyRD
s
cCs|jj
|
ƒ

dS(
N(RPR(RR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR5
s
c

Cs$|jrd
|jj
ƒfSdSdS(Ni
i(iN(RPtpopleftR;(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pytpop!
s
    
N(    RIRJR;RRQRRRDR5RT(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyRO
s
                cCs?t|
ƒ
d
}x(|r:|j
|
| ƒ
r:|d
8}qW|S(Ni
(R!tendswith(thaystacktneedlet
l((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyR&6
s



(((RKRR    tcollectionsRtsysR
twarningsRRR
RRLROR&(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asynchat.pyt<module>/s



Ç(