add missing files

tzh

2024-08-22 c7d0944258c7d0943aa7b2211498fd612971ce27

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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
ó 
K\¬Qc@sdZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZm    Z    m
Z
mZmZm Z mZmZmZmZmZmZmZmZ
eee eeeefƒ
Zye
Wnek
rë


iZn
Xd„Zdef
d„ƒYZeeefZd„Z d„Z!d    „Z"d
„Z#de$d„Z%de$d „Z&e&Z'de(e$e$d„Z)dfd„ƒYZ*de*f
d„ƒYZ+d„Z,e$e(d„Z-ej.dkrÿ
d
dl/Z/dfd„ƒYZ0de*f
d„ƒYZ1ndS(s Basic infrastructure for asynchronous socket service clients and servers.
 
There are only two ways to have a program on a single processor do "more
than one thing at a time".  Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.
 
If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background."  Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
iÿÿÿÿN(tEALREADYtEINPROGRESStEWOULDBLOCKt
ECONNRESETtEINVALtENOTCONNt    ESHUTDOWNtEINTRtEISCONNtEBADFtECONNABORTEDtEPIPEtEAGAINt    errorcodec

CsKytj
|ƒ
SWn3tttfk
rF


|tkr>t|Sd
|SXdS(NsUnknown error %s(toststrerrort
ValueErrort OverflowErrort    NameErrorR (
terr((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt    _strerrorDs





tExitNowc
BseZ
RS((t__name__t
__module__(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRLs
c

Cs9y|jƒ
Wn$t
k
r$


‚n


|jƒ
n
XdS(
N(thandle_read_eventt_reraised_exceptionsthandle_error(
tobj((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytreadQs


 


c

Cs9y|jƒ
Wn$t
k
r$


‚n


|jƒ
n
XdS(
N(thandle_write_eventRR(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytwriteYs


 


c

Cs9y|jƒ
Wn$t
k
r$


‚n


|jƒ
n
XdS(
N(thandle_expt_eventRR(
R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt
_exceptionas


 


cCsäyz|
tj
@r|jƒ
n|
tj@r7|jƒ
n|
tj@rQ|jƒ
n|
tjtjBtj    B@ry|j
ƒ
nWnctjk
r¼
}
|j d
tkr¯|jƒ
qà|j
ƒ
n$tk
rÏ


‚n


|jƒ
n
XdS(Ni(tselecttPOLLINRtPOLLOUTRtPOLLPRIRtPOLLHUPtPOLLERRtPOLLNVALthandle_closetsocketterrortargst _DISCONNECTEDRR(Rtflagst
e((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt    readwriteis"

 
 
 
 
 
 




  
 


gc
Cs|
dkrt
}
n|
rþ
g}g}g}x„|
jƒD]v\}}|jƒ}|jƒ}|rt|j|ƒ

n|r”|jr”|j|ƒ

n|s |r:|j|ƒ

q:q:Wg|koÖ|koÖ|kn
rìtj|ƒ

dSy%t    j    ||||ƒ\}}}Wn3t    j
k
rF

}    
|    jd
tkr?
‚qG
dSn
Xx9|D]1}|
j |ƒ
}|dkru
qN
nt|ƒ

qN
Wx9|D]1}|
j |ƒ
}|dkr±
qŠ
nt|ƒ

qŠ
Wx<|D]1}|
j |ƒ
}|dkrí
qÆ
nt|ƒ

qÆ
WndS(Ni(tNonet
socket_maptitemstreadabletwritabletappendt    acceptingttimetsleepR!R*R+RtgetRRR (
ttimeouttmapt
rt
wR.tfdRtis_rtis_wR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytpoll}sN

    










'
 

%


 



 



 



cCs}
|
dkrt
}
n|dk    r4t|d
ƒ
}ntjƒ}|
ry
x|
jƒD]\}}d}|jƒrˆ|tjtjBO}n|j    ƒr®|j
r®|tjO}n|rS|tjtj BtjBO}|j||ƒ
qSqSWy|j|ƒ
}Wn5tjk
r0

}
|jdtkr'
‚ng}n
XxE|D]:\}}|
j|ƒ
}|dkre
q8
nt||ƒ
q8
WndS(Nièi(R0R1tintR!RAR2R3R"R$R4R6R#R&R%R'tregisterR*R+RR9R/(R:R;tpollsterR>RR-R<R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytpoll2ªs4
    





















g>@cCs–|dkrt
}n|
r3ttd
ƒr3t}nt}|dkrbxJ|r^|||ƒ
qHWn0x-|r‘|dkr‘|||ƒ
|d}qeWdS(NRAii
(R0R1thasattrR!RERA(R:tuse_pollR;tcounttpoll_fun((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytloopÍs

    
    
    

 
t
dispatchercBsa
eZ
eZeZeZeZeZd Z    e
dg
ƒ
Zd d d
„Zd„Z e Zd d„
Zd d„
Zd„Zd d„
Zd„Zd„Zd    „Zd
„Zd„Zd„Zd „Zd„Zd„Zd„Zd„Zd„Zdd„
Zd„Z d„Z!d„Z"d„Z#d„Z$d„Z%d„Z&d„Z'd„Z(d„Z)d„Z*RS(!twarningcCsÇ|dkrt
|_n    ||_d|_|
rº|
jd
ƒ

|j|
|ƒ
t|_y|
jƒ|_    WqÃt
jk
r¶
}
|jd
t tfkr£t|_q·|j|ƒ

‚qÃXn    d|_
dS(Ni(R0R1t_mapt_filenotsetblockingt
set_sockettTruet    connectedtgetpeernametaddrR)R*R+RRtFalsetdel_channel(tselftsockR;R((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt__init__és 

         

    


 

c
CsÉ|jj
d
|jjg
}
|jr?|jr?|
jdƒ

n|jrX|
jdƒ

n|jdk    r¬y|
jd|jƒ

Wq¬tk
r¨


|
jt    |jƒ
ƒ

q¬Xnddj
|
ƒ
t|ƒ
fS(Nt
.t    listeningRRs%s:%ds<%s at %#x>t
 (t    __class__RRR6RTR5RRR0t    TypeErrortreprtjointid(RWtstatus((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt__repr__    
s



    




 

cCs)|
dkr|j
}
n||
|j<dS(
N(R0RMRN(RWR;((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytadd_channel
s

cCsD|j}|
dkr!|j}
n||
kr7|
|=nd|_dS(
N(RNR0RM(RWR;R>((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRV
s
    




cCs?|
|f|_t
j
|
|ƒ}|jd
ƒ

|j|ƒ

dS(Ni(tfamily_and_typeR)RORP(RWtfamilyttypeRX((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt create_socket'
s


 
cCs)|
|_|
j
ƒ|_|j|ƒ

dS(
N(R)tfilenoRNRd(RWRXR;((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRP-
s
    
c

CsTy9|jj
tjtj|jjtjtjƒd
Bƒ
Wntjk
rO


n
XdS(Ni
(R)t
setsockoptt
SOL_SOCKETtSO_REUSEADDRt
getsockoptR*(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytset_reuse_addr3
s
    



c


CstS(
N(
RQ(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR3D
s
c


CstS(
N(
RQ(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR4G
s
cCs=t|_
tjd
kr-|
dkr-d}
n|jj|
ƒ
S(Ntnti(RQR6RtnameR)tlisten(RWtnum((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRqN
s
    

    
cCs|
|_|j
j|
ƒ
S(
N(RTR)tbind(RWRT((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRsT
s
    
cCs£t|_
t|_|jj|
ƒ
}|tttfksT|t    krat
jdkra|
|_dS|dt fkr‰|
|_|jƒ
ntj|t|ƒ‚
dS(NRotcei(sntRt(RURRRQt
connectingR)t
connect_exR
RRRRRpRTRthandle_connect_eventR*R (RWtaddressR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytconnectX
s
    
    



    


    
 c
Csty|jj
ƒ\}
}WnJtk
r-


dStjk
re
}
|jd
tttfkr_dS‚nX|
|fSdS(Ni(    R)tacceptR^R0R*R+RR
R(RWtconnRTtwhy((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRzf
s

 



cCsry|jj
|
ƒ
}|SWnQtjk
rm
}
|jd
tkrFd
S|jd
tkrg|jƒ
d
S‚n
XdS(Ni(R)tsendR*R+RR,R((RWtdatatresultR|((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR}t
s









cCsoy.|jj
|
ƒ
}|s)|jƒ
d
S|SWn:tjk
rj
}
|jdtkrd|jƒ
d
S‚n
XdS(Nti(R)trecvR(R*R+R,(RWtbuffer_sizeR~R|((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR
s



 

c
Csrt|_
t|_t|_|jƒ
y|jjƒ
Wn5tjk
rm
}

|
jd
t    t
fkrn‚qnn
XdS(Ni(RURRR6RuRVR)tcloseR*R+RR    (RWR|((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRƒ“
s
    
    
    






cCs‚yt|j
|
ƒ}Wn-tk
rE


td
|jj|
fƒ
‚
n9Xdi|jjd6|
d6}tj|tddƒ

|SdS(Ns!%s instance has no attribute '%s'sB%(me)s.%(attr)s is deprecated. Use %(me)s.socket.%(attr)s instead.tmetattrt
stackleveli(tgetattrR)tAttributeErrorR]RtwarningstwarntDeprecationWarning(RWR…tretattrtmsg((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt__getattr__ 
s


 




cCstj
jd
t|
ƒ
ƒ

dS(Nslog: %s
(tsyststderrRtstr(RWtmessage((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytlog°
s
tinfocCs%||jkr!d
||
fGHndS(Ns%s: %s(
tignore_log_types(RWR’Rg((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pytlog_info³
s

c


CsP|jr|j
ƒ
n6|jsB|jr5|jƒ
n|jƒ
n
|jƒ
dS(
N(R6t handle_acceptRRRuRwthandle_read(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR·
s
     
    
    
 
 c
Csb|jj
tjtjƒ}
|
d
krBtj|
t|
ƒ
ƒ‚
n|jƒ
t|_t    |_
dS(Ni(R)RmRktSO_ERRORR*Rthandle_connectRQRRRURu(RWR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRwÃ
s





    
c


Cs=|jr dS|j
s/|jr/|jƒ
q/n|jƒ
dS(
N(R6RRRuRwthandle_write(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRË
s
        
    

c
CsB|jj
tjtjƒ}
|
d
kr4|jƒ
n
|jƒ
dS(Ni(R)RmRkR™R(thandle_expt(RWR((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRÖ
s
 c
Csmtƒ\}
}}}yt
|ƒ
}Wn


d
t|ƒ
}n
X|jd||||fdƒ
|jƒ
dS(Ns)<__repr__(self) failed for object at %0x>s:uncaptured python exception, closing channel %s (%s:%s %s)R*(tcompact_tracebackR_RaR–R((RWtnilt
tt
vttbinfot    self_repr((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRå
s








c

Cs|jd
dƒ
dS(Ns!unhandled incoming priority eventRL(
R–(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRϝ
s
c

Cs|jd
dƒ
dS(Nsunhandled read eventRL(
R–(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR˜ü
s
c

Cs|jd
dƒ
dS(Nsunhandled write eventRL(
R–(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR›ÿ
s
c

Cs|jd
dƒ
dS(Nsunhandled connect eventRL(
R–(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRšs
c

Cs|jd
dƒ
dS(Nsunhandled accept eventRL(
R–(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR—s
c

Cs|jd
dƒ
|j
ƒ
dS(Nsunhandled close eventRL(R–Rƒ(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR(s

N(+RRRUtdebugRRR6RutclosingR0RTt    frozensetR•RYRct__str__RdRVRhRPRnR3R4RqRsRyRzR}RRƒRŽR“R–RRwRRRRœR˜R›RšR—R((((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRKßsL





                                                                                                        tdispatcher_with_sendcBs;eZ
ddd„Zd
„Zd„Zd„Zd„ZRS(cCs tj
||
|ƒ
d
|_dS(NR€(RKRYt
out_buffer(RWRXR;((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRYs

c
Cs3d
}
tj
||jd ƒ}
|j|
|_dS(Nii(RKR}R¨(RWtnum_sent((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt initiate_sends


c


Cs|jƒ
dS(
N(
Rª(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR›s
c

Cs|jpt
|jƒ
S(
N(RRtlenR¨(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR4s
cCsA|jr#|j
d
t|
ƒ
ƒ

n|j|
|_|jƒ
dS(Ns
sending %s(R£R–R_R¨Rª(RWR~((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR}"s
    


N(RRR0RYRªR›R4R}(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR§s
            c    CsÌtj
ƒ\}}
}g}|s0td
ƒ
‚
nxD|rv|j|jjj|jjjt|j    ƒ
fƒ

|j
}q3W~|d\}}}djg|D]}d|^qšƒ
}|||f||
|fS(Nstraceback does not existiÿÿÿÿR\s
[%s|%s|%s](Rtexc_infotAssertionErrorR5ttb_frametf_codetco_filenametco_nameR‘t    tb_linenottb_nextR`(    RŸR ttbR¡tfiletfunctiontlinet
xR”((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR,s




    



 
&
cCs¥|dkrt
}nx|jƒD]q}y|jƒ
Wq"tk
rm
}
|jd
tkr^q“|
s“‚q“q"tk
r€


‚q"


|
s“‚q“q"Xq"W|jƒ
dS(Ni(    R0R1tvaluesRƒtOSErrorR+R    Rtclear(R;t
ignore_allR¸((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt    close_all@s 

    







    
 




tposixtfile_wrappercBsMeZ
d„Zd
„Zd„Zdd„
ZeZeZd„Z    d„Z
RS(cCstj
|
ƒ
|_dS(
N(RtdupR>(RWR>((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRYgs
c
Gstj
|j|
Œ
S(
N(RRR>(RWR+((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRjs
c
Gstj
|j|
Œ
S(
N(RRR>(RWR+((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR}ms
cCs9|
tj
kr)|tjkr)|r)d
Stdƒ
‚
dS(Nis-Only asyncore specific behaviour implemented.(R)RkR™tNotImplementedError(RWtleveltoptnametbuflen((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRmps





c

Cstj
|jƒ

dS(
N(RRƒR>(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRƒ{s
c


Cs|jS(
N(
R>(
RW((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRi~s
N(RRRYRR}R0RmRRRƒRi(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyR¿bs            
    tfile_dispatchercBseZ
dd„
Zd
„ZRS(cCsŒtj
|d|ƒ
t|_y|
jƒ}
Wntk
r?


n
X|j|
ƒ

tj|
tj    d
ƒ}|t
jB}tj|
tj|ƒ
dS(Ni( RKRYR0RQRRRiRˆtset_filetfcntltF_GETFLRt
O_NONBLOCKtF_SETFL(RWR>R;R-((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRYƒs

    


 

 
 
cCs/t|
ƒ
|_
|j
jƒ|_|jƒ
dS(
N(R¿R)RiRNRd(RWR>((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRƐs


N(RRR0RYRÆ(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyRŁs (2t__doc__R!R)RR7R‰RterrnoRR
RRRRRRRR    R
RRR R¥R,R1RRt    ExceptionRtKeyboardInterruptt
SystemExitRRRR R/R0RAREtpoll3RURJRKR§RR½RpRÇR¿RÅ(((sP/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/asyncore.pyt<module>/sB




^


 

                    -!ÿ3