Nexus File Manager
v2.0
🏠
Dashboard
⚡
System
🌐
›
lib64
›
python2.7
›
test
Quick:
⬆️ Parent
🌐 Root
🏠 Home
🌍 WWW
📁 Temp
⚙️ Etc
📤 Upload
📁 Create
⚡ WordPress Admin
🔄 Refresh
✏️ test_multiprocessing.pyc
← Back
� z fc @ 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 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 roe Z n Xy d d l m! Z! m" Z" e Z# Wn e k r�e Z# n Xy d d l$ Z$ Wn e k r�d Z$ n Xe& Z' e j( Z) d Z* e Z+ e+ rd� \ Z, Z- Z. n d� \ Z, Z- Z. e/ e d e � Z0 e j1 d k Z2 y e j3 d � Z4 Wn d Z4 n Xy d d l5 m6 Z6 m7 Z7 m8 Z8 Wn! e k r�e9 Z6 d Z7 Z8 n Xd � Z: d e9 f d � � YZ; d e9 f d � � YZ< d � Z= d e9 f d � � YZ> d e< f d � � YZ? d e j@ f d � � YZA d e< f d � � YZB d � ZC d! � ZD 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 d. e< f d/ � � YZK d0 e< f d1 � � YZL d2 d3 � ZM d4 � ZN d5 e9 f d6 � � YZO d7 eP f d8 � � YZQ d9 � ZR d: e< f d; � � YZS d< � ZT d= e< f d> � � YZU d? e< f d@ � � YZV dA e< f dB � � YZW d dC l mX ZX mY ZY mZ ZZ dD e9 f dE � � YZ[ dF � Z\ dG eY f dH � � YZ] dI eX f dJ � � YZ^ e^ j_ dK dL e[ �e^ j_ dM dL e[ dN d� �e^ j_ dQ dL e\ dR e] �dS e< f dT � � YZ` e j � Za dU � Zb dV eX f dW � � YZc ec j_ dX dL eb �dY eX f dZ � � YZd ed j_ dX � d[ Ze d\ e< f d] � � YZf d^ e< f d_ � � YZg e' d` � Zh da e< f db � � YZi dc e< f dd � � YZj de e< f df � � YZk dg e6 f dh � � YZl di e< f dj � � YZm dk e< f dl � � YZn dm e< f dn � � YZo do e< f dp � � YZp dq e< f dr � � YZq ds e jr f dt � � YZs du � Zt dv � Zu dw e9 f dx � � YZv eu ev dy dz �Zw ex � jy ew � d{ e9 f d| � � YZz eu ez dy d} �Z{ ex � jy e{ � d~ e9 f d � � YZ| eu e| dy d� �Z} ex � jy e} � d� e jr f d� � � YZ~ d� � Z d� e jr f d� � � YZ� d� � Z� d� � Z� d� � Z� d� � Z� d� e9 f d� � � YZ� d� e jr f d� � � YZ� d� e jr f d� � � YZ� d� e jr f d� � � YZ� d� e jr f d� � � YZ� d� e jr f d� � � YZ� d� e jr f d� � � YZ� e~ es e� e� e� e� e� e� e� g Z� d d� � Z� d� � Z� e� d� k r�e� � n d S(� i����N( t 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( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt check_enough_semaphoresc 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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __init__x s c O s; t j � } z | j | | � SWd t j � | | _ Xd S( N( t timeR R ( R t argst kwdst t( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __call__| s ( t __name__t __module__R R! ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR v 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( ( s1 /usr/lib64/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( ( s1 /usr/lib64/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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __reduce__� s ( R% R& R' ( R" R# t ALLOWED_TYPESR, R1 R2 t __reduce_ex__( ( ( s1 /usr/lib64/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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR5 � s t DummyCallablec B s e Z d � Z RS( c C s& t | t � s t � | j d � d S( Ni ( t isinstanceR8 t AssertionErrort put( R t qt c( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR! � s ( R" R# R! ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR8 � 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 d � Z RS( R% R' c C s� | j d k r+ | j d j | j � � n | j � } | j } | j | j � � | j | j � | j | t � | j t | � d k � | j | j t j � � | j | j d � d S( NR' s test not appropriate for {}i ( t TYPEt skipTestt formatt current_processt authkeyt assertTruet is_alivet daemont assertIsInstancet bytest lenR. t identR t getpidt exitcodeR ( R t currentRC ( ( s1 /usr/lib64/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' ( RB R; t nameR? RH RC t pid( t clsR< R R RM ( ( s1 /usr/lib64/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 kwargsRO R' i ( t Queuet Eventt ProcessRR t TrueRF RB R? R. RC RE t Falset assertNotInt active_childrenRD t typet listRL R t startt assertInt getRO RP t join( R R< t eR RW RO t pRM ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_process� s< c C s t j d � d S( Ni� ( R t sleep( RQ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_terminate� s c C s | j d k r+ | j d j | j � � n | 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' s test not appropriate for {}RV g ( R? R@ RA RZ Ri R[ RF Ra R. RE Rb R^ RL R t terminateR Rd R, R R\ R] ( R Rf Rd ( ( s1 /usr/lib64/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- RD R_ t int( R t cpus( ( s1 /usr/lib64/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( NRV R ( R. R_ R^ R` RZ R Rh t DELTAR] R[ RF Ra Rb Rd ( R Rf ( ( s1 /usr/lib64/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 RV R ( Rl Rs t sendRI t rangeRZ t _test_recursionRa Rd ( RQ t wconnt idRs t iRf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRv . 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 PipeR\ Rv R Rh Rq t pollt appendt recvR. ( R t rconnRw t resultt expected( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_recursion: s c C s# t | d � t _ t j | � d S( Nt w( t opent syst stderrt exit( RQ t reasont testfn( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_sys_exitN s c C sp | j d k r+ | j d j | j � � n t 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 QXqc Wxh t t d f D]W } | j d t j d | f � } t | _ | j � | j d � | j | j | � qWd S( NR' s test not appropriate for {}i i i s ignore thisRV R i t ri ( s ignore thisi ( R? R@ RA R t TESTFNt addCleanupt unlinkRZ R� R[ RF Ra Rd R. RL R� t readt rstript strR\ R� R� ( R R� R� t codeRf t f( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_sys_exitS s$ (! , c C s� t � } t j | � } | j � } | j d | d | | f � } ~ | j � | j � | j | � d � | j | j � d � d S( NRV R i ( R8 t weakreft refRX RZ Ra Rd t assertIsR R. Rc ( R R= t wrR< Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_lose_target_refl s ( R% R' ( R" R# R3 RN t classmethodRR Rg Ri Rk Rp Rr Rv R� R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR> � 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( Rl RZ R R{ t child_connt parent_conn( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR ~ 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� R~ R Rt t upper( R t s( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt run� s c C s5 t | � t k s t � | j j | � | j j � S( N( R_ R� R: R� Rt R~ ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt submit� s c C s. | j j d � | j j � | j j � d S( N( R� Rt R R� R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt stop� s ( R" R# R R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� | 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( NRS t HELLOt worldt WORLD( R� R[ RF Ra R. R� R� Rd ( R t uppercaser( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_subclassing� s ( R% ( R" R# R3 R� ( ( ( s1 /usr/lib64/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( R< ( ( s1 /usr/lib64/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� ( R< t maxsize( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt queue_full� s t _TestQueuec B s� e Z e d � � Z d � Z e d � � Z d � Z e d � � Z d � Z d � Z e d � � Z d � Z d � Z d � Z RS( c C s9 | j � x t d � D] } | j � q W| j � d S( Ni ( t waitRu Rc t set( RQ t queuet child_can_startt parent_can_continueRy ( ( s1 /usr/lib64/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� RV R i i i i i i i t timeout( RX RY RZ R� R[ RF Ra R. R� R� R\ R; R t put_nowaitR Rh Rq R t assertRaisest FullR, R t TIMEOUT1t TIMEOUT2t TIMEOUT3R� R� Rd ( R t MAXSIZER� R� R� t procR; R� ( ( s1 /usr/lib64/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� R; R� ( RQ R� R� R� ( ( s1 /usr/lib64/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( NRV R i i R� i i i i ( RX RY RZ R� R[ RF Ra R. R� R� R� R Rh Rq R\ Rc R t get_nowaitR R� t EmptyR, R R� R� R� Rd ( R R� R� R� R� Rc R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_get� sB c C s+ x$ t d d � D] } | j | � q Wd S( Ni i ( Ru R; ( RQ R� Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_fork2 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 RV R i ( RX Ru R; R Rh Rq RZ R� R[ RF Ra R. Rc R� R� R\ Rd ( R R� Ry Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_fork: s c C s� | j � } y | j | j � d � Wn t k rF | j d � n X| j d � | j | j � d � | j d � | j | j � d � | j � | j | j � d � | j � | j | j � d � d S( Ni s qsize method not implementedi i i ( RX R. R� R- R@ R; Rc ( R R< ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_qsizeU s c C s8 x1 t | j d � D] } t j t � | j � q Wd S( N( R� Rc R R Rh Rq t task_done( RQ R< t obj( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_task_doned 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 RV R i ( i i ( t JoinableQueueR� t version_infoR� R@ t xrangeRZ R� R[ RF Ra R; Rd R ( R R� Ry t workersRf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_task_donej s 4 c C s� t j � �� d } t | d d � � } | j d � Wd QXt j t j � � �7 y t | � Wn! t j k r� | j d � n XWd QXWd QXd S( Nt imported_by_an_imported_modules .pyR� s� if 1: import multiprocessing q = multiprocessing.Queue() q.put('knock knock') q.get(timeout=3) q.close() s? Probable regression on import lock contention; see Issue #22853( R t temp_cwdR� t writet DirsOnSysPathR t getcwdt __import__RX R� t fail( R t module_nameR� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_no_import_lock_contention� s c C s� | j d k r+ | j d j | j � � n d t f d � � Y} t j j � �G | j � } | j | � � | j t � | j | j d d � � Wd QXd S( NR% s test not appropriate for {}t NotSerializablec B s e Z d � Z RS( c S s t � d S( N( R ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR2 � s ( R" R# R2 ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s R� g �?( R? R@ RA t objectt testR t captured_stderrRX R; R[ RD Rc ( R R� R< ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt" test_queue_feeder_donot_stop_onexc� s ( R" R# R� R� R� R� R� R� R� R� R� R� R� R� ( ( ( s1 /usr/lib64/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 acquireR[ R\ t releaseR R� R t threadingt ThreadError( R t lock( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_lock� 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� R[ R� R R� R: t RuntimeError( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_rlock� s c C s | j � � Wd QXd S( N( R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_lock_context� s ( R" R# R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � 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� R[ R\ R� R ( R t sem( ( s1 /usr/lib64/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� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_semaphore� s c C s | j d � } | j | � d S( Ni ( t BoundedSemaphoreR� ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_bounded_semaphore� s c C s& | j d k r+ | j d j | j � � n | 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% s test not appropriate for {}i g R� ( R? R@ RA R� R R� R. R\ R, R R R� R[ R� R� ( R R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_timeout� s ( R" R# R� R� R� R� ( ( ( s1 /usr/lib64/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� ( RQ t condt sleepingt wokenR� ( ( s1 /usr/lib64/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 ( R? t _sleeping_countR5 t _woken_countR. t _wait_semaphoreR- ( R R� t sleepers( ( s1 /usr/lib64/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 RV R i i ( t ConditionR� RZ R� R[ RF Ra R� t ThreadR� R Rh Rq R1 R5 t notifyR� R� Rd ( R R� R� R� Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_notify s2 $ $ c C sr | 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 � xP t d � D]B } y t | � d k r'Pn Wn t k r<Pn Xt j t � qW| j d t | � | j | � d S( Ni i RV R i i ( R� R� Ru RZ R� R� R[ RF Ra R� R� R� R� R1 R5 R� R Rh Rq t notify_allR� R- ( R R� R� R� Ry Rf R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_notify_all8 sR $ $ 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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� y s N( R" R# R� R R� R� R R R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s + At _TestEventc B s e Z e d � � Z d � Z RS( c C s t j t � | j � d S( N( R Rh R� R� ( RQ t event( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_event� 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 RV R ( RY R R� R. t is_setR\ R, R R� R� R[ t clearRZ R RF Ra ( R R R� Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_event� s$ ( R" R# R� R R ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � 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% Ry i� i�^ t dg @g �t hi���i� R= t xt yc C s t s | j d � n d S( Ns% requires multiprocessing.sharedctypes( t HAS_SHAREDCTYPESR@ ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt setUp� s c C s4 x- t | | j � D] \ } } | d | _ q Wd S( Ni ( t zipt codes_valuesR/ ( RQ t valuest svt cv( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRR � 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 RV R i ( R t RawValueR R R. R/ RZ RR R[ RF Ra Rd ( R t rawR� R/ t _R R R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_value� s 1. c C s | j d t � d S( NR ( R R[ ( R ( ( s1 /usr/lib64/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( NRy i R� t get_lockt get_objt navalue( R R R R R� R. R\ t assertFalseR� R� R R ( R t val1t lock1t obj1t val2t lock2t obj2R� t val3t lock3t obj3t arr4t arr5( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_getobj_getlock� s$ ( R% ( Ry i� i�^ ( R g @g �( R i���i� ( R" R# R3 t latinR R R� RR R\ R R R) ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � 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 ( Ru RI ( RQ t seqRy ( ( s1 /usr/lib64/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? Ry i i i i i i RV R ( t RawArrayt ArrayR. RI R` t arrayR� RZ R[ RF Ra Rd ( R R R, t arrRf ( ( s1 /usr/lib64/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 Ry i ( Ru R. R. RI R` ( R t sizeR R0 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_array_from_size s c C s | j d t � d S( NR ( R1 R[ ( R ( ( s1 /usr/lib64/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( NRy l i ( R. R. RI R- ( R R0 t raw_arr( ( s1 /usr/lib64/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( NRy i R� R R t notalock( R. Ru R R R R� R. R\ R R� R� R R- ( R t arr1R R t arr2R" R# R� t arr3R% R& R' R( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_getobj_getlock_obj1 s& ( R% N( R" R# R3 R� R� R t skipIfR R R\ R1 R3 R4 R6 R; ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR+ � s !!!t _TestContainersc B s; e Z d Z d � 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 RS ( R` Ru R. t extendR} ( R R* R+ R Re R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_listS s( /> I c C s� | j t d � � } t | � } | j t | � t d � � | j t | � g � t | � } d | d <| j t | � d � d S( Ni id i ( R` Ru R� R. t next( R R* t it( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_list_iterr s 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 .0Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>� s ( t dictRu RC R. R t sortedt keysR t items( R R t indicesRy ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_dict| s & 5c C s� | j � } t d d � } x | D] } t | � | | <q" Wt | � } | j t | � | � | j t | � g � t | � } | j � | j t t | � d S( NiA iF ( RE Ru RC R� R. R` R R� R� R@ ( R R RI Ry RA ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_dict_iter� s c 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')RO t job( RL RM ( t NamespaceRO RO t _hiddenR. R� RD R� ( R t n( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_namespace� s ( R& ( R" R# R3 R? RB RJ RK RS ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR= O s g c C s t j | � | | S( N( R Rh ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt sqr� s c C s | S( N( ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt identity� s t CountedObjectc B s e Z d Z d � Z d � Z RS( i c C s | j d 7_ t j | � S( Ni ( t n_instancesR� t __new__( RQ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRX � s c C s t | � j d 8_ d S( Ni ( R_ RW ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __del__� s ( R" R# RW RX RY ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRV � s t SayWhenErrorc B s e Z RS( ( R" R# ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRZ � s c c s; x4 t | � D]& } | | k r. t d � � n | Vq Wd S( Ns Somebody said when( Ru RZ ( t totalt whenRy ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt exception_throwing_generator� s t _TestPoolc B s� e Z d � Z d � Z d � Z d � 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. RT ( R t papply( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_apply� 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. RT Ru ( R t pmap( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_map� s . c C sx | j d k r+ | j d j | j � � n d t f d � � Y} | j t � �" | j j t | � g d � Wd QXd S( NR' s test not appropriate for {}t Ac B s e Z d � Z RS( c S s t d � � d S( Ns cannot pickle( R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR2 � s ( R" R# R2 ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRg � s i ( R? R@ RA R� R� R� R_ Rd RT ( R Rg ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_map_unplicklable� s c C sQ y) | j j t g d d �j d t � Wn! t j k rL | j d � n Xd S( NRc i R� s2 pool.map_async with chunksize stalled on null list( R_ t map_asyncRT Rc R� Rl t TimeoutErrorR� ( R ( ( s1 /usr/lib64/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_asyncRT R� R Rc R. R, R ( R R0 Rc ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_async� 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_ Rl RT R� R Rc R� Rl Rj R, R ( R R0 Rc ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_async_timeout� 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� Rc id ( R_ t imapRT Ru R. R` Rd R@ R� t StopIteration( R RA Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_imap� s % ! c C s^ | j d k r+ | j d j | j � � n | j j t t d d � d � } x. t d � D] } | j t | � | | � qY W| j t | j � | j j t t d d � d � } x. t d � D] } | j t | � | | � q� W| j t | j � | j j t t d d � d � } x. t d � D] } | j t | � | | � q#W| j t | j � d S( NR& s test not appropriate for {}i i i i i i i i ( R? R@ RA R_ Ro RT R] Ru R. R@ R� RZ ( R RA Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt# test_imap_handle_iterable_exception� 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( Nid i� Rc ( R_ t imap_unorderedRT Ru R. RF Rd ( R RA ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_imap_unordered s %!c C sG | j d k r+ | j d j | j � � n | j j t t d d � d � } t t t d � � } | j t � �E x= t d � D]/ } t | � } | j | | � | j | � q~ WWd QX| j j t t d d � d � } t t t d � � } | j t � �E x= t d � D]/ } t | � } | j | | � | j | � q WWd QXd S( NR& s test not appropriate for {}i i i i i i ( R? R@ RA R_ Rs RT R] Rd Ru R� RZ R@ Rb t remove( R RA t expected_valuesRy R/ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt- test_imap_unordered_handle_iterable_exception 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 Rl t PoolR. RI t _poolR� Rd ( R Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_make_pool% s c C s} | j d � } | j t j g t d � D] } d ^ q( d d �} | j � t | j � } | � | j | j d k � d S( Ni i' g�������?Rc i g�������?( Rx Ri R Rh Ru Rj R Rd RD R ( R Rf Ry R� Rd ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRk . 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 ( Rx R. Rd RT R` Ro Rs Ri Rc R� Rd ( R Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_empty_iterable8 s """ c C s� t d � t d � D� � } t d � | D� � } | j j t | � ~ t j t � | j t d � | D� � d h � | j t j d � d S( Nc s s | ] } t � Vq d S( N( RV ( RD Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>G s i c s s | ] } t j | � Vq d S( N( R� R� ( RD t o( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>H s c s s | ] } | � Vq d S( N( ( RD R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>M s i ( R` Ru R_ Rd RU R Rh Rq R. R� R RV RW ( R t objst refs( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_release_task_refsD s #( R" R# Rb Rf Rh Rk Rm Rn Rq Rr Rt Rw Rz Rk R{ R ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR^ � s c C s d � S( Nc S s d S( Ni* ( ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt <lambda>T t ( ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt unpickleable_resultS 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.poolR� Rl Rx Ru Rl R� R� Rc R� Rd ( R R� Rf t iterationR0 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_unpickleable_resultY s ( R% ( R" R# R3 R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� V 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( RE ( RD R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>y s i ( Rl Rx R. RI Ry RP Ru R} Rl RT t enumerateRc t _repopulate_poolt allR Rh Rq R] R t assertNotEqualRF R� Rd ( R Rf R� t origworkerpidst resultsRy t jR0 t countdownt finalworkerpids( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_pool_worker_lifetimeh 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�?( Rl Rx Ru R} Rl RT R� Rd R� R. Rc ( R Rf R� Ry R� R0 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt% test_pool_worker_lifetime_early_close� s # ( R% ( R" R# R3 R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� e 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 ( Rl R^ t gct collectR& t _number_of_objectst _debug_infoR. ( R t EXPECTED_NUMBERR~ t debug_info( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_number_of_objects� s ( R& ( R" R# R3 R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � 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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c C s t � d S( N( R ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt g� s c C s d S( Ns _h()( ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _h� s ( R" R# R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c c s$ x t d � D] } | | Vq Wd S( Ni ( R� ( Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt baz� s t IteratorProxyc B s) e Z d Z d � Z d � Z d � Z RS( R@ t __next__c C s | S( N( ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __iter__� s c C s | j d � S( NR@ ( t _callmethod( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR@ � s c C s | j d � S( NR� ( R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s ( R@ R� ( R" R# t _exposed_R� R@ R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s t MyManagerc B s e Z RS( ( R" R# ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s t Foot callablet Bart exposedR� R� R� 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� R� R� s f()s _h()i ( R� R� R� ( R� R� R� ( R� Ra R� R� R� R� R. R� R� R R� R� R� R� R` Ru t shutdown( R R& t foot barR� RO t foo_methodst bar_methodsRy ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_mymanager� s& ((3( R& ( R" R# R3 R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c C s t S( N( t _queue( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt get_queue� s t QueueManagerc B s e Z d Z RS( s$ manager class used by server process( R" R# t __doc__( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s R� t QueueManager2c B s e Z d Z RS( s@ manager class which specifies the same interface as QueueManager( R" R# R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s t xmlrpclibt _TestRemoteManagerc B st e Z d Z d d e d g Z e Z e j rZ e j d � Z e j e � e j e � n e d � � Z d � Z RS( R& s hello worldg @s= \u043f\u0440\u0438\u0432\u0456\u0442 \u0441\u0432\u0456\u0442c C sK t d | d | d t � } | j � | j � } | j t | j � � d S( Nt addressRC t serializer( R� t SERIALIZERt connectR� R; t tupleR ( RQ R� RC R& R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _putter s c C s� t j d � } t d t j j d f d | d t � } | j � | j d | j d | j | f � } t | _ | j � t d | j d | d t � } | j � | j � } | j | j � | j � | j t | j t j � ~ | j � d S( Ni R� i RC R� RV R ( R t urandomR� R� R t HOSTR� Ra RZ R� R� R[ RF R� R� R� R. Rc R� R� t ExceptionR; R Rh R� ( R RC R& Rf t manager2R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_remote s ! $ ( R& N( R" R# R3 R R[ R R� R t have_unicodet ut uvalueR} R� R� R� ( ( ( s1 /usr/lib64/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� RC R� s hello world( R� R� R� R� R; ( RQ R� RC R& R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� 6 s c C s� t j d � } t d t j j d f d | d t � } | j � } | j } | j j � | j � | j d | j d | j | f � } | j � | j � | j � } | j | j � d � ~ | j � t d | d | d t � } | j � | j � d S( Ni R� i RC R� RV R s hello world( R R� R� R� R R� R� t get_serverR� t listenerR� Ra RZ R� Rd R� R. Rc R� ( R RC R& t srvrt addrRf R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_rapid_restart> s$ ! $ ( R" R# R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� 4 s R� 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� ( RQ t connt msg( ( s1 /usr/lib64/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( NRV R i g @s hello worldi Ry i R% i i t i( s expected BufferTooShort, got %sg�������?t Xi i i i i (+ R{ RZ R� R[ RF Ra R R* R/ Ru R? R. R_ t filenoRn Rt R~ R� R� R` RI t recv_bytes_intot itemsizet bytearrayRl t BufferTooShortR R� R R| R\ R, R R� R Rh R� R� t readablet writableR� t EOFErrorRd ( R R� R� Rf R, R� t longmsgR0 t bufferR� R0 Re R| t really_big_msg( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_connectionf 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( NRz i R% i ( R{ R\ R. Rt R R~ R? R� R[ R� R� t IOErrorR| ( R t readert writer( ( s1 /usr/lib64/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( NRV R RS ( R{ RZ R� R[ RF Ra R� R* R� R. R� R� Rd ( R R� R� Rf R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_spawn_close� s c C s� | j d k r+ | j d j | j � � n t 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% s test not appropriate for {}t abcdefghijklmnopqrstuvwxyzi i i i R� i i i i i����i i ( R? R@ RA R* R{ R� R. R� R� R ( R R� R* R+ ( ( s1 /usr/lib64/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 EBADFR\ R[ ( RQ t fdRe ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _is_fd_assigned� 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 ( Ru R� R t dup2R� R t recv_handlet msvcrtt open_osfhandlet O_WRONLYR� R� ( RQ R� t datat create_dummy_fdsRy R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _writefd� 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 � | j t j 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 processesRz RV R R� t wbt rb( R? R@ R{ R[ RZ R� RF Ra R� R R� R� R� R� R� t get_osfhandleR t send_handleRP Rd R. R� ( R R� R� Rf R� R� ( ( s1 /usr/lib64/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 s_ | j d k r | j d � n | j d t � \ } } | j d | j d | d t f � } t | _ | j � | j t j 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 processesRz RV R R� R� i s2 could not find an unassigned large file descriptorR� ( R? R@ R{ R[ RZ R� RF Ra R� R R� R� R� R� Ru t MAXFDR� R� R R� R R� RP R� Rd R. R� ( R R� R� Rf R� R� t newfd( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_large_fd_transfer s( $ c C s t j | j � d � d S( Ns ( R R� R� ( R R� ( ( s1 /usr/lib64/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 processesRz RV R ( R? R@ R{ R[ RZ R RF Ra R� R� R R� Rd ( R R� R� Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_missing_fd_transferC s ( R% R' ( R" R# R3 R� R� R� R� R� R� R� R\ R� R t skipUnlesst HAS_REDUCTIONR� R< R� t platformR R� R R R R ( ( ( s1 /usr/lib64/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( NRS ( t connectiont ClientRt R� ( RQ R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRR V 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 familyRV R RS ( R t familiest ListenerRZ RR R� R[ RF Ra t acceptR. R~ Rd R� ( R R t lRf R� ( ( s1 /usr/lib64/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( NRV R i RS ( R R RZ RR R� R[ RF Ra R Rh R R. R~ R� Rd ( R R Rf R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_issue14725g s ! ( R% R' ( R" R# R3 R� RR R R ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR R 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� Rn t randomt lognormvariateRl t heapt BufferWrapperR} RI t randranget _heapt _lockR� R� R� t _len_to_seqR t _arenast indext _allocated_blockst sortRu RD ( R t iterationst maxblockst blocksRy R2 R+ R R� R t Lt arenaRa R� t narenat nstartt nstop( ( s1 /usr/lib64/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 ( R� t isenabledt enableR� t disablet get_thresholdt set_thresholdRu Rl R R t buddy( R t thresholdsRy R* R+ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_free_from_gc� s ( R% ( R" R# R3 R) R1 ( ( ( s1 /usr/lib64/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_( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR2 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 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR " 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 Ru RI ( RQ R R R� R0 t stringRy ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _double& 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( NRy i R� g �?g @i i R i R= i RS RV R i g @i g @t hellohello( R R R2 R. Ru R* R/ RZ R6 R[ RF Ra Rd R. R) R R ( R R� R R R� R0 R5 Rf Ry ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_sharedctypes0 s" * c C s | j d t � d S( NR� ( R8 R[ ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_synchronizeE s c C sW t d d � } t | � } d | _ d | _ | j | j d � | j | j d � d S( Ni g @i ( R2 R R R R. R) ( R R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_copyH s ( R% ( R" R# R3 R R� R6 R\ R8 R9 R: ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR4 s t _TestFinalizec B sA e Z d Z d � Z d � Z e d � � Z d � Z d � Z RS( R% c C s# t j j � | _ t j j � d S( N( R t _finalizer_registryR t registry_backupR ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR X s c C s' | j t j � t j j | j � d S( N( R R R< t updateR= ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt tearDown\ s 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# ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� b s R R* R+ R= t d10t exitpriorityi t d01i t d02t d03Re i����t STOPi����( R* ( R+ ( R= ( R@ ( RB ( RC ( RD ( Re ( RE ( R� R t FinalizeRt R t _exit_functionR� R t _exit( RQ R� R� R* R+ t close_bR= R@ RB RC RD ( ( s1 /usr/lib64/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( NRV R RE R* R+ R@ RD RC RB Re ( R{ RZ RJ R[ RF Ra Rd R� R~ R. ( R R� R� Rf R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_finalize� s %c s d � � d t f � f d � � Y� t � g � � � f d � } � � � f d � } t j � } t j � } z� t j d � t j d d d � t j d | � t j d | � g } t j | � � t j d � t � Wd QX� r� � d � n Wd t j | � t j | � t j � Xd S( Nc S s d S( N( ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt cb� s R� c s e Z � f d � Z RS( c s/ | | _ t j | � d t j d d � �d S( NRA i id ( R� R RF R t randint( R ( RL ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � s ( R" R# R ( ( RL ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c sY xR � sT t j t j � d � y t j � Wq t k rP } � j | � q Xq Wd S( Ng�������?( R Rh R R t _run_finalizersR� R} ( Re ( t exct finish( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt run_finalizers� s c sq i } xd � sl y- � f d � t d � D� | t j d � <Wq t k rh } � j | � | j � q Xq Wd S( Nc s h | ] } � � � q S( ( ( RD Ry ( R� ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <setcomp>� s i i ( Ru R t getrandbitsR� R} R ( R Re ( R� RO RP ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt make_finalizers� s - i i RV g @i ( R� R\ R� t getcheckintervalR� R- t setcheckintervalR. R� R� R t start_threadsR Rh R[ R� ( R RQ RS t old_intervalt old_thresholdR' ( ( R� RL RO RP s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_thread_safety� s* ( R% ( R" R# R3 R R? R� RJ RK RY ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR; T 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( NRl 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 R} R R R� R� t modulest getattrRD R� ( R R\ RO t modt attr( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_import� s ( R% ( R" R# R3 R` ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRZ � 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( Rl t get_loggert setLevelR t SUBWARNINGRD R t debugt infot LOG_LEVEL( R t logger( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_enable_logging� s c C s# t j � } | j | j � � d S( N( Rl Rb Rt t getEffectiveLevel( RQ R� Rh ( ( s1 /usr/lib64/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% Rz RV R t level( Rl Rb t loggingt getLoggerRl R{ R\ Rc RZ Rk R[ RF Ra R. R~ t NOTSETRg ( R t LEVEL1t LEVEL2Rh t root_loggert root_levelR� R� Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_level� s& ( R% ( R" R# R3 Ri R� Rk Rt ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRa � 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 Rh R t killt signalt SIGUSR1( RQ RP ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _killer2 s Rx 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 ( R[ ( R ( t got_signal( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt record: s RV R i i ( i ( R\ R RK Rw Rx RZ Ry Ra R Rh Rd RD R. RL ( R R{ RP t oldhandlert killerRf ( ( Rz s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_poll_eintr7 s ( R% ( R" R# R3 R� Ry R R R� Rw R~ ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRu . 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� R| ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_invalid_handlesP s ( R" R# R R< t WIN32R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR N s c C s[ i } xN | D]F } t | | � } t | � t t � k rI t | � } n | | | <q W| S( N( R] R_ t get_attributest staticmethod( t Sourcet namesR RO R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� Z 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# ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� m s ( t globalst capitalizeRG t startswithR3 R t TestCaseR" R# ( t MixinR_ R� t globt TypeRO t baset newnameR� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt create_test_casesc s t ProcessesMixinc B s0 e Z d Z e j Z e � j e e d � � RS( R% RX R� R� R� R� R� RY R R. R R- RB R^ R{ R R� Rx ( RX R� R� R� R� R� RY R R. R R- RB R^ R{ R R� Rx ( R" R# R? Rl RZ t localsR> R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� x s R_ 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& RX R� R� R� R� R� RY R R. R` RE RP R� Rx ( RX R� R� R� R� R� RY R R. R` RE RP R� Rx ( R" R# R? Rl RZ R� RX t managerst SyncManagerR& R� R> R� ( ( ( s1 /usr/lib64/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' RX R� R� R� R� R� RY R R. RB R^ R{ R RE R` RP R� Rx ( RX R� R� R� R� R� RY R R. RB R^ R{ R RE R` RP R� Rx ( R" R# R? Rl t dummyRZ R� R> R� ( ( ( s1 /usr/lib64/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 R2 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c S s d S( N( ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s ( R" R# R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s t abc( R� R� Rl t AuthenticationErrorR t deliver_challenge( R R� ( ( s1 /usr/lib64/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( NR� c B s# e Z d � Z d � Z d � Z RS( c S s d | _ d S( Ni ( t count( R ( ( s1 /usr/lib64/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� ( R� Rl R t CHALLENGE( R R2 ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c S s d S( N( ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s ( R" R# R R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s R� ( R� R� Rl R� R t answer_challenge( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt" test_answer_challenge_auth_failure� s ( R" R# R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c C s | j d 7_ d S( Ni ( R� ( t ns( ( s1 /usr/lib64/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 ( Rl t Managert mgrRP R� R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � s c C s | j j � d S( N( R� R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR? � s c C s_ t j j � } | j t | j d � | j t | j f � | j | j j d � | j � d S( Ni ( Rl R� R� R� t TypeErrorRa R� R� R. R� R� ( R t m( ( s1 /usr/lib64/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( NR� i ( R� R� Rl Rx R� R� R� Rd R. R� ( R Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_pool_initializer� s ( R" R# R R? R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s c C s1 y | j d t � } Wn t j k r, n Xd S( Nt block( Rc R\ RX R� ( R< t item( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _this_sub_process� s c C sH t j � } t j d t d | f � } t | _ | j � | j � d S( NRV R ( Rl RX RZ R� R[ RF Ra Rd ( R< R� t subProc( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_process� s c C s | | S( N( ( R ( ( s1 /usr/lib64/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 ( Rl Rx Rd R� ( R_ R ( ( s1 /usr/lib64/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( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � s c C s7 t j � } | | j k r0 | | _ g | _ n | j S( N( R RK R� t _cache( R RP ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt cache� s c C s | j j | � d S( N( R� R} ( R R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� s c C s) | j j d j | j � � g | _ d S( NR� ( R� R� Rd R� R� ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt flush s ( R" R# R t propertyR� R� R� ( ( ( s1 /usr/lib64/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( NRV R ( Rl RX RZ R� Ra Rd ( R R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_queue_in_process s c C s* t j d t � } | j � | j � d S( NRV ( Rl RZ R� Ra Rd ( R Rf ( ( s1 /usr/lib64/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� RV c s � j � S( N( R� ( ( t flike( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� R� ( R R� R� Rl RZ R� t getvalueR: ( R t sioR� ( ( R� s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_flushing s ( R" R# R� R� R� ( ( ( s1 /usr/lib64/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 Rh Rt R� Rl R R ( RQ t childR� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_timeout$ 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�������?Rz R t AF_INETRV R i{ i� i ( t sockett getdefaulttimeoutt setdefaulttimeoutRl R{ R[ R R RZ R� R� Ra R� R. R~ R Rd ( R t old_timeoutt parentR� R Rf R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� - s" ( R" R# R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� # s t TestNoForkBombc B s e Z d � Z RS( c C s� t j j t j j t � d � } t re t j j | � \ } } } | j | d � | j d | � nA t j j | � \ } } } | j | j � d � | j | d � d S( Ns mp_fork_bomb.pyR� R� t 123( R t pathRd t dirnamet __file__R� R� t script_helpert assert_python_failureR. Rb t assert_python_okR� ( R RO t rct outt err( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_noforkbombF s !( R" R# R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� E s t TestFlagsc B s8 e Z e d � � Z e d � � Z e j d � � Z RS( c C s | j t t j � � d S( N( Rt R� R� t flags( RQ R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt run_in_grandchildV 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����Rz RV R ( t jsonRl R{ R\ RZ R� Ra R~ Rd R� R� R� R� t dumps( RQ R� R� R� Rf t grandchild_flagsR� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt run_in_childZ 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 -ct ascii( R� t subprocesst check_outputR� t executablet loadst decodeR. ( R R� R� t progR� t child_flagsR� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_flagsg s ( R" R# R� R� R� R t requires_unicodeR� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� U 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 RV R ( Rl RZ R� Ra Rd Rt RI R t _afterfork_registryR� ( RQ RR R� Rf ( ( s1 /usr/lib64/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( NRV R i ( Rl R{ R\ R t ForkAwareThreadLockRI R� RZ R� Ra R~ Rd t assertLessEqual( R R� R� R t old_sizeRf t new_size( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s ! ( R" R# R� R� R� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� v s t TestIgnoreEINTRc B s� e Z e e j e j � Z e d � � Z e j e e d � d � d � � Z e d � � Z e j e e d � d � d � � Z RS( c C sZ d � } t j t j | � | j d � | j � } | j | � | j d | j � d S( Nc S s d S( N( ( t signumt frame( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt handler� s t readyR ( Rw Rx Rt R~ R� t CONN_MAX_SIZE( RQ R� R� R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_ignore� s Rx s requires SIGUSR1c C s# t j � \ } } z� t j d | j d | f � } t | _ | j � | j � | j | j � d � t j d � t j | j t j � t j d � | j d � | j | j � d � t j d � t j | j t j � | j | j � d | j � t j d � | j � Wd | j � Xd S( NRV R R� g�������?i� R ( Rl R{ RZ R� R[ RF Ra R� R. R~ R Rh R Rv RP Rw Rx Rt R� R� Rd ( R R� R� Rf ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_ignore� s& c C sX d � } t j t j | � t j j � } | j | j � | j � } | j d � d S( Nc S s d S( N( ( R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � s t welcome( Rw Rx Rl R R Rt R� R ( RQ R� R� R R* ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_ignore_listener� s c C s� t j � \ } } z� t j d | j d | f � } t | _ | j � | j � | j � } t j d � t j | j t j � t j d � t j j | � } | j | j � d � | j � Wd | j � Xd S( NRV R g�������?R� ( Rl R{ RZ R� R[ RF Ra R� R~ R Rh R Rv RP Rw Rx R R R. Rd ( R R� R� Rf R� t client( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_ignore_listener� s ( R" R# t maxR t PIPE_MAX_SIZEt SOCK_MAX_SIZER� R� R� R R R� Rw R� R� R� ( ( ( s1 /usr/lib64/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( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � R� c S s | j S( N( R" ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � R� c S s | j S( N( R" ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR� � R� c 3 s | ] } � | � Vq d S( N( ( RD R ( t loadTestsFromTestCase( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr> s s% .+__(get|set)slice__ has been removeds sys.exc_clear\(\) not supportedt quiet() R� R R� Rl R� R� R R R R t test.supportR R t get_temp_dirRb Rc Rg Rx R� R_ R� R� R� R& R Ra RF t testcases_processesR t testcases_threadst testcases_managert testcases_othert defaultTestLoaderR t TestSuiteR t check_py3k_warningst DeprecationWarningR[ Rj R� ( R� R� t testcasest suite( ( R s1 /usr/lib64/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� ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt main s t __main__( g= ףp=�?gffffff�?gffffff�?( g�������?g�������?g�������?( R� R� (� R RX R R� R R� Rw R/ R� R Rm R� R� t test.script_helperR� R R t import_moduleR R� t multiprocessing.dummyRl t multiprocessing.connectiont multiprocessing.managerst multiprocessing.heapR� R R R[ R t ImportErrorR\ t multiprocessing.sharedctypesR R R R� R R� R* Rd Rg Rq R( R� R� R� R] t HAVE_GETVALUER R� R R t ctypesR R R R� R R R$ R5 R8 R> RZ R� R� R� R� R� R� R� R� R R R+ R= RT RU RV R RZ R] R^ R� R� R� R� R� R� R� R� R� R� R� t registerR� R� R� R� R� R� R� R� R� R� R R R2 R4 R; RZ Ra Ru R� R R� R� R� R R� R> R� R R� R R� R� R� R� R� R� R� R� R� R� R� R� R� R� R R R R" ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt <module> s$ � �6�-EZS � 2 $ 4& ��E6v!C ! "! G 0
💻
System Info
Current path
/lib64/python2.7/test
Contents
10 folders, 1437 files
Disk free
100.01 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /lib64/python2.7/test
⚡ Nexus File Manager • 1447 items