ó
|
Q\¬Qc @ s~ d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l
|
Z
|
d d l Z d d l Z d d l m Z d d l m Z e j d Z d d l Z e j d d d l 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 m Z e Z Wn e k
|
rce Z n Xy d d l m Z m! Z! e Z" Wn e k
|
re Z" n Xy d d l# Z# Wn e k
|
rÇd Z# n Xe% Z& e j' Z( d Z) e Z* e* rûd \ Z+ Z, Z- n d \ Z+ Z, Z- e. e d e Z/ e j0 d k Z1 y e j2 d Z3 Wn d Z3 n Xy d d l4 m5 Z5 m6 Z6 m7 Z7 Wn! e k
|
re8 Z5 d Z6 Z7 n Xd Z9 d e8 f d YZ: d e8 f d YZ; d Z< d e; f d YZ= d e j> f d YZ? d e; f d YZ@ d ZA d ZB d e; f d! YZC d" e; f d# YZD d$ e; f d% YZE d& e; f d' YZF d( e; f d) YZG d* e; f d+ YZH d, e; f d- YZI d. e; f d/ YZJ d0 d1 ZK d2 e; f d3 YZL d4 ZM d5 e; f d6 YZN d7 e; f d8 YZO d9 e; f d: YZP d d; l mQ ZQ mR ZR mS ZS d< e8 f d= YZT d> ZU d? eR f d@ YZV dA eQ f dB YZW eW jX dC dD eT eW jX dE dD eT dF d eW jX dI dD eU dJ eV dK e; f dL YZY e j ZZ dM Z[ dN eQ f dO YZ\ e\ jX dP dD e[ dQ eQ f dR YZ] e] jX dP dS Z^ dT e; f dU YZ_ dV e; f dW YZ` e& dX Za dY e; f dZ YZb d[ e; f d\ YZc d] e; f d^ YZd d_ e5 f d` YZe da e; f db YZf dc e; f dd YZg de e; f df YZh dg e; f dh YZi di e; f dj YZj dk e jk f dl YZl dm Zm dn Zn do e8 f dp YZo en eo dq dr Zp eq jr ep ds e8 f dt YZs en es dq du Zt eq jr et dv e8 f dw YZu en eu dq dx Zv eq jr ev dy e jk f dz YZw d{ Zx d| e jk f d} YZy d~ Zz d Z= d Z{ d Z| d e8 f d YZ} d e jk f d
YZ~ d e jk f d YZ d e jk f d YZ d e jk f d YZ d e jk f d YZ ew el ey e~ e e e e g Z d d Z d Z
e d k rze
n d S( iÿÿÿÿN( t test_support( t StringIOt _multiprocessings multiprocessing.synchronize( t util( t reduction( t Valuet copyg¹?g=
|
×£p=ê?gffffffÖ?gffffffö?t HAVE_BROKEN_SEM_GETVALUEt win32t SC_OPEN_MAXi ( t Structuret c_intt c_doublec C sg d } y t j d } Wn t t f k
|
r3 d SX| d k sL | | k rP d St j d | d S( sA Check that the system supports enough semaphores to run the test.i t SC_SEM_NSEMS_MAXNiÿÿÿÿsH The OS doesn't support enough semaphores to run the test (required: %d).( t ost sysconft AttributeErrort
|
ValueErrort unittestt SkipTest( t nsems_mint nsems( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt check_enough_semaphoresd s t TimingWrapperc B s e Z d Z d Z RS( c C s | | _ d | _ d S( N( t funct Nonet elapsed( t selfR ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt __init__y s c O s; t j } z | j | | SWd t j | | _ Xd S( N( t timeR R ( R t argst kwdst t( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt __call__} s ( t __name__t
|
__module__R R! ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR w s t BaseTestCasec B s/ e Z d Z d Z d Z d Z e Z RS( t processest managert threadsc C s t r | j | | d n d S( Ni ( t CHECK_TIMINGSt assertAlmostEqual( R t at b( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt assertTimingAlmostEqual s c G s8 y | | } Wn t k
|
r# n X| j | | Sd S( N( t NotImplementedErrort assertEqual( R t valueR R t res( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt assertReturnsIfImplemented s
|
c G s t d d S( Ns# shouldn't try to pickle a test case( R- ( R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
__reduce__ s ( s processess managerR' ( R" R# t ALLOWED_TYPESR, R1 R2 t __reduce_ex__( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR$ s
|
|
c C sj y | j SWnU t k
|
re y | j SWqf t k
|
ra y | j SWqb t k
|
r] t qb Xqf Xn Xd S( N( t get_valueR t _Semaphore__valuet _valueR- ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR5 £ s t _TestProcessc B s e Z d Z d Z e d Z d Z e d Z d Z d Z d Z
|
e d Z d
|
Z e d Z d Z RS( R% R' c C s¥ | j d k r d S| j } | j } | j | j | j | j | j | t | j t | d k | j | j
|
t j | j | j d d S( NR' i ( t TYPEt current_processt authkeyt
|
assertTruet is_alivet daemont assertIsInstancet bytest lenR. t identR t getpidt exitcodeR ( R t currentR; ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_current· s c O sr | j } | j | | j | | j | j | j d k rn | j t | j | j | j n d S( NR' ( R: t putt nameR9 R@ R; t pid( t clst qR R RE ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _testÅ s c C s< | j d } | j } | d d f } i d d 6d d 6} d } | j d | j d | d
|
| d | } t | _ | j } | j d k r¨ | j | j | j n | j | j
|
t | j | j t | j | | j | j t | j t k | j | j d | j | j | j d | j | j
|
t | j | | j | j | j | d | j | j | | j | j | j | j d k rï| j | j | j | j | j | j n | j | j | j d | j | j
|
t | j | | j d S( Ni i i t hellogR¸
ëQ@t byet SomeProcesst targetR t kwargsRH R' i ( t Queuet Eventt ProcessRL t TrueR> R: R9 R. R; R= t Falset assertNotInt active_childrenR< t typet listRD R t startt assertInt getRH RI t join( R RK t eR RQ RH t pRE ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_processÏ s<
|
|
c C s t j d d S( Niè ( R t sleep( RJ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_terminateö s c C só | j d k r d S| j d | j } t | _ | j | j | j t | j | | j | j | j
|
d | j t | j } | j | d | j | j d | j | j t | j | | j | j d S( NR' RP g ( R9 RT Rc RU R> R[ R. R= R\ RX RD R t terminateR R^ R, R RV RW ( R R` R^ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_terminateú s
|
|
c C sZ y t j } Wn t k
|
r) d } n X| j t | t k | j | d k d S( Ni ( t multiprocessingt cpu_countR- R< RY t int( R t cpus( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_cpu_count s
|
c C s | j t | j t | j d t j d t f } | j | | j t | _
|
| j | j | | j | j | j | | j d S( NRP R ( R. RY RX RZ RT R Rb t DELTARW RU R> R[ R\ R^ ( R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_active_children s
|
|
c C s d d l m } | j | t | d k r
xS t d D]B } | j d | j d | | | g f } | j | j q< Wn d S( Niÿÿÿÿ( t forkingi RP R ( Rf Rm t sendRA t rangeRT t _test_recursionR[ R^ ( RJ t wconnt idRm t iR` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRp ) s
|
c C s® | j d t \ } } | j | g t j t g } x# | j r` | j | j q> Wg d g d d g d d g d g d d g d d g g } | j | | d S( Nt duplexi i (
|
t PipeRV Rp R Rb Rk t pollt appendt recvR. ( R t rconnRq t resultt expected( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_recursion5 s c C s# t | d t _ t j | d S( Nt w( t opent syst stderrt exit( RJ t reasont testfn( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_sys_exitI s c C sX | j d k r d St j } | j t j | x· d d d g d f d f D] \ } } | j d | j d | | f } t | _ | j | j
|
d | j | j | t | d
|
) } | j | j j t | Wd QXqK Wxh t t d f D]W } | j d t j d | f } t | _ | j | j
|
d | j | j | qù Wd S( NR' i i i s ignore thisi RP R i t ri ( s ignore thisi ( R9 R t TESTFNt
|
addCleanupt unlinkRT R RU R> R[ R^ R. RD R~ t readt rstript strRV R R ( R R R t codeR` t f( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_sys_exitN s$ (!
|
,
|
( s processess threads( R" R# R3 RF t classmethodRL Ra Rc Re Rj Rl Rp R| R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR8 ³ s
|
' t _UpperCaserc B s, e Z d Z d Z d Z d Z RS( c C s, t j j | t j \ | _ | _ d S( N( Rf RT R Ru t
|
child_connt parent_conn( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR m s c C sT | j j x3 t | j j d D] } | j j | j q# W| j j d S( N( R t closet iterR Rx R Rn t upper( R t s( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt runq s c C s5 t | t k s t | j j | | j j S( N( RY R t AssertionErrorR Rn Rx ( R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt submitw s c C s. | j j d | j j | j j d S( N( R Rn R R R ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt stop| s ( R" R# R R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR k s t _TestSubclassingProcessc B s e Z d Z d Z RS( R% c C sf t } t | _ | j | j | j d d | j | j d d | j | j d S( NRM t HELLOt worldt WORLD( R RU R> R[ R. R R R^ ( R t
|
uppercaser( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_subclassing
s
|
|
( s processes( R" R# R3 R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s c C s- t | d r | j S| j d k Sd S( Nt emptyi ( t hasattrR¡ t qsize( RK ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt queue_empty s
|
c C s- t | d r | j S| j | k Sd S( Nt full( R¢ R¥ R£ ( RK t maxsize( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
queue_full s
|
t
|
_TestQueuec B sq e Z e d Z d Z e d Z d Z e d Z d Z d Z e d Z
|
d Z RS( c C s9 | j x t d D] } | j q W| j d S( Ni ( t waitRo R] t set( RJ t queuet child_can_startt parent_can_continueRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_put¢ s
|
c C sµ d } | j d | } | j } | j } | j d | j d | | | f } t | _ | j | j t | t | j t | | t
|
| j d | j d t | j d t d | j d t
|
| j d t
|
d | j d t j t | j t | t
|
| j t | | t t | j } t | j } | j t j | d
|
t
|
| j | j d | j t j | d
|
t
|
d | j | j d | j t j | d
|
| j | j d | j t j | d
|
t t | j | j t | j t j | d
|
t
|
t | j | j d | j t j | d
|
t d t | j | j t | j | j | j t | t | j t | | t
|
| j d S( Ni R¦ RP R i i i i i i i t timeout( RR RS RT R® RU R> R[ R. R¤ R§ RV RG R t
|
put_nowaitR Rb Rk R t assertRaisest FullR, R t TIMEOUT1t TIMEOUT2t TIMEOUT3Rª R© R^ ( R t MAXSIZER« R¬ R t procRG R° ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_put© sN
|
|
|
c C sL | j | j d | j d | j d | j d | j d S( Ni i i i ( R© RG Rª ( RJ R« R¬ R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_getã s
|
c C sP | j } | j } | j } | j d | j d | | | f } t | _ | j | j t | t | j | j
|
t j t | j t | t | j | j t d d | j | j t d | j | j d d d | j | j d | j t | t t | j } t | j } | j t j | t | j | j d | j t j | t d | j | j d | j t j | | j | j d | j t j | t t | j | j t | j t j | t t | j | j d | j t j | d t | j | j t | j d S(
|
NRP R i i R¯ i i i i ( RR RS RT R¹ RU R> R[ R. R¤ Rª R© R Rb Rk RV R] R t
|
get_nowaitR R± t EmptyR, R R³ R´ Rµ R^ ( R R« R¬ R R· R] Rº ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_getí sB
|
|
|
c C s+ x$ t d d D] } | j | q Wd S( Ni
|
i ( Ro RG ( RJ R« Rs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
_test_fork! s c C s | j } x! t d D] } | j | q Wt j t | j d | j d | f } t | _ | j
|
x* t d D] } | j | j | q{ W| j t j | j t | j d S( Ni
|
RP R i ( RR Ro RG R Rb Rk RT R½ RU R> R[ R. R] R± R» RV R^ ( R R« Rs R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_fork) s
|
c C sÅ | j } y | j | j d Wn t k
|
r: d SX| j d | j | j d | j d | j | j d | j | j | j d | j | j | j d d S( Ni i i i ( RR R. R£ R- RG R] ( R RK ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_qsizeD s
|
|
c C s8 x1 t | j d D] } t j t | j q Wd S( N( R R] R R Rb Rk t task_done( RJ RK t obj( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_task_doneS s c C s | j } t j d k r; t | d r; | j d n g t d D]$ } | j d | j d | f ^ qH } x! | D] } t | _ | j
|
qy Wx! t d D] } | j | q£ W| j x | D] } | j d qË Wx | D] } | j qé Wd S(
|
Ni i RÀ s# requires 'queue.task_done()' methodi RP R i
|
( i i ( t JoinableQueueR t version_infoR¢ t skipTestt xrangeRT RÂ RU R> R[ RG R^ R ( R R« Rs t workersR` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_task_doneY s 4
|
( R" R# R R® R¸ R¹ R¼ R½ R¾ R¿ RÂ RÈ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR¨ s :
|
4 t _TestLockc B s# e Z d Z d Z d Z RS( c C sq | j } | j | j t | j | j t t | j | j d | j t t j
|
f | j d S( N( t LockR. t acquireRU RV t releaseR R± R t threadingt ThreadError( R t lock( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_lockw s
|
c C s | j } | j | j t | j | j t | j | j t | j | j d | j | j d | j | j d | j t t f | j d S( N( t RLockR. RË RU RÌ R R± R t RuntimeError( R RÏ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_rlock~ s c C s | j Wd QXd S( N( RÊ ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_lock_context s ( R" R# RÐ RÓ RÔ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÉ u s
|
t _TestSemaphorec B s, e Z d Z d Z d Z d Z RS( c C sç | j d t | | j | j t | j d t | | j | j t | j d t | | j | j t t | j d t | | j | j d | j d t | | j | j d | j d t | d S( Ni i i ( R1 R5 R. RË RU RV RÌ R ( R t sem( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_semaphore s c C sr | j d } | j | | j | j d | j d t | | j | j d | j d t | d S( Ni i i ( t SemaphoreR× R. RÌ R R1 R5 ( R RÖ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_semaphore s c C s | j d } | j | d S( Ni ( t BoundedSemaphoreR× ( R RÖ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_bounded_semaphore¤ s c C s | j d k r d S| j d } t | j } | j | t t | j | j d | j | t d t | j | j d | j | t t t | j | j d | j | t
|
t t | j | j t | j | d t t | j | j t d S( NR% i g R¯ ( R9 RØ R RË R. RV R, R R R³ RU R´ Rµ ( R RÖ RË ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_timeout¬ s ( R" R# R× RÙ RÛ RÜ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÕ s t _TestConditionc B s> e Z e d d Z d Z d Z d Z d Z RS( c C s9 | j | j | j | | j | j d S( N( RË RÌ R© ( RJ t condt sleepingt wokenR¯ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR Å s
|
|
|
|
c C ss | j d k ro yI | j j | j j } | j | d | j | j j d Wqo t k
|
rk qo Xn d S( NR% i ( R9 t _sleeping_countR5 t _woken_countR. t _wait_semaphoreR- ( R RÞ t sleepers( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt check_invariantÍ s c C sc | j } | j d } | j d } | j d | j d | | | f } t | _ | j t j d | j d | | | f } t | _ | j | j | j t
|
j t | j d t | | j | j | j t
|
j t | j d t | | j | j | j t
|
j t | j d t | | j | | j d S( Ni RP R i i ( t ConditionRØ RT R RU R> R[ RÍ t ThreadRË R Rb Rk R1 R5 t notifyRÌ Rå R^ ( R RÞ Rß Rà R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_notifyØ s2 $
|
$
|
|
|
|
|
|
|
|
|
c C s, | j } | j d } | j d } x t d D]z } | j d | j d | | | t f } t | _ | j t j
|
d | j d | | | t f } t | _ | j q7 Wx t d D] } | j q Wx t d D] } | j qã W| j d t | | j | x t d D]t } | j d | j d | | | f } t | _ | j t j
|
d | j d | | | f } t | _ | j q$Wx t d D] } | j q©Wt j t | j d t | | j | j | j t j t | j d t | | j | d S( Ni i RP R i ( Ræ RØ Ro RT R R³ RU R> R[ RÍ Rç RÆ RË R1 R5 Rå R Rb Rk t
|
notify_allRÌ ( R RÞ Rß Rà Rs R` R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_notify_all sF
|
$
|
$
|
|
|
c C sb | j } t | j } | j | t } | j | j | d | j | j t d S( N(
|
Ræ R R© RË R³ RÌ R. R R, R ( R RÞ R© R0 ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÜ > s
|
|
N( R" R# R R R Rå Ré Rë RÜ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÝ Ã s + ;t
|
_TestEventc B s e Z e d Z d Z RS( c C s t j t | j d S( N( R Rb R´ Rª ( RJ t event( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_eventJ s c C sD | j } t | j } | j | j t | j | d t | j | j d | j | t t | j | j t | j | j | j t
|
| j | t
|
| j | j d | j | t t
|
| j | j d | j | j d | j d | f } t
|
| _ | j | j | t
|
d S( Ng RP R ( RS R R© R. t is_setRV R, R R³ Rª RU t clearRT Rî R> R[ ( R Rí R© R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_eventO s$
|
|
|
( R" R# R Rî Rñ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRì H s t
|
_TestValuec B sk e Z d Z d d d d
|
e d e d f g Z d Z e d Z e d Z d Z
|
d Z RS( R% Rs i÷ iª^ t dg @g Àt hiÿÿÿiê t ct xt yc C s t s | j d n d S( Ns% requires multiprocessing.sharedctypes( t HAS_SHAREDCTYPESRÅ ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt setUp s c C s4 x- t | | j D] \ } } | d | _ q Wd S( Ni ( t zipt codes_valuesR/ ( RJ t valuest svt cv( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRL s c C s | r: g | j D]! \ } } } | j | | ^ q } n1 g | j D]! \ } } } | j | | ^ qD } x7 t | | j D]# \ } } | j | j | d q~ W| j d | j d | f } t | _ | j
|
| j x7 t | | j D]# \ } } | j | j | d qó Wd S( Ni RP R i ( Rû t RawValueR Rú R. R/ RT RL RU R> R[ R^ ( R t rawR R/ t _Rü Rý Rþ R· ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_value s 1.
|
|
c C s | j d t d S( NR ( R RU ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_rawvalue s c C sK | j d d } | j } | j } | j d d d d } | j } | j } | j } | j d d d | } | j } | j }
|
| j | | | j d d d t } | j t | d | j t | d | j t
|
| j d d d d | j d d } | j t | d | j t | d d S( NRs i RÏ t get_lockt get_objt navalue( R R R R RÊ R. RV t assertFalseR¢ R± R Rÿ ( R t val1t lock1t obj1t val2t lock2t obj2RÏ t val3t lock3t obj3t arr4t arr5( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_getobj_getlock s$ ( s processes( Rs i÷ iª^ ( Ró g @g À( Rô iÿÿÿiê ( R" R# R3 t latinRû Rù R RL RV R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRò u s t
|
_TestArrayc B sÅ e Z d Z e d Z e j e d k d e d Z
|
e j e d k d d Z e j e d k d d Z e j e d k d d Z e j e d k d d Z RS(
|
R% c C s< x5 t d t | D] } | | c | | d 7<q Wd S( Ni ( Ro RA ( RJ t seqRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR ¾ s s requires _ctypesc
|
C sY d d d d d d d d d d
|
g
|
} | r? | j d | } n | j d | } | j t | t | | j | d | d | j t | d d ! t | d d ! t j d d d d d g | d d +| d d +| j t | | | j | | j d | j d | f } t | _ | j
|
| j | j t | | d S( Ni¨ ir i¦ i5 i ié i$ iÖ iÊ i? Rs i i i i i i RP R ( t RawArrayt ArrayR. RA RZ t arrayR RT RU R> R[ R^ ( R R R t arrR` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_arrayàs $ *0
|
|
c C s d } x
t d D]w } | j d | } | j t | | | j t | d g | t d | (| j t | t d ~ q Wd S( Ni
|
i Rs i ( Ro R R. RA RZ ( R t sizeR R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_array_from_sizeÜ s c C s | j d t d S( NR ( R RU ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_rawarrayë s c C sT | j d d } | j t | d | j d d } | j t | d d S( NRs l
|
i
|
( R R. RA R ( R R t raw_arr( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_array_accepts_longï s c C so | j d t d } | j } | j } | j d t d d d } | j } | j } | j } | j d t d d | } | j } | j }
|
| j | | | j d t d d t } | j t | d | j t | d | j
|
t | j d t d d d | j d t d } | j t | d | j t | d d S( NRs i
|
RÏ R R t notalock( R Ro R R R RÊ R. RV R R¢ R± R R ( R t arr1R R
|
t arr2R R RÏ t arr3R R R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_getobj_getlock_objö s& ( s processesN( R" R# R3 R R R t skipIfR R RV R R R R R% ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR º s !!!t _TestContainersc B s) e Z d Z d Z d Z d Z RS( R& c C sû | j t d } | j | t d | j } | j | g | j t d | j | t d | j | d d | j | d d !d d d g | d 9} | j | d d d d d d d d d d g
|
| j | d d g d d d d d d d d d d d d g | j | t d | | g } | j | } | j | d d d d d d d d d
|
d g
|
d d d d d d d d d d g
|
g | j | g } | j d | j | d d d d d d d d d
|
d d g g d S( Ni
|
i i i i i i i i i i RM ( RZ Ro R. t extendRw ( R R* R+ Ró R_ R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_list s(
|
/> I c C sò | j } t d d } x | D] } t | | | <q" W| j | j t d | D | j t | j | | j t | j g | D] } t | ^ q | j t | j g | D] } | t | f ^ qÏ d S( NiA iF c s s! | ] } | t | f Vq d S( N( t chr( t .0Rs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pys <genexpr>< s ( t dictRo R* R. R t sortedt keysRü t items( R Ró t indicesRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_dict7 s & 5c C s | j } d | _ d | _ d | _ | j | j | j f d | ` | j t | d | j t | d | j t | d d S( Nt Bobt Buildert hiddens Namespace(name='Bob')RH t job( R2 R3 ( t NamespaceRH R5 t _hiddenR. R R< R¢ ( R t n( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_namespaceA s ( s manager( R" R# R3 R) R1 R9 ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR' s
|
g c C s t j | | | S( N( R Rb ( Rö R© ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt sqrP s t _TestPoolc B sb e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z RS(
|
c C s[ | j j } | j | t d t d | j | t d i d d 6 t d d d S( Ni i Rö ( i ( ( t poolt applyR. R: ( R t papply( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_applyU s c C sr | j j } | j | t t d t t t d | j | t t d d d t t t d d S( Ni
|
id t chunksizei ( R< t mapR. R: Ro ( R t pmap( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_mapZ s . c C sQ y) | j j t g d d j d t Wn! t j k
|
rL | j d n Xd S( NR@ i R¯ s2 pool.map_async with chunksize stalled on null list( R< t map_asyncR: R] R³ Rf t TimeoutErrort fail( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_map_chunksize` s )c C sT | j j t d t f } t | j } | j | d | j | j t d S( Ni i1 ( R< t apply_asyncR: R³ R R] R. R, R ( R R0 R] ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_asyncf s c C s^ | j j t d t d f } t | j } | j t j | d t | j | j
|
t d S( Ni gÉ?R¯ ( R< RH R: R´ R R] R± Rf RE R, R ( R R0 R] ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_async_timeoutl s c C s | j j t t d } | j t | t t t d | j j t t d } x. t d D] } | j | j | | qh W| j t | j | j j t t d d d } x. t d D] } | j | j | | qÍ W| j t | j d S( Ni
|
iè R@ id (
|
R< t imapR: Ro R. RZ RA t nextR± t StopIteration( R t itRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_imapr s % ! c C s | j j t t d } | j t | t t t d | j j t t d d d } | j t | t t t d d S( Niè R@ i5 ( R< t imap_unorderedR: Ro R. R- RA ( R RN ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_imap_unordered s %!c C sl | j t t j d | j t t j d t j d } | j d t | j | j | j d S( Niÿÿÿÿi i ( R± R Rf t PoolR. RA t _poolR R^ ( R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_make_pool s
|
c C s | j d k r d S| j j t j g t d D] } d ^ q/ d d } | j j t | j j } | | j | j
|
d k d S( NR& i' g¹?R@ i gÉ?( R9 R< RD R Rb Ro Rd R R^ R< R ( R Rs Rz R^ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRe s . c C s© | j d } | j | j t g g | j t | j t g g | j t | j t g g | j | j t g j g | j | j
|
d S( Ni ( RR R. RA R: RZ RK RP RD R] R R^ ( R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_empty_iterable¢ s """
|
( R" R# R? RC RG RI RJ RO RQ RT Re RU ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR; S s c C s d S( Nc S s d S( Ni* ( ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt <lambda>¯ s ( ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt unpickleable_result® s t _TestPoolWorkerErrorsc B s e Z d Z d Z RS( R% c C sp d d l m } t j d } x6 t d D]( } | j t } | j | | j q, W| j | j
|
d S( Niÿÿÿÿ( t MaybeEncodingErrori i ( t multiprocessing.poolRY Rf RR Ro RH RW R± R] R R^ ( R RY R` t iterationR0 ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_unpickleable_result´ s
|
( s processes( R" R# R3 R\ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRX ± s t _TestPoolWorkerLifetimec B s e Z d Z d Z d Z RS( R% c
|
C s t j d d d } | j d t | j g | j D] } | j ^ q8 } g } x0 t d D]" } | j | j t | f q` Wx6 t
|
| D]( \ } } | j | j t | q W| j d } x; | r t d | j D r | d 8} t j t qÒ Wg | j D] } | j ^ q} | j d | | j d | | j t | t | | j | j d S( Ni t maxtasksperchildi
|
id i2 c s s | ] } | j Vq d S( N( R= ( R+ R} ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pys <genexpr>Ô s i ( Rf RR R. RA RS RI Ro Rw RH R: t enumerateR] t _repopulate_poolt allR Rb Rk RW R t assertNotEqualR- R R^ (
|
R R` R} t origworkerpidst resultsRs t jR0 t countdownt finalworkerpids( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_pool_worker_lifetimeà s&
|
#
|
|
c C s¢ t j d d d } g } x3 t d D]% } | j | j t | d f q( W| j | j x6 t | D]( \ } } | j | j
|
t | qr Wd S( Ni R^ i i g333333Ó?( Rf RR Ro Rw RH R: R R^ R_ R. R] ( R R` Rd Rs Re R0 ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt% test_pool_worker_lifetime_early_closeà s #
|
|
( s processes( R" R# R3 Rh Ri ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR] À s t _TestZZZNumberOfObjectsc B s e Z d Z d Z RS( R& c C sn d } t j t j | j j } | j j } | | k rZ | j j GH| GHn | j | | d S( Ni ( Rf RX t gct collectR& t _number_of_objectst _debug_infoR. ( R t EXPECTED_NUMBERt refst
|
debug_info( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_number_of_objectsù s
|
|
( s manager( R" R# R3 Rr ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRj ò s ( t BaseManagert BaseProxyt RemoteErrort FooBarc B s# e Z d Z d Z d Z RS( c C s d S( Ns f()( ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s c C s
|
t d S( N( R ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt g s c C s d S( Ns _h()( ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _h s ( R" R# R Rw Rx ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRv s c c s$ x t d D] } | | Vq Wd S( Ni
|
( RÆ ( Rs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt baz s t IteratorProxyc B s) e Z d Z d Z d Z d Z RS( RL t __next__c C s | S( N( ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt __iter__ s c C s | j d S( NRL ( t _callmethod( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRL s c C s | j d S( NR{ ( R} ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR{ s ( s nexts __next__( R" R# t _exposed_R| RL R{ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRz s t MyManagerc B s e Z RS( ( R" R# ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s t Foot callablet Bart exposedR Rx Ry t proxytypet _TestMyManagerc B s e Z d Z d Z RS( R& c C sª t } | j | j } | j } | j } g d D] } t | | r> | ^ q> } g d D] } t | | rf | ^ qf } | j | d d g | j | d d g | j | j d | j t | j
|
| j | j d d | j t | j d | j | j d | j | j d | j | j d d | j | j d d | j t | g t d D] } | | ^ q
| j d S( NR Rw Rx s f()s _h()i
|
( R Rw s _h( R Rw s _h( R R[ R R Ry R¢ R. R R± R Rw R} Ru Rx RZ Ro t shutdown( R R& t foot barRy RH t foo_methodst bar_methodsRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_mymanager, s&
|
((3( s manager( R" R# R3 R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR
( s c C s t S( N( t _queue( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt get_queueM s t QueueManagerc B s e Z d Z RS( s$ manager class used by server process( R" R# t __doc__( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR P s R t QueueManager2c B s e Z d Z RS( s@ manager class which specifies the same interface as QueueManager( R" R# R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR T s t xmlrpclibt _TestRemoteManagerc B s& e Z d Z e d Z d Z RS( R& c C sN t d | d | d t } | j | j } | j d d t d f d S( Nt addressR; t
|
serializers hello worldg @( R t
|
SERIALIZERt connectR RG R RU ( RJ R R; R& R« ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _putter_ s
|
|
c C së t j d } t d d d | d t } | j | j d | j d | j | f } t | _ | j t
|
d | j d | d t } | j | j } | j | j d d t d
|
g | j t | j t j ~ | j d S( Ni R t localhosti R; R RP R s hello worldg @( R i ( R t urandomR R R[ RT R R RU R> R R R R. R] R R± t ExceptionRG R Rb R ( R R; R& R` t manager2R« ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_remoteh s
|
$
|
|
"( s manager( R" R# R3 R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR [ s t _TestManagerRestartc B s e Z e d Z d Z RS( c C sB t d | d | d t } | j | j } | j d d S( NR R; R s hello world( R R R R RG ( RJ R R; R& R« ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s
|
|
c C sï t j d } t d d
|
d | d t } | j } | j } | j j | j | j d | j
|
d | j | f } t | _ | j | j } | j | j d ~ | j t d | d | d t } | j | j d S( Ni R R i R; R RP R s hello world( s localhosti ( R R R R t
|
get_serverR t listenerR R[ RT R RU R> R R. R] R ( R R; R& t srvrt addrR` R« ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_rapid_restart s$
|
$
|
|
|
( R" R# R R R¢ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR
s t t _TestConnectionc B s+ e Z d Z e d Z d Z d Z d Z d Z e d Z e e
|
d Z e j e d d
|
Z e j e d e j e j d k d e j e d k d e j e e d d d Z e d Z e j e d e j e j d k d d Z RS( R% R' c C s8 x' t | j t D] } | j | q W| j d S( N( R t
|
recv_bytest SENTINELt
|
send_bytesR ( RJ t connt msg( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _echo° s c C s@ | j \ } } | j d | j d | f } t | _ | j d d d g } t d } | d } t j d t d } | j
|
d k r® | j t | j t n | j | j | d | j | j | | j | j | d | j | j | | j
|
d k rÓt j d d
|
g d } t | d
|
g d t | } | j | j | d | j | j | t | | j | j t | | t j d d
|
g d } d
|
g d t | d
|
g d t | } | j | j | d | j | j | d | j t | | j | j t | | t t d d } | j | j | d y | j | }
|
Wn, t j k
|
r¾} | j | j | f qÓX| j d |
|
n t | j } | j | t | j | j d
|
| j | t! t | j | j t! | j d t" j# d | j | t! t | j | j d
|
| j | j d t d d } | j | | j | j | | j t$ | j% | j
|
d k r2| j | j& t | j | j' t | j( t) | j | j( t) | j n | j* d S( NRP R i g @s hello worldi
|
Rs i R% i i t i( s expected BufferTooShort, got %sg¹?t Xi i i i i (+ Ru RT Rª RU R> R[ R R R Ro R9 R. RY t filenoRh Rn Rx R§ R¥ RZ RA t recv_bytes_intot itemsizet bytearrayRf t BufferTooShortR RF R Rv RV R, R R³ R Rb R¦ R t readablet writableR± t EOFErrorR^ ( R R¨ R R` R R© t longmsgR t bufferR{ R0 R_ Rv t really_big_msg( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_connection¶ sn
|
|
!,
|
c C så | j d t \ } } | j | j d d | j | j d | j d k rá | j | j t | j | j t | j | j t | j | j t | j
|
t | j d | j
|
t | j | j
|
t | j n d S( NRt i R% i ( Ru RV R. Rn R Rx R9 R² RU R³ R± t IOErrorRv ( R t readert writer( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_duplex_false s c C s¡ | j \ } } | j d | j d | f } t | _ | j | j t d } | j | | j | j
|
| | j t | j | j d S( NRP R RM ( Ru RT Rª RU R> R[ R R R§ R. R¥ R¦ R^ ( R R¨ R R` R© ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_spawn_close s
|
|
|
c C s | j d k r d St d } | j \ } } | j | | j | j | | j | d | j | j | d | j | d d | j | j | d d ! | j | d | j | j t d | j | d d | j | j t d | j t | j | d | j t | j | d
|
d | j t | j | d d | j t | j | d | j t | j | d d d S( NR% t abcdefghijklmnopqrstuvwxyzi i i i R£ i i i i iÿÿÿÿi i ( R9 R Ru R§ R. R¥ R± R ( R R© R* R+ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_sendbytes$ s& c C sH y t j | Wn, t k
|
r? } | j t j k r9 t S n Xt Sd S( N( R t fstatt OSErrort errnot EBADFRV RU ( RJ t fdR_ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _is_fd_assignedD s c C s | rK xB t d d D]. } | j | s t j | j | q q Wn t j | } t rx t j | t j } n t j
|
| | t j | d S( Ni i ( Ro RÅ R t dup2R R t recv_handlet msvcrtt open_osfhandlet O_WRONLYt writeR ( RJ R¨ t datat create_dummy_fdsRs RÄ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _writefdO s s$ test needs multiprocessing.reductionc C sÿ | j d k r | j d n | j d t \ } } | j d | j d | d f } t | _ | j t t j
|
d A } | j } t r¤ t j | } n t j | | | j Wd QX| j t t j
|
d } | j | j d Wd QXd S( NR% s only makes sense with processesRt RP R R t wbt rb( R9 RÅ Ru RU RT RÎ R> R[ R~ R R R RÈ t get_osfhandleR t send_handleRI R^ R. R ( R R¨ R R` R RÄ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_fd_transfer[ s !
|
|
R s* test semantics don't make sense on Windowsi s) largest assignable fd number is too smallRÆ s test needs os.dup2()c C sI | j d k r | j d n | j d t \ } } | j d | j d | d t f } t | _ | j t t j
|
d } | j } x7 t d t D] } | j | s Pq q W| j d t j | | z t j | | | j Wd t j | XWd QX| j t t j
|
d
|
} | j | j d Wd QXd S( NR% s only makes sense with processesRt RP R R RÏ i s2 could not find an unassigned large file descriptorRÐ ( R9 RÅ Ru RU RT RÎ R> R[ R~ R R R Ro t MAXFDRÅ RF R RÆ R RÒ RI R R^ R. R ( R R¨ R R` R RÄ t newfd( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_large_fd_transferm s& $
|
|
c C s t j | j d d S( Nt ( R RË R ( R R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _send_data_without_fd s s doesn't make sense on Windowsc C s | j d k r | j d n | j d t \ } } | j d | j d | f } t | _ | j | j t t
|
j | | j d S( NR% s only makes sense with processesRt RP R ( R9 RÅ Ru RU RT RØ R> R[ R± RÒ R RÇ R^ ( R R¨ R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_missing_fd_transfer s
|
( s processess threads( R" R# R3 R Rª R¸ R¼ R½ R¿ RÅ RV RÎ R t
|
skipUnlesst HAS_REDUCTIONRÓ R& R t platformRÔ R¢ R RÖ RØ RÙ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR¤ ¬ s( L t _TestListenerClientc B s/ e Z d Z e d Z d Z d Z RS( R% R' c C s- | j j | } | j d | j d S( NRM ( t
|
connectiont ClientRn R ( RJ R R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRL ¤ s c C s x | j j D]
} | j j d | } | j d | j d | j f } t | _ | j | j } | j
|
| j d | j | j q Wd S( Nt familyRP R RM ( RÞ t familiest ListenerRT RL R RU R> R[ t acceptR. Rx R^ R ( R Rà t lR` R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_listener_clientª s !
|
|
c C s | j j } | j d | j d | j f } t | _ | j t j d | j
|
} | j | j d | j | j | j d S( NRP R i RM ( RÞ Râ RT RL R RU R> R[ R Rb Rã R. Rx R R^ ( R Rä R` R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_issue14725µ s !
|
|
|
( s processess threads( R" R# R3 R RL Rå Ræ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÝ s t _TestHeapc B s e Z d Z d Z d Z RS( R% c C s d } d } g } xz t | D]l } t t j d d d } t j j | } | j | t | | k r t j | } | | =q q Wt j j j
|
} g } d } | j j | j | j j x] | j j D]L }
|
xC |
|
D]; \ } } } | j | j j | | | | | d f qç WqÚ WxT | j D]I \ } } } | j | j j | | | | | d f | | | 7} q4W| j x{ t t | d D]c } | | d \ } } } | | d d \ } } } | j | | k rø| d k p| | k q¢Wd S( Ni i2 i i iè t freet occupiedi ( RÆ Rh t randomt lognormvariateRf t heapt BufferWrapperRw RA t randranget _heapt _lockRË R RÌ t _len_to_seqRü t _arenast indext _allocated_blockst sortRo R< ( R t
|
iterationst maxblockst blocksRs R R+ Rì Ra Ré t Lt arenaR[ R t narenat nstartt nstop( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_heap% s:
|
c C s¦ t j s) t j | j t j n t j } | j t j | t j d xJ t d D]< } t j j
|
d } t j j
|
d } | | _ | | _ qb Wd S( Ni
|
i i ( Rk t isenabledt enableR t disablet get_thresholdt set_thresholdRo Rf Rì Rí t buddy( R t
|
thresholdsRs R* R+ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_free_from_gcL s
|
( s processes( R" R# R3 Rþ R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRç ! s 't _Fooc B s e Z d e f d e f g Z RS( Rö R÷ ( R" R# R R t _fields_( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR f s t _TestSharedCTypesc B sD e Z d Z d Z e d Z e d Z d Z d Z RS( R% c C s t s | j d n d S( Ns% requires multiprocessing.sharedctypes( Rø RÅ ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRù p s c C s| | j d 9_ | j d 9_ | j d 9_ | j d 9_ | j d 9_ x* t t | D] } | | c d 9<q^ Wd S( Ni ( R/ Rö R÷ Ro RA ( RJ Rö R÷ R R t stringRs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _doublet s c C sn t d d d | } t t d d d | } t t d d d | } | j d t d d | } | j d
|
d d | } t d | _ | j d | j d | | | | | f } t | _
|
| j | j | j | j d | j | j d d | j | j d | j | j d x, t d D] } | j | | | d q/W| j | j t d d S( NRs i RÏ g ð?g @i i Ró i
|
Rõ i RM RP R i g @i g @t
|
hellohello( R R R R Ro R R/ RT R RU R> R[ R^ R. R) Rö R÷ ( R RÏ Rö R÷ R R R
|
R` Rs ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_sharedctypes~ s" *
|
|
c C s | j d t d S( NRÏ ( R RU ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_synchronize s c C sW t d d } t | } d | _ d | _ | j | j d | j | j d d S( Ni g @i ( R R Rö R÷ R. R) ( R R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_copy s ( s processes(
|
R" R# R3 Rù R R RV R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR l s
|
t _TestFinalizec B s& e Z d Z e d Z d Z RS( R% c C s d t f d Y} | } t j | | j d d ~ | } t j | | j d d } | | ~ | } t j | | j d d | } t j | | j d d d d | } t j | | j d d d d | } t j | | j d d d d | }
|
t j |
|
| j d d d d t j d | j d d d d t j d | j d d d d t j | j t j d d S( NR c B s e Z RS( ( R" R# ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR ¨ s R R* R+ Rõ t d10t exitpriorityi t d01i t d02t d03R_ iöÿÿÿt STOPiÿÿÿ( R* ( R+ ( Rõ ( s d10( s d01( s d02( s d03( R_ ( R ( t objectR t FinalizeRn R t _exit_functionR R t _exit( RJ R¨ R R* R+ t close_bRõ R R R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_finalize¦ s0
|
|
c C s | j \ } } | j d | j d | f } t | _ | j | j g t | j d D] } | ^ q` } | j | d d d d d d d
|
g d S( NRP R R R* R+ R R R R R_ (
|
Ru RT R RU R> R[ R^ R Rx R. ( R R¨ R R` RÁ Rz ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_finalizeÌ s
|
|
%( s processes( R" R# R3 R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR ¢ s &t _TestImportStarc B s e Z d Z d Z RS( R% c C s¼ d d d d d d d d g } t r4 | j d n t d k rP | j d
|
n xe | D]] } t | t j | } x= t | d d D]) } | j t | | d | | f q WqW Wd S( NRf s multiprocessing.connections multiprocessing.heaps multiprocessing.managerss multiprocessing.pools multiprocessing.processs multiprocessing.synchronizes multiprocessing.utils multiprocessing.reductions multiprocessing.sharedctypest __all__s %r does not have attribute %r( (
|
RÛ Rw R R t
|
__import__R t modulest getattrR< R¢ ( R R! RH t modt attr( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_importß s
|
( s processes( R" R# R3 R% ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR Û s t _TestLoggingc B s/ e Z d Z d Z e d Z d Z RS( R% c C sZ t j } | j t j | j | d k | j d | j d | j t d S( Ns this will not be printeds nor will this(
|
Rf t
|
get_loggert setLevelR t
|
SUBWARNINGR< R t debugt infot LOG_LEVEL( R t logger( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_enable_logging s c C s# t j } | j | j d S( N( Rf R' Rn t getEffectiveLevel( RJ R¨ R- ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_level s c C s d } d } t j } t j } | j } t j d t \ } } | j | | j d | j d | f } t
|
| _ | j | j | | j | j t j | j | | j d | j d | f } t
|
| _ | j | j | | j | j | | j d t d S( Ni i% Rt RP R t level( Rf R' t loggingt getLoggerR1 Ru RV R( RT R0 RU R> R[ R. Rx t NOTSETR, ( R t LEVEL1t LEVEL2R- t root_loggert
|
root_levelRº R» R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_level s&
|
|
( s processes( R" R# R3 R. R R0 R9 ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR& ü s t _TestPollEintrc B sA e Z d Z e d Z e j e e d d d Z RS( R% c C s$ t j d t j | t j d S( Ng à?( R Rb R t killt signalt SIGUSR1( RJ RI ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _killerC s R= s requires SIGUSR1c sÝ t g f d } t j } t j t j | } z | j d | j d | f } | j | j d t j d d } | j | j
|
| j d | j | j d | j
|
Wd t j t j | Xd S( Nc s t d <d S( Ni ( RU ( R ( t
|
got_signal( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt recordK s RP R i i ( i ( RV R RC R< R= RT R> R[ R Rb R^ R< R. RD ( R R@ RI t
|
oldhandlert killerR` ( ( R? sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_poll_eintrH s
|
|
|
( s processes(
|
R" R# R3 R R> R RÚ R¢ R< RC ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR: ? s t TestInvalidHandlec B s# e Z e j e d d Z RS( s skipped on Windowsc C s< t j d } | j t | j | j t t j d d S( NiÈM®iÿÿÿÿ( R t
|
ConnectionR± R¹ Rv ( R R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_invalid_handlesa s ( R" R# R R& t WIN32RF ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRD _ s c C s[ i } xN | D]F } t | | } t | t t k rI t | } n | | | <q W| S( N( R" RY t get_attributest staticmethod( t Sourcet namesRó RH RÁ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRH k s c C s´ i } t } | j } x | j D] } | j d r( | | } | | j k r¬ d | | d } d | t j | f d Y} | | | <| | _ | j | _ q¬ q( q( W| S( Nt _Testt Withi t Tempc B s e Z RS( ( R" R# ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRN ~ s ( t globalst
|
capitalizeR. t
|
startswithR3 R t TestCaseR" R# ( t MixinRY Rz t globt TypeRH t baset newnameRN ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt create_test_casest s
|
|
t ProcessesMixinc B s0 e Z d Z e j Z e j e e d RS( R% RR RÊ RÑ RØ RÚ Ræ RS R R Rÿ R R: RX Ru RÞ RÃ RR ( s Queues Locks RLocks Semaphores BoundedSemaphores Conditions Events Values Arrays RawValues RawArrays current_processs active_childrens Pipes
|
connections JoinableQueues Pool( R" R# R9 Rf RT t localst updateRH ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRY s RY R% t ManagerMixinc B sE e Z d Z e j Z e j e j j Z e
|
j e e d RS( R& RR RÊ RÑ RØ RÚ Ræ RS R R RZ R, R6 RÃ RR ( s Queues Locks RLocks Semaphores BoundedSemaphores Conditions Events Values Arrays lists dicts Namespaces JoinableQueues Pool( R" R# R9 Rf RT R t __new__t managerst SyncManagerR& RZ R[ RH ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR\ s R& t ThreadsMixinc B s6 e Z d Z e j j Z e j e e j d RS( R' RR RÊ RÑ RØ RÚ Ræ RS R R R: RX Ru RÞ R, RZ R6 RÃ RR ( s Queues Locks RLocks Semaphores BoundedSemaphores Conditions Events Values Arrays current_processs active_childrens Pipes
|
connections dicts lists Namespaces JoinableQueues Pool( R" R# R9 Rf t dummyRT RZ R[ RH ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR` ¥ s R' t OtherTestc B s e Z d Z d Z RS( c C s< d t f d Y} | j t j t j j | d d S( Nt _FakeConnectionc B s e Z d Z d Z RS( c S s d S( Ns something bogus( ( R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR¥ ¶ s c S s d S( N( ( R RÌ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR§ ¸ s ( R" R# R¥ R§ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRc µ s t abc( R R± Rf t AuthenticationErrorRÞ t deliver_challenge( R Rc ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt# test_deliver_challenge_auth_failure´ s c C s< d t f d Y} | j t j t j j | d d S( NRc c B s# e Z d Z d Z d Z RS( c S s d | _ d S( Ni ( t count( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR À s c S s? | j d 7_ | j d k r( t j j S| j d k r; d Sd S( Ni i s something bogusR£ ( Rh Rf RÞ t CHALLENGE( R R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR¥ Â s
|
c S s d S( N( ( R RÌ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR§ É s ( R" R# R R¥ R§ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRc ¿ s Rd ( R R± Rf Re RÞ t answer_challenge( R Rc ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt" test_answer_challenge_auth_failure¾ s ( R" R# Rg Rk ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRb ² s
|
c C s | j d 7_ d S( Ni ( t test( t ns( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt initializerÓ s t TestInitializersc B s, e Z d Z d Z d Z d Z RS( c C s1 t j | _ | j j | _ d | j _ d S( Ni ( Rf t Managert mgrR6 Rm Rl ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRù × s c C s | j j d S( N( Rq R ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt tearDownÜ s c C s_ t j j } | j t | j d | j t | j f | j | j j d | j
|
d S( Ni ( Rf R^ R_ R± t TypeErrorR[ Rn Rm R. Rl R ( R t m( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_manager_initializerß s
|
c C sb | j t t j d d t j d t | j f } | j | j | j | j j d d S( NRn i (
|
R± Rs Rf RR Rn Rm R R^ R. Rl ( R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_pool_initializeræ s
|
|
|
( R" R# Rù Rr Ru Rv ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRo Ö s c C s1 y | j d t } Wn t j k
|
r, n Xd S( Nt block( R] RV RR R» ( RK t item( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _ThisSubProcessò s c C sH t j } t j d t d | f } t | _ | j | j d S( NRP R ( Rf RR RT Ry RU R> R[ R^ ( RK R« t subProc( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR8 ø s
|
|
c C s | | S( N( ( Rö ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _afuncÿ s c C s= t j d d } | j t d d d d d d d g } d S( NR% i i i i i i i ( Rf RR RA R{ ( R< Rö ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt pool_in_process s t
|
_file_likec B s2 e Z d Z e d Z d Z d Z RS( c C s | | _ d | _ d S( N( t _delegateR t _pid( R t delegate( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s c C s7 t j } | | j k r0 | | _ g | _ n | j S( N( R RC R t _cache( R RI ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt cache s
|
c C s | j j | d S( N( R Rw ( R RÌ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRË s c C s) | j j d j | j g | _ d S( NR£ ( R~ RË R^ R R ( R ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt flush s ( R" R# R t propertyR RË R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR} s t TestStdinBadfiledescriptorc B s# e Z d Z d Z d Z RS( c C s? t j } t j d t d | f } | j | j d S( NRP R ( Rf RR RT R8 R[ R^ ( R R« R· ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_queue_in_process s
|
c C s* t j d t } | j | j d S( NRP ( Rf RT R| R[ R^ ( R R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_pool_in_process# s
|
c sc t } t | j d t j d f d } j | j d k s_ t d S( NR RP c s
|
j S( N( R ( ( t flike( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRV , s ( R R} RË Rf RT R t getvalueR ( R t sioR· ( ( R sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_flushing( s
|
( R" R# R R R ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR
s t TestTimeoutsc B s e Z e d Z d Z RS( c C sQ t j d | j d | j t j j | } | j d | j d S( Ni i{ iÈ ( R Rb Rn R Rf RÞ Rß ( RJ t childR R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt _test_timeout5 s
|
c C sú t j } zÙ t j d t j d t \ } } t j j d d } t j d | j d | | j
|
f } | j | j | j | j d | j | j } | j | j d | j | j | j d Wd t j | Xd S(
|
Ng¹?Rt Rà t AF_INETRP R i{ iÈ i
|
( t sockett getdefaulttimeoutt setdefaulttimeoutRf Ru RU RÞ Râ RT R R R[ R R. Rx Rã R^ ( R t old_timeoutt parentR Rä R` R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÜ > s"
|
|
|
|
|
( R" R# R R RÜ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR 4 s t TestNoForkBombc B s e Z d Z RS( c C sÎ t j j t j j t d } t rw t j j | \ } } } | j d | j
|
d | j d | j
|
d nS t j j | \ } } } | j d | j
|
d j | j d | j
|
d d S( Ns mp_fork_bomb.pyR£ t asciiRÒ t 123( R t pathR^ t dirnamet __file__RG Rl t script_helpert assert_python_failureR. t decodeR\ t assert_python_okR ( R RH t rct outt err( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_noforkbombW s ! ( R" R# R¢ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR V s t TestFlagsc B s/ e Z e d Z e d Z d Z RS( c C s | j t t j d S( N( Rn t tupleR t flags( RJ R¨ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt run_in_grandchildg s c C s d d l } t j d t \ } } t j d | j d | f } | j | j } | j | j | j t
|
t j | f } | j | GHd S( NiÿÿÿÿRt RP R ( t jsonRf Ru RV RT R¦ R[ Rx R^ R R¤ R R¥ t dumps( RJ R§ R
R} R` t grandchild_flagsR¥ ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt run_in_childk s
|
|
|
|
c C sx d d l } d d l } d d } | j t j d d d d | g } | j | j d \ } } | j | | d S( Niÿÿÿÿs1 from test.test_multiprocessing import TestFlags; s TestFlags.run_in_child()s -Es -Bs -Os -cR ( R§ t
|
subprocesst check_outputR t
|
executablet loadsR R. ( R R§ R« t progRÌ t child_flagsR© ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt
|
test_flagsx s ( R" R# R R¦ Rª R± ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR£ f s t TestForkAwareThreadLockc B s e Z e d Z d Z RS( c C sl | d k rH t j d | j d | d | f } | j | j n | j t t j | j d S( Ni RP R (
|
Rf RT R R[ R^ Rn RA R t _afterfork_registryR ( RJ R8 R¨ R` ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR s %
|
c C s
t j t \ } } t j } t t j } t j d | j d d | f } | j | j
|
} | j | j | | d S( NRP R i ( Rf Ru RV R t ForkAwareThreadLockRA R³ RT R R[ Rx R^ t assertLessEqual( R R
R} Rä t old_sizeR` t new_size( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRÐ s !
|
|
( R" R# R R RÐ ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyR² s
|
c sÜ t j j d rH y t j } WqH t k
|
rD t j d qH Xn t | d k rn d d l
|
m } n t j t j j t t j d t _ t j j d t _ t j j t j j t j j d t _ t t j d d t t j d d t t j d d t } t j j! t j" f d
|
| D } t# j$ d t% f d t% f d t& | | Wd QXt j j' t j j' t j j' t j j( t ` t ` t ` d S( Nt linuxs1 OSError raises on RLock creation, see issue 3111!iÿÿÿÿ( t run_unittesti t keyc S s | j S( N( R" ( t tc( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRV Â s c S s | j S( N( R" ( R» ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRV Ã s c S s | j S( N( R" ( R» ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyRV Ä s c 3 s | ] } | Vq d S( N( ( R+ R» ( t loadTestsFromTestCase( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pys <genexpr>É s s% .+__(get|set)slice__ has been removeds sys.exc_clear\(\) not supportedt quiet() R RÜ RQ Rf RÑ RÁ R R R R t test.test_supportR¹ R t get_temp_dirR' R( R, RR RY R< Ra R` R\ R& R R[ R- t testcases_processesRü t testcases_threadst testcases_managert testcases_othert defaultTestLoaderR¼ t TestSuiteR t check_py3k_warningst DeprecationWarningRU Rd R ( R RÏ t testcasest suite( ( R¼ sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt test_main« s:
|
J
|
c C s t t j d d j d S( Nt verbosityi ( RÊ R t TextTestRunnerR ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt mainÛ s t __main__( g=
|
×£p=ê?gffffffÖ?gffffffö?( g¹?g¹?g¹?( R s _h( R RR R R R Rk R< R R Rê R2 RÂ t test.script_helperRl R R t import_moduleR RÍ t multiprocessing.dummyRf t multiprocessing.connectiont multiprocessing.managerst multiprocessing.heapRZ R R RU RÛ t ImportErrorRV t multiprocessing.sharedctypesR R Rø RÈ R R R R) R, Rk R( R³ R´ Rµ R" t HAVE_GETVALUERÜ RG R RÔ t ctypesR
|
R R R R R R$ R5 R8 RT R R R¤ R§ R¨ RÉ RÕ RÝ Rì Rò R R' R: R; RW RX R] Rj Rs Rt Ru Rv Ry Rz R t registerR
R R R R R R R R¦ R¤ RÝ Rç R R R R R& R: RR RD RH RX RY RÀ RO R[ R\ RÂ R` RÁ Rb Rn Ro Ry R{ R| R} R
R R R£ R² RÃ RÊ RÍ R" ( ( ( sa /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_multiprocessing.pyt <module> s
|
|
|
|
|
|
¸ Ö6
-EZ< [ 2 $ *% ôE69!C
|
|
|
! " 0
|
