ó
|
O\¬Qc @ s d d l m Z d d l Z d d l Z d d l Z d d l Z d d l m Z y d d l Z d d l Z Wn e
|
k
|
r d Z d Z n Xd d l Z e j e d d e j f d Y Z e j e oÒ e d d e j f d Y Z d Z e d
|
k re n d S( iÿÿÿÿ( t with_statementN( t test_supports! Threading required for this test.t TestPendingCallsc B s8 e Z d Z d d Z d Z d Z d Z RS( c sa f d } xK t | D]= } t j t j d x t rX t j | r< Pq< q< Wq Wd S( Nc s j d d S( N( t appendt None( ( t l( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt callback s g{®Gáz?( t ranget timet sleept randomt Truet _testcapit _pending_threadfunc( t selfR t nR t i( ( R sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt pendingcalls_submit s c C s× d } x¦ t | | k r® t r> t j r> d t | f Gn x t d D] } | | } qK W| r{ | j j r{ q n | d 7} | j | d k d | t | f q Wt rÓ t j rÓ d t | f GHn d S( Ni s (%i)iè i i' s( timeout waiting for %i callbacks, got %i( t lent FalseR t verboset xranget eventt is_sett
|
assertTrue( R R R t contextt countR t a( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt pendingcalls_wait$ s
|
c C sø d } g } d t f d Y} | } g | _ d | _ | | j | _ d | _ t j | _ t j | _ xL t
|
| j D]; } t j d | j d | f } | j | j | q W| j | j | | x | D] } | j qà Wd S( Ni t fooc B s e Z RS( ( t __name__t
|
__module__( ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR ; s i i t targett args( t objectR R t nThreadst nFinishedt threadingt Lockt lockt EventR R t Threadt pendingcalls_threadt startR R t join( R R t threadsR R R t t( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt test_pendingcalls_threaded7 s"
|
c
|
C s z | j | j | j Wd | j 8 | j d 7_ | j } t rZ t j rZ d G| GHn Wd QX| | j k r | j j
|
n Xd S( Ni s finished threads: ( R R R R' R$ R R R R# R t set( R R R$ ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR* N s
|
c C s0 g } d } | j | | | j | | d S( Ni@ ( R R ( R R R ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt test_pendingcalls_non_threadedZ s N( R R R R R R/ R* R1 ( ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR s
|
t TestThreadStatec B s e Z e j d Z RS( c s@ f d } | t j d | } | j | j d S( Nc s_ g f d } t j | | } } t j d j j t j d d d S( Nc s j t j d S( N( R t threadt get_ident( ( t idents( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR n s i i s/ Couldn't find main thread correctly in the list( R t _test_thread_stateR R t assertEqualR R3 R4 ( R R t b( R ( R5 sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR k s
|
R ( R% R) R+ R, ( R R R. ( ( R sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt test_thread_stateh s
|
|
( R R R t reap_threadsR9 ( ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyR2 e s c C s x t t D]t } | j d r t t | } t j rF d G| GHn y | Wq t j k
|
r} t j t j d q Xq q Wt j
|
t t d S( Nt test_t internali ( t dirR t
|
startswitht getattrR R t errort
|
TestFailedt syst exc_infot run_unittestR R2 ( t namet test( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt test_main~ s !t __main__( t
|
__future__R RB R R
|
t unittestRF R R3 R% t ImportErrorR R t
|
skipUnlesst TestCaseR R2 RG R ( ( ( sV /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_capi.pyt <module> s&
|
R
|
