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
ó 
]\¬Qc@s8
dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlm    Z    m
Z

ddlZddlm Z 
ddlmZmZmZmZ
ddlmZmZmZmZ
dd    lmZ
def
d
„ƒYZeƒZdef
d„ƒYZd
ef
d„ƒYZdS( tQueuetSimpleQueuet JoinableQueueiÿÿÿÿN(tEmptytFull(
tPipe(tLocktBoundedSemaphoret    Semaphoret    Condition(tdebugtinfotFinalizetregister_after_fork(
tassert_spawningcBsËeZ
dd
„
Zd„Zd„Zd„Zedd„Zedd„Z    d„Z
d„Zd    „Zd
„Z d„Zd„Zd „Zd„Zd„Zed„ƒ
Zed„ƒ
Zed„ƒ
ZRS(icCsÀ|
d
k
rtj
j}
n|
|_tdtƒ
\|_|_tƒ|_    t
jƒ|_t jdkrud|_ntƒ|_t|
ƒ
|_|jƒ
t jdkr¼t|tjƒ
ndS(Nitduplextwin32(t_multiprocessingtSemLockt SEM_VALUE_MAXt_maxsizeRtFalset_readert_writerRt_rlocktostgetpidt_opidtsystplatformtNonet_wlockRt_semt_after_forkR R(tselftmaxsize((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt__init__:s


    







c

Cs8t|ƒ

|j
|j|j|j|j|j|jfS(
N(RRRRRRR R(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt__getstate__Ls



cCs>|
\|_|_
|_|_|_|_|_|jƒ
dS(
N(RRRRRR RR!(R"tstate((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt__setstate__Qs0
c

Cstd
ƒ

t
jt
jƒƒ
|_tjƒ|_d|_    d|_
t|_t|_ d|_|jj|_|jj|_|jj|_dS(NsQueue._after_fork()(R
t    threadingR    Rt    _notemptytcollectionstdequet_bufferRt_threadt_jointhreadRt_joincancelledt_closedt_closeRtsendt_sendRtrecvt_recvtpollt_poll(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR!Vs




    
    
    
    
    


cCs|jst
‚
|jj||ƒs.t‚
n|jjƒ
z=|jdkrZ|jƒ
n|j    j
|
ƒ

|jjƒ
Wd|jjƒ
XdS(
N( R0tAssertionErrorR tacquireRR)R-Rt _start_threadR,tappendtnotifytrelease(R"tobjtblockttimeout((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytputcs


     


 

cCs
|
rT|dkrT|j
jƒ
z!|jƒ}|jjƒ
|SWd|j
jƒ
Xn¼|
rmtjƒ|}n|j
j|
|ƒs‹t‚
nzt|
rÌ|tjƒ}|d
ksÀ|j|ƒ
rát‚
qán|jƒsát‚
n|jƒ}|jjƒ
|SWd|j
jƒ
XdS(Ni(    RRR9R5R R=ttimeRR7(R"R?R@trestdeadline((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytgetqs,

 


 



    






    

 
c

Cs|j|j
jjƒS(
N(RR t_semlockt
_get_value(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytqsizesc


Cs|jƒS(
N(
R7(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytempty‘s
c


Cs|jj
jƒS(
N(R RFt_is_zero(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytfull”s
c

Cs |jt
ƒ
S(
N(RER(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt
get_nowait—s
cCs|j|
t
ƒS(
N(RAR(R"R>((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt
put_nowaitšs
c

Cs0t|_
|jjƒ
|jr,|jƒ
ndS(
N(tTrueR0RtcloseR1(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyROs
    
 
    
c

Cs3td
ƒ

|j
st‚
|jr/|jƒ
ndS(NsQueue.join_thread()(R
R0R8R.(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytjoin_thread£s



    
c

Cs<td
ƒ

t
|_y|jjƒ
Wntk
r7


n
XdS(NsQueue.cancel_join_thread()(R
RNR/R.tcanceltAttributeError(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pytcancel_join_thread©s


    


 
c

    Csótd
ƒ

|j
jƒ
tjdtjd|j
|j|j|j    |j
jfddƒ|_t |j_tdƒ

|jjƒ
tdƒ

|jsÅt|jtjtj|jƒ
g
dd    ƒ
|_nt|tj|j
|jgdd
ƒ
|_dS(NsQueue._start_thread()ttargettargstnametQueueFeederThreadsdoing self._thread.start()s... done self._thread.start()texitpriorityiûÿÿÿi
(R
R,tclearR(tThreadRt_feedR)R3RRROR-RNtdaemontstartR/Rt_finalize_jointweakreftrefR.t_finalize_closeR1(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR:±s(

 
    
    



 
    




    

c
CsDtd
ƒ

|ƒ}
|
dk    r6|
jƒ
tdƒ

n
tdƒ

dS(Nsjoining queue threads... queue thread joineds... queue thread already dead(R
Rtjoin(ttwrtthread((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR^Ñs

    



 cCsAtd
ƒ

|
j
ƒ
z|jtƒ

|
jƒ
Wd|
jƒ
XdS(Nstelling queue thread to quit(R
R9R;t    _sentinelR<R=(tbuffertnotempty((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRaÛs
 


 
cCs€
td
ƒ

ddl
m}
|
j}|
j}|
j}|j}    t}
tj    dkrh|j}|j}nd}y±xª|ƒ
z|sŽ|ƒ
nWd|ƒ
Xymxf|    ƒ} | |
krÊtdƒ

|ƒ
dS|dkrã|| ƒ

q |ƒ
z|| ƒ

Wd|ƒ
Xq Wqttk
r



qtXqtWnZtk
r{

}
y3|ƒrM
t d|ƒ
nddl}|jƒ
Wq|
tk
rw



q|
Xn
XdS(Ns$starting thread to feed data to pipei
(
t
is_exitingRs%feeder thread got sentinel -- exitingserror in queue thread: %siÿÿÿÿ(R
tutilRhR9R=twaittpopleftReRRRt
IndexErrort    ExceptionRt    tracebackt    print_exc(RfRgR2t    writelockRORhtnacquiretnreleasetnwaittbpoplefttsentineltwacquiretwreleaseR>t
eRn((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR[åsR

    
    
    
    


    








    





 


 


    


 
N(t__name__t
__module__R$R%R'R!RNRRARERHRIRKRLRMRORPRSR:tstaticmethodR^RaR[(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR8s$                                                  
 
cBsGeZ
dd
„
Zd„Zd„Zedd„Zd„Zd„Z    RS(icCs/tj
||
ƒ
td
ƒ
|_tƒ|_dS(Ni(RR$Rt_unfinished_tasksR    t_cond(R"R#((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR$)
s


c

Cstj
|ƒ
|j|jfS(
N(RR%R}R|(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR%.
s
cCs.tj
||
d
 ƒ
|
d
\|_|_dS(Niþÿÿÿ(RR'R}R|(R"R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR'1
s

cCs´|jst
‚
|jj||ƒs.t‚
n|jjƒ
|jjƒ
zJ|jdkrg|j    ƒ
n|j
j|
ƒ

|jj ƒ
|jjƒ
Wd|jj ƒ
|jj ƒ
XdS(
N(R0R8R R9RR)R}R-RR:R,R;R|R=R<(R"R>R?R@((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRA5
s


     
 


 

 
 
c

Csi|jj
ƒ
zG|jj
tƒ
s1td
ƒ
‚
n|jjjƒrS|jjƒ
nWd|jjƒ
XdS(Ns!task_done() called too many times(    R}R9R|Rt
ValueErrorRFRJt
notify_allR=(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt    task_doneF
s
 




c

CsH|jj
ƒ
z&|jjjƒs2|jjƒ
nWd|jjƒ
XdS(
N(R}R9R|RFRJRjR=(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRbP
s

 


N(
RyRzR$R%R'RNRRAR€Rb(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR'
s            
c
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(c

Cs\td
t
ƒ
\|_|_tƒ|_tjdkrBd|_    ntƒ|_    |j
ƒ
dS(NRR(RRRRRRRRRRt _make_methods(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR$^
s




c


Cs|jj
ƒS(
N(RR6(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRIg
s
c

Cs&t|ƒ

|j
|j|j|jfS(
N(RRRRR(
R"((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR%j
s


cCs,|
\|_|_
|_|_|jƒ
dS(
N(RRRRR(R"R&((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR'n
s

c
s«|jj
‰
|jj|jj‰‰‡‡
‡fd
†}
|
|_|jdkrd|jj    |_
nC|jj    ‰|jj|jj‰‰‡‡‡fd†}||_
dS(Ncs!ˆƒ
zˆ
ƒSWdˆƒ
XdS(
N(((tracquireR4trrelease(s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyREu
s


c

s$ˆ
ƒ
zˆ|ƒ
SWdˆƒ
XdS(
N((
R>(R2RvRw(s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRAƒ
s


(RR4RR9R=RERRRR2RA(R"RERA((R‚R4RƒR2RvRws^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyRr
s


    

(RyRzR$RIR%R'R(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyR
\
s
                    (t__all__RRR(R*RBtatexitR_RRRRtmultiprocessingRtmultiprocessing.synchronizeRRRR    tmultiprocessing.utilR
RRR tmultiprocessing.forkingRtobjectReRR
(((s^/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/queues.pyt<module>#s"








"
"
å    
5