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.pyo
← 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 | j d � d S( Ni ( t 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 currentRA ( ( 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' ( R@ R9 t nameR= RF RA t pid( t clsR: R R RK ( ( 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 kwargsRM R' i ( t Queuet Eventt ProcessRP t TrueRD R@ R= R. RA RC t Falset assertNotInt active_childrenRB t typet listRJ R t startt assertInt getRM RN t join( R R: t eR RU RM t pRK ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_process� s< c C s t j d � d S( Ni� ( R t sleep( RO ( ( 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 {}RT g ( R= R> R? RX Rg RY RD R_ R. RC R` R\ RJ R t terminateR Rb R, R RZ R[ ( R Rd Rb ( ( 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- RB 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( NRT R ( R. R] R\ R^ RX R Rf t DELTAR[ RY RD R_ R` Rb ( R Rd ( ( 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 RT R ( Rj Rq t sendRG t rangeRX t _test_recursionR_ Rb ( RO t wconnt idRq t iRd ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRt . 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 PipeRZ Rt R Rf Ro t pollt appendt recvR. ( R t rconnRu 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( RO 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 thisRT R i t ri ( s ignore thisi ( R= R> R? R t TESTFNt addCleanupt unlinkRX R� RY RD R_ Rb R. RJ R� t readt rstript strRZ R� R� ( R R� R� t codeRd 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( NRT R i ( R8 t weakreft refRV RX R_ Rb t assertIsR R. Ra ( R R; t wrR: Rd ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_lose_target_refl s ( R% R' ( R" R# R3 RL t classmethodRP Re Rg Ri Rn Rp Rt 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( Rj RX R Ry 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 Rr t upper( R t s( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt run� s c C s | j j | � | j j � S( N( R� Rr 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� Rr 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( NRQ t HELLOt worldt WORLD( R� RY RD R_ R. R� R� Rb ( 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 waitRs Ra t set( RO t queuet child_can_startt parent_can_continueRw ( ( 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� RT R i i i i i i i t timeout( RV RW RX R� RY RD R_ R. R� R� RZ R9 R t put_nowaitR Rf Ro R t assertRaisest FullR, R t TIMEOUT1t TIMEOUT2t TIMEOUT3R� R� Rb ( R t MAXSIZER� R� R� t procR9 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� R9 R� ( RO 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( NRT R i i R� i i i i ( RV RW RX R� RY RD R_ R. R� R� R� R Rf Ro RZ Ra R t get_nowaitR R� t EmptyR, R R� R� R� Rb ( R R� R� R� R� Ra 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 ( Rs R9 ( RO R� Rw ( ( 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 RT R i ( RV Rs R9 R Rf Ro RX R� RY RD R_ R. Ra R� R� RZ Rb ( R R� Rw Rd ( ( 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 ( RV R. R� R- R> R9 Ra ( 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� Ra R R Rf Ro t task_done( RO 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 RT R i ( i i ( t JoinableQueueR� t version_infoR� R> t xrangeRX R� RY RD R_ R9 Rb R ( R R� Rw t workersRd ( ( 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__RV 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> R? t objectt testR t captured_stderrRV R9 RY RB Ra ( 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 acquireRY RZ 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� RY R� R R� t AssertionErrort 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� RY RZ 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> R? R� R R� R. RZ R, R R R� RY 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� ( RO 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 RT R i i ( t ConditionR� RX R� RY RD R_ R� t ThreadR� R Rf Ro R1 R5 t notifyR� R� Rb ( R R� R� R� Rd ( ( 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 RT R i i ( R� R� Rs RX R� R� RY RD R_ R� R� R� R� R1 R5 R� R Rf Ro t notify_allR� R- ( R R� R� R� Rw Rd 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 Rf R� R� ( RO 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 RT R ( RW R R� R. t is_setRZ R, R R� R� RY t clearRX R RD R_ ( R R R� Rd ( ( 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% Rw 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/ ( RO t valuest svt cv( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRP � 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 RT R i ( R t RawValueR R R. R/ RX RP RY RD R_ Rb ( 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 RY ( 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( NRw i R� t get_lockt get_objt navalue( R R R R R� R. RZ 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% ( Rw i� i�^ ( R g @g �( R i���i� ( R" R# R3 t latinR R R� RP RZ 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 ( Rs RG ( RO t seqRw ( ( 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? Rw i i i i i i RT R ( t RawArrayt ArrayR. RG R^ t arrayR� RX RY RD R_ Rb ( R R R+ t arrRd ( ( 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 Rw i ( Rs R- R. RG R^ ( R t sizeR R/ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_array_from_size s c C s | j d t � d S( NR ( R0 RY ( 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( NRw l i ( R- R. RG R, ( R R/ 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( NRw i R� R R t notalock( R- Rs R R R R� R. RZ 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 RZ R0 R2 R3 R5 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 RQ ( R^ Rs R. t extendR{ ( R R* R+ R Rc 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^ Rs 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 .0Rw ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>� s ( t dictRs RB R. R t sortedt keysR t items( R R t indicesRw ( ( 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 ( RD Rs RB R� R. R^ R R� R� R? ( R R RH Rw R@ ( ( 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')RM t job( RK RL ( t NamespaceRM RN t _hiddenR. R� RB R� ( R t n( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_namespace� s ( R& ( R" R# R3 R> RA RI RJ RR ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR< O s g c C s t j | � | | S( N( R Rf ( 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__( RO ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRW � s c C s t | � j d 8_ d S( Ni ( R] RV ( R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt __del__� s ( R" R# RV RW RX ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRU � s t SayWhenErrorc B s e Z RS( ( R" R# ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRY � s c c s; x4 t | � D]& } | | k r. t d � � n | Vq Wd S( Ns Somebody said when( Rs RY ( t totalt whenRw ( ( 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. RS ( 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. RS Rs ( 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.pyRf � s i ( R= R> R? R� R� R� R^ Rc RS ( R Rf ( ( 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( NRb i R� s2 pool.map_async with chunksize stalled on null list( R^ t map_asyncRS Ra R� Rj 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_asyncRS R� R Ra R. R, R ( R R0 Ra ( ( 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^ Rk RS R� R Ra R� Rj Ri R, R ( R R0 Ra ( ( 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� Rb id ( R^ t imapRS Rs R. R^ Rc R? R� t StopIteration( R R@ Rw ( ( 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> R? R^ Rn RS R\ Rs R. R? R� RY ( R R@ Rw ( ( 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� Rb ( R^ t imap_unorderedRS Rs R. RE Rc ( R R@ ( ( 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> R? R^ Rr RS R\ Rc Rs R� RY R? R` t remove( R R@ t expected_valuesRw 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 Rj t PoolR. RG t _poolR� Rb ( R Rd ( ( 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�������?Rb i g�������?( Rw Rh R Rf Rs Rh R Rb RB R ( R Rd Rw R~ Rb ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRi . 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 ( Rw R. Rc RS R^ Rn Rr Rh Ra R� Rb ( R Rd ( ( 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( RU ( RC Rw ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>G s i c s s | ] } t j | � Vq d S( N( R� R� ( RC t o( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>H s c s s | ] } | � Vq d S( N( ( RC R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>M s i ( R^ Rs R^ Rc RT R Rf Ro R. R� R RU RV ( R t objst refs( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_release_task_refsD s #( R" R# Ra Re Rg Rj Rl Rm Rp Rq Rs Rv Ry Ri Rz 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� Rj Rw Rs Rk R� R� Ra R� Rb ( R R� Rd 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( RC ( RC R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <genexpr>y s i ( Rj Rw R. RG Rx RN Rs R{ Rk RS t enumerateRa t _repopulate_poolt allR Rf Ro R[ R t assertNotEqualRE R� Rb ( R Rd R� t origworkerpidst resultsRw 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�?( Rj Rw Rs R{ Rk RS R� Rb R� R. Ra ( R Rd R� Rw 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 ( Rj 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� ( Rw ( ( 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� R_ R� R� R� R� R. R� R� R R� R� R� R� R^ Rs t shutdown( R R& t foot barR� RM t foo_methodst bar_methodsRw ( ( 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 addressRA t serializer( R� t SERIALIZERt connectR� R9 t tupleR ( RO R� RA 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 RA R� RT R ( R t urandomR� R� R t HOSTR� R_ RX R� R� RY RD R� R� R� R. Ra R~ R� t ExceptionR9 R Rf R� ( R RA R& Rd t manager2R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_remote s ! $ ( R& N( R" R# R3 R RY 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� RA R� s hello world( R� R� R� R� R9 ( RO R� RA 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 RA R� RT R s hello world( R R� R� R� R R� R� t get_serverR� t listenerR� R_ RX R� Rb R� R. Ra R� ( R RA R& t srvrt addrRd 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� ( RO 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( NRT R i g @s hello worldi Rw i R% i i t i( s expected BufferTooShort, got %sg�������?t Xi i i i i (+ Ry RX R� RY RD R_ R R) R. Rs R= R. R] t filenoRl Rr R| R� R� R^ RG t recv_bytes_intot itemsizet bytearrayRj t BufferTooShortR R� R Rz RZ R, R R� R Rf R� R� t readablet writableR� t EOFErrorRb ( R R� R� Rd R+ R� t longmsgR/ t bufferR R0 Rc Rz 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( NRx i R% i ( Ry RZ R. Rr R R| R= R� RY R� R� t IOErrorRz ( 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( NRT R RQ ( Ry RX R� RY RD R_ R� R) R� R. R� R� Rb ( R R� R� Rd 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> R? R) Ry 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 EBADFRZ RY ( RO t fdRc ( ( 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 ( Rs R� R t dup2R� R t recv_handlet msvcrtt open_osfhandlet O_WRONLYR� R� ( RO R� t datat create_dummy_fdsRw 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 processesRx RT R R� t wbt rb( R= R> Ry RY RX R� RD R_ R� R R� R� R� R� R� t get_osfhandleR t send_handleRN Rb R. R� ( R R� R� Rd 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 processesRx RT R R� R� i s2 could not find an unassigned large file descriptorR� ( R= R> Ry RY RX R� RD R_ R� R R� R� R� R� Rs t MAXFDR� R� R R� R R� RN R� Rb R. R� ( R R� R� Rd 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 processesRx RT R ( R= R> Ry RY RX R RD R_ R� R� R R� Rb ( R R� R� Rd ( ( 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� RZ 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( NRQ ( t connectiont ClientRr R� ( RO R� R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRP 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 familyRT R RQ ( R t familiest ListenerRX RP R� RY RD R_ t acceptR. R| Rb R� ( R R t lRd 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( NRT R i RQ ( R R RX RP R� RY RD R_ R Rf R R. R| R� Rb ( R R Rd R� ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_issue14725g s ! ( R% R' ( R" R# R3 R� RP 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� Rl t randomt lognormvariateRj t heapt BufferWrapperR{ RG t randranget _heapt _lockR� R� R� t _len_to_seqR t _arenast indext _allocated_blockst sortRs RB ( R t iterationst maxblockst blocksRw R1 R+ R R� R t Lt arenaR_ 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_thresholdRs Rj R R t buddy( R t thresholdsRw R* R+ ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_free_from_gc� s ( R% ( R" R# R3 R( R0 ( ( ( 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.pyR1 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 Rs RG ( RO R R R� R/ t stringRw ( ( 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( NRw i R� g �?g @i i R i R; i RQ RT R i g @i g @t hellohello( R R R1 R- Rs R) R/ RX R5 RY RD R_ Rb R. R) R R ( R R� R R R� R/ R4 Rd Rw ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_sharedctypes0 s" * c C s | j d t � d S( NR� ( R7 RY ( 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 ( R1 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� R5 RZ R7 R8 R9 ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR3 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 d03Rc i����t STOPi����( R* ( R+ ( R; ( R? ( RA ( RB ( RC ( Rc ( RD ( R� R t FinalizeRr R t _exit_functionR� R t _exit( RO R� R� R* R+ t close_bR; R? RA RB RC ( ( 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( NRT R RD R* R+ R? RC RB RA Rc ( Ry RX RI RY RD R_ Rb R� R| R. ( R R� R� Rd 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( NR@ i id ( R� R RE R t randint( R ( RK ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR � s ( R" R# R ( ( RK ( 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 Rf R R t _run_finalizersR� R{ ( Rc ( 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( ( ( RC Rw ( R� ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pys <setcomp>� s i i ( Rs R t getrandbitsR� R{ R ( R Rc ( R� RN RO ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt make_finalizers� s - i i RT g @i ( R� RZ R� t getcheckintervalR� R, t setcheckintervalR- R� R� R t start_threadsR Rf RY R� ( R RP RR t old_intervalt old_thresholdR' ( ( R� RK RN RO s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_thread_safety� s* ( R% ( R" R# R3 R R> R� RI RJ RX ( ( ( 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( NRj 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 getattrRB R� ( R R[ RM 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.pyRY � 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( Rj t get_loggert setLevelR t SUBWARNINGRB 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( Rj Ra Rr t getEffectiveLevel( RO R� Rg ( ( 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% Rx RT R t level( Rj Ra t loggingt getLoggerRk Ry RZ Rb RX Rj RY RD R_ R. R| t NOTSETRf ( R t LEVEL1t LEVEL2Rg t root_loggert root_levelR� R� Rd ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_level� s& ( R% ( R" R# R3 Rh R� Rj Rs ( ( ( s1 /usr/lib64/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 Rf R t killt signalt SIGUSR1( RO RN ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _killer2 s Rw 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 ( RY ( R ( t got_signal( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt record: s RT R i i ( i ( RZ R RI Rv Rw RX Rx R_ R Rf Rb RB R. RJ ( R Rz RN t oldhandlert killerRd ( ( Ry s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_poll_eintr7 s ( R% ( R" R# R3 R� Rx R R R� Rv R} ( ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyRt . 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� Rz ( 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 RM 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 capitalizeRF t startswithR3 R t TestCaseR" R# ( t MixinR] R~ t globt TypeRM 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% RV R� R� R� R� R� RW R R- R R, R@ R\ Ry R R� Rw ( RV R� R� R� R� R� RW R R- R R, R@ R\ Ry R R� Rw ( R" R# R= Rj RX 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& RV R� R� R� R� R� RW R R- R^ RD RO R� Rw ( RV R� R� R� R� R� RW R R- R^ RD RO R� Rw ( R" R# R= Rj RX R� RW 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' RV R� R� R� R� R� RW R R- R@ R\ Ry R RD R^ RO R� Rw ( RV R� R� R� R� R� RW R R- R@ R\ Ry R RD R^ RO R� Rw ( R" R# R= Rj t dummyRX 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 R1 ( ( 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� Rj 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� Rj R t CHALLENGE( R R1 ( ( 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� Rj 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 ( Rj t Managert mgrRO 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 ( Rj R� R� R� t TypeErrorR_ 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� Rj Rw R� R� R� Rb R. R� ( R Rd ( ( 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( Ra RZ RV 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( NRT R ( Rj RV RX R� RY RD R_ Rb ( 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 ( Rj Rw Rc 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 RI R� t _cache( R RN ( ( 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� Rb 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( NRT R ( Rj RV RX R� R_ Rb ( 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( NRT ( Rj RX R� R_ Rb ( R Rd ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt test_pool_in_process s c sK t � } t | � � � j d � t j d � f d � � } � j � d S( NR� RT c s � j � S( N( R� ( ( t flike( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyR R� ( R R� R� Rj RX R� ( 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 Rf Rr R� Rj R R ( RO 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�������?Rx R t AF_INETRT R i{ i� i ( t sockett getdefaulttimeoutt setdefaulttimeoutRj Ry RY R R RX R� R� R_ R� R. R| R Rb ( R t old_timeoutt parentR� R Rd 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 pathRb t dirnamet __file__R� R� t script_helpert assert_python_failureR. R` t assert_python_okR� ( R RM 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( Rr R� R� t flags( RO 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����Rx RT R ( t jsonRj Ry RZ RX R� R_ R| Rb R� R� R� R� t dumps( RO R� R� R� Rd 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 RT R ( Rj RX R� R_ Rb Rr RG R t _afterfork_registryR� ( RO RQ R� Rd ( ( 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( NRT R i ( Rj Ry RZ R t ForkAwareThreadLockRG R� RX R� R_ R| Rb t assertLessEqual( R R� R� R t old_sizeRd 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 ( Rv Rw Rr R| R� t CONN_MAX_SIZE( RO R� R� R ( ( s1 /usr/lib64/python2.7/test/test_multiprocessing.pyt _test_ignore� s Rw 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( NRT R R� g�������?i� R ( Rj Ry RX R� RY RD R_ R� R. R| R Rf R Ru RN Rv Rw Rr R� R� Rb ( R R� R� Rd ( ( 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( Rv Rw Rj R R Rr R� R ( RO 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( NRT R g�������?R� ( Rj Ry RX R� RY RD R_ R� R| R Rf R Ru RN Rv Rw R R R. Rb ( R R� R� Rd 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� Rv 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( ( RC 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� Rj R� R� R R R R t test.supportR� R t get_temp_dirRa Rb Rf Rw R� R^ R� R� R� R& R R_ RE t testcases_processesR t testcases_threadst testcases_managert testcases_othert defaultTestLoaderR t TestSuiteR t check_py3k_warningst DeprecationWarningRY Rh 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 RV R R� R R� Rv R. R� R Rl R� R� t test.script_helperR� R R t import_moduleR R� t multiprocessing.dummyRj t multiprocessing.connectiont multiprocessing.managerst multiprocessing.heapR� R R RY R t ImportErrorRZ t multiprocessing.sharedctypesR R R R� R R� R) Rc Rf Ro R( R� R� R� R\ t HAVE_GETVALUER R� R R� t ctypesR R R R� R R R$ R5 R8 R< RX R� R� R� R� R� R� R� R� R R R* R< RS RT RU R RY 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 R1 R3 R: RY R` Rt 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.05 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /lib64/python2.7/test
⚡ Nexus File Manager • 1447 items