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
ó 
Q\¬Qc@sM
dd
lZdd
l
Z
dd
lZddlmZ
ejdƒ
ZdZdejf
d„ƒYZ    ddd„ƒYZ
d    e
f
d
„ƒYZdeejfd„ƒYZ d eejfd„ƒYZdeejfd„ƒYZdef
d„ƒYZdejf
d„ƒYZde
ejfd„ƒYZd„ZedkrI
eƒ
nd
S(iÿÿÿÿN(
ttest_supportt    threadingit_TriggerThreadc
BseZ
d„Zd
„ZRS(cCs5|
|_||_
tjƒ|_tjj|ƒ

dS(
N(tfntargsR
tEventtstartedEventtThreadt__init__(tselfRR((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyR s
    
    

c

Cs.tj
d
ƒ

|jjƒ
|j|jŒ
dS(Ngš™™™™™¹?(ttimetsleepRtsetRR(
R    ((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytruns     
 
(t__name__t
__module__RR (((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRs
    tBlockingTestMixinc
Bs#eZ
d„Zd
„Zd„ZRS(c

Cs d|_
dS(
N(tNonet
t(
R    ((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyttearDown.s
cCsŽt||ƒ|_
|j
jƒ
|
|Œ|_|j
jjƒsT|jd
|
ƒ

n|j
jdƒ

|j
jƒr‡|jd|ƒ

n|jS(Ns,blocking function '%r' appeared not to blocki
s,trigger function '%r' appeared to not return(    RRtstarttresultRtis_settfailtjointis_alive(R    t
block_funct
block_argsttrigger_functtrigger_args((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytdo_blocking_test1s

 

    



    

cCs¶t||ƒ|_
|j
jƒ
z:y|
|Œ
Wn|k
rF


‚nX|jd
|ƒ

Wd|j
jdƒ

|j
jƒr|jd|ƒ

n|j
jjƒs±|jdƒ

nXdS(Nsexpected exception of kind %ri
s,trigger function '%r' appeared to not returns(trigger thread ended but event never set(RRRRRRRR(R    RRRRtexpected_exception_class((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytdo_exceptional_blocking_test@s
 



 
    


    


(RRRRR (((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyR,s        t BaseQueueTestc
BsGeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„ZRS(c

Csd
|_t
jƒ|_dS(Ni(tcumR
tLocktcumlock(
R    ((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytsetUpVs
    
c    Csã|
jƒst
d
‚n|
jdƒ

|
jdƒ

|
jdƒ

tddddgddddgddddgƒ}|
jƒ|
jƒ|
jƒg}|j|||
jjdƒ
x<tt    d    ƒ
D]*}|
j|ƒ

|j
|
jƒd
ƒ
qÄW|j
|
jƒdƒ
dt    }dt    }|
j|ƒ

|j
|
jƒdƒ
y$|
j|ddƒ


|jdƒ

Wnt jk
rz



n
Xy$|
j|ddƒ


|jdƒ

Wnt jk
rµ



n
X|j|
j|f
|
jdƒ
|j|
j|tdf|
jdƒ
xtt    ƒ
D]}|
jƒ
qW|j
|
jƒdƒ
y!|
jddƒ

|jdƒ

Wnt jk
rh


n
Xy!|
jddƒ

|jdƒ

Wnt jk
r 


n
X|j|
jd|
jdƒ
|j|
jtdf|
jdƒ
dS( Ns&Call this function with an empty queueioiM
iÞtQueuet    LifoQueuet PriorityQueues&Didn't seem to queue the correct data!i
sQueue should not be emptysQueue should not be fulliisQueue should be fulltblockis(Didn't appear to block with a full queuettimeoutg{®Gáz„?s+Didn't appear to time-out with a full queuei
sQueue should be emptys*Didn't appear to block with an empty queues-Didn't appear to time-out with an empty queuetemptyi((((
sempty(
sempty(R+tRuntimeErrortputtdicttgettassertEqualt    __class__Rtranget
QUEUE_SIZEt
assertTruetfullRR&tFullRtTruetEmpty(R    t
qttarget_ordertactual_ordert
itlastR5((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytsimple_queue_testZs\

 
 
 



!



 



 

 











%












cCs`xYtr[|
j
ƒ}|dkr/|
jƒ
dS|j
|j|7_WdQX|
jƒ
qWdS(
N(R7R/Rt    task_doneR$R"(R    R9t
x((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytworkers
    



 


cCs¸d
|_x0dD](}t
jd|jd|
f
ƒjƒ
qWx!tdƒ
D]}|
j|ƒ

qIW|
jƒ
|j|jt    t
dƒ
ƒ
dƒ
xdD]}|
jdƒ

q“W|
jƒ
dS(    Nii
ttargetRids0q.join() did not block until all tasks were done(ii
(ii
(R"R
RRARtxrangeR-RR0tsumR2R(R    R9R<((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytqueue_join_test™s
    
 
&






 

c
Cs?|jƒ}
y|
j
ƒ
Wntk
r-


nX|jd
ƒ

dS(Ns(Did not detect task count going negative(t    type2testR?t
ValueErrorR(R    R9((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyttest_queue_task_done¦s


 
c
CsY|jƒ}
|j
|
ƒ

|j
|
ƒ

y|
jƒ
Wntk
rG


nX|jd
ƒ

dS(Ns(Did not detect task count going negative(RFRER?RGR(R    R9((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyttest_queue_join°s
 
 


 
c
Cs-|jt
ƒ
}
|j|
ƒ

|j|
ƒ

dS(
N(RFR3R>(R    R9((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyttest_simple_queue½s
 
(    RRR%R>RARERHRIRJ(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyR!Us
        5    
         
     t    QueueTestc
BseZ
ejZRS((RRR&RF(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRKÅs
t LifoQueueTestc
BseZ
ejZRS((RRR&R'RF(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRLÈs
tPriorityQueueTestc
BseZ
ejZRS((RRR&R(RF(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRMËs
tFailingQueueExceptionc
BseZ
RS((RR(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRNÑs
tFailingQueuec
Bs#eZ
d„Zd
„Zd„ZRS(c
Gs)t|_
t|_tjj||
Œ

dS(
N(tFalset fail_next_putt fail_next_getR&R(R    R((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRÕs
    
    
cCs1|jrt
|_td
‚ntjj||
ƒS(NsYou Lose(RQRPRNR&t_put(R    titem((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRSÙs
    
    

c

Cs.|jrt
|_td
‚ntjj|ƒ
S(NsYou Lose(RRRPRNR&t_get(
R    ((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRUÞs
    
    

(RRRRSRU(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyROÔs
        tFailingQueueTestc
BseZ
d„Zd
„ZRS(cCs¥|
jƒst
d
‚nx%ttdƒ
D]}|
j|ƒ

q)Wt|
_y$|
jdddƒ


|jdƒ

Wntk
r€


n
Xt|
_y$|
jdddƒ


|jdƒ

Wntk
rÁ


n
X|
jd    ƒ

|j    |
j
ƒd
ƒ
t|
_y-|j|
jd|
jdƒ
|jdƒ

Wntk
r.



n
X|
jd    ƒ

t|
_y9|j |
jdtdf|
jdtƒ
|jdƒ

Wntk
r‘



n
X|
jd    ƒ

|j    |
j
ƒd
ƒ
|
jƒ
|j    |
j
ƒd ƒ
|
jd    ƒ

|j    |
j
ƒd
ƒ
|j|
jd|
jdƒ
xttƒ
D]}|
jƒ
q"W|j    |
jƒdƒ
|
jdƒ

t|
_y|
jƒ
|jdƒ

Wntk
r


n
X|j    |
jƒdƒ
t|
_y!|
jddƒ

|jdƒ

Wntk
rå


n
X|j    |
jƒdƒ
|
jƒ
|j    |
jƒdƒ
t|
_y0|j |
jd|
jdtƒ
|jdƒ

Wntk
ri


n
X|j    |
jƒdƒ
|
jƒ
|j    |
jƒdƒ
dS(Ns&Call this function with an empty queuei
toopsR)is)The queue didn't fail when it should haveR*gš™™™™™¹?R=sQueue should be fullR5i
sQueue should not be fullsQueue should be emptytfirstsQueue should not be emptyR+(
sfull(((
sfull(((
sempty(R+R,R2R3R-R7RQRRNR4R5RR/R RR(R    R9R<((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pytfailing_queue_testæsŠ



    



 

    



 

 
    



 
     

!


 
 




 



 
    




 


    



 





    




 



c
Cs*tt
ƒ
}
|j|
ƒ

|j|
ƒ

dS(
N(ROR3RY(R    R9((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyttest_failing_queue7
s
 
(RRRYRZ(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyRVäs    QcCstj
ttttƒ
dS(
N(Rtrun_unittestRKRLRMRV(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyt    test_main?
s

t__main__((R&R
tunittestttestRt import_moduleR
R3RRRR!tTestCaseRKRLRMt    ExceptionRNRORVR\R(((sW/tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_queue.pyt<module>s"



 )p[