o tPfJ@sbddlmZmZmZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZddlmZddlmZd Zeejd d ZGd d d e jZiddddddddddddddddddddddddd dd!d"d#dd$dd%d&d'dd(dd)Zgd*Zddd+d,d-d.d.d/d0d1d2d2d2d3 Zd4d5Zd6d7Zdfd8d9Zd:d;Z dZ"d?d@Z#dAdBZ$dCdDZ%hdEZ&hdFZ'dgdGdHZ(dhdIdJZ)GdKdLdLe*Z+dMdNZ,e -Z.dOdPZ/dQdRZ0GdSdTdTe1Z2dUdVZ3didXdYZ4dZd[Z5d\d]Z6d^d_Z7Gd`dadae*Z8Gdbdcdce8ej9Z:Gdddedee j;Zt Ynwzt|Wn t yRt Ynwz|WdSt yht YdSw)NTsetpgrp_enabledwin)rcancelpoll was_killedgetattrrdrmr\platformrKrurl traceback print_excrywaitrxrrrrs2             r> GEVENT_DEBUGr GEVENTSETUP_EMBEDGEVENTSETUP_EV_VERIFY>GEVENT_RESOLVERthreadGEVENTTEST_USE_RESOURCESallGEVENT_RESOLVER_NAMESERVERSz8.8.8.8cCsg}|ptj}||pit|D]\}}|ds q|tvr%q||ftvr,q| d||fqt |t j rB| |n| |d|S)NGEVENTz%s=%s )rhenvironcopyupdatesorteditemsrKIGNORED_GEVENT_ENV_KEYSIGNORED_GEVENT_ENV_ITEMSappend isinstancer string_typesextendjoin)commandenvsetenvresultkeyvaluerrrgetnames      rc Ks|dd}d}tjdsttdd}|dd}|ddp!i}t|||d}|dur1d|d<|rC|r9|ntj}|||sJtd|t |f||d |}||_ |du|_ d |_ |dur|t d d |t|fd } | |_d| _| | |_|S)NtimeoutDO_NOT_SETPGRPsetpgrprr)rr1z+ %s) preexec_fnrF threadingTimer)rT)rZrhrgetrrrrrar namerzr~r rrdaemonstart) rquietr_rrrrrrxtrrrrs2       rc@sLeZdZdZ     dddZeddZdd ZeZd d Z d d Z dS) RunResultz The results of running an external command. If the command was successful, this has a boolean value of True; otherwise, a boolean value of false. The integer value of this object is the command's exit code. Nrc Cs:||_||_||_||_||_||_||_||_| |_dSr) r run_kwargsrQoutputr#r run_count skipped_count run_duration) rrrrQrr#rrrrrrr__init__ s  zRunResult.__init__cCs |jSr)r splitlinesrrrr output_liness zRunResult.output_linescCs t|j Sr)boolrQrrrr__bool__!rzRunResult.__bool__cCs|jSr)rQrrrr__int__&szRunResult.__int__cCsd|j|j|j|j|jfS)NzLRunResult of: %r Code: %s kwargs: %r Output: ---- %s---- Error: ---- %s---- )rrQrrr#rrrr__repr__)s zRunResult.__repr__)NNNrrr) rrrrrpropertyrr __nonzero__rrrrrrrs    rcCsdd|vr.|dd}|dd}|dd}|dd}|dd}|dd}|d d}d|vS) NWarningzWarning -- reap_childrenNADAzWarning -- threading_cleanupz/DeprecationWarning: Using or importing the ABCsz UserWarning: libuv only supportsz&ImportWarning: Not importing directoryz*DeprecationWarning: 'U' mode is deprecatedz#DeprecationWarning: dns.hash module)replace)outrrr_should_show_warning_output?s       rcCsd}d}d}d}|rStd|}|r0|||}|d|}t||d|d}td|}|rStd|||}t||d|d}|||f}|d krbtd |}|||fS) Nz[took %.1fs%s]rIrzRan (\d+) tests intookrz \(skipped=(\d+)\)$r- r1)researchrendrintrX)rrstatusr-rrmrrrr_find_test_statusXs$      rc Ks|dt}|dt}| }|dd}|dd}|r3d|vr%d|vs)J|tj|d<tj|d<t|fd|i|}|j}z+t} | \} } t| } |j sX| d ur[d } n| } Wt ||j d uskJn t ||j d uswJwt| o| |v}| r| } t| tr| n| d d } | r|s|st| rd | dd} | } | d7} td|| t| | \}}}| rtd|| ||rdnddn|std||t||| |vrdn| | | |||| d S)zv Execute *command*, returning a `RunResult`. This blocks until *command* finishes or until it times out. buffer_outputrnestedFallowed_return_codesrstdoutr]NTIMEOUTzutf-8ignorez rYz z| %s %sz! %s [code %s] %sr#r2)rNz- %s %sr)rr#rrrr)rZ BUFFER_OUTPUTrbroSTDOUTrprrr rqr~r}rrrrrrstrdecoderrrstriprarr)rr_rrverboserrrxr time_startrrtdurationrfailedrrrrrrrunns`            rc@seZdZdZdS)NoSetupPyFoundzRaised by find_setup_py_aboveN)rrrrrrrrrsrcCsltjtj|}tjtj|ds4|tj|}}||kr)td|ftjtj|dr|S)zAReturn the directory containing setup.py somewhere above *a_file*zsetup.pyz#could not find my setup.py above %r)rhpathdirnameabspathexistsrr)a_filerootprevrrrfind_setup_py_abovesrTcCs|durzt|WStyYnw|dur+z ttj|jjWSty*Ynw|durBz ttj|jWStyAYnw|rHtdStdtf)Nz./dnezAfter checking %r)rrr\modulesr__file__locals)r a_module_namea_class climb_cwdrrrsearch_for_setup_pys*    rcCsFdtjdd}dtjdd}ttdr|d7}|d7}||fS)N%s.%s%s.%s.%srfpypy_version_infopypy)r\ version_inforg) directoryfull_directoryrrr_version_dir_componentss  rcCsttd}tj|dd}t\}}dtjdd}dtjdd}ttd r1|d 7}|d 7}tj||}tj||}||fS) z Return a sequence of directories that could contain stdlib tests for the running version of Python. The most specific tests are at the end of the sequence. No checks are performed on existence of the directories. )rsrc greentestrNrrrfrr) rrrhrrrr\rrg)setup_pyrrrrrrfind_stdlib_testss   rcCs>dtjvrdStjd}dd|tjjD}tjj|S)z Return the PYTHONPATH environment variable (if set) with each entry being an absolute path. If not set, returns None. PYTHONPATHNcSsg|]}tj|qSr)rhrr).0prrr sz'absolute_pythonpath..)rhrsplitrpathsepr)rrrrabsolute_pythonpaths  rc@s\eZdZdZgZdZdZdZdZddZ e ddZ e d d Z d d Z d dZddZdS) ExampleMixinz Something that uses the ``examples/`` directory from the root of the gevent distribution. The `cwd` property is set to the root of the gevent distribution. rfg?NcCsttt|dS)z(Return the directory containing setup.py)rr)rrrkrrrr find_setup_pyszExampleMixin.find_setup_pyc CsDz|}Wnty}ztd|fd}~wwtj|dS)N$Unable to locate file/dir to run: %sexamples)rrunittestSkipTestrhrr)rrerrrcwds zExampleMixin.cwdcCst}|r d|iSdS)a" Returns a dictionary of environment variables to set for the child in addition to (or replacing) the ones already in the environment. Since the child is run in `cwd`, relative paths in ``PYTHONPATH`` need to be converted to absolute paths. rN)r)rabs_pythonpathrrrrs zExampleMixin.setenvc Cst|ddr td||jt|ddrtd||jz|j}|j}Wnty6}ztd|fd}~ww|j p;i}|j }|rQd|vrM|d |n||d<|t j ddd|g|jfd |i|S) Nrz Invalid testserverrrz-Wrz-ur )rAssertionErrorrr exampler rrr start_kwargsrrr\ executable example_args)rmethr  server_dirr r_rrrr_start,s0    zExampleMixin._startcC |jtdSN)r)rrrrrr start_exampleFrzExampleMixin.start_examplecCrr)rrrrrr run_exampleIrzExampleMixin.run_example)rrrrr before_delay after_delayrrrrr rrrrrrrrrs    rc@s8eZdZdZddZddZddZdd Zd d ZdS) TestServerNcs"ddlm}|fdd}|S)Nr)contextmanagerc3sL}|_dVWddS1swYdSr)rrxbeforeafterrrrrrunning_serverTs  "z1TestServer.running_server..running_server) contextlibr)rrrrrrrQs zTestServer.running_servercCs6| |WddS1swYdSr)r_run_all_testsrrrrtest]s  "zTestServer.testcC:|jdur t|j||jd|j|jfdSNz%s died with code %s)rr assertIsNonerxr}rrrrrra    zTestServer.beforecCr#r$)rrr%rxr}rrrrrrir&zTestServer.aftercCsHd}tt|D]}|drt||}t|r|d}q|s"JdS)NF_testT)rdirrKrcallable)rranmethodfunctionrrrr!qs   zTestServer._run_all_tests) rrrrxrr"rrr!rrrrrMs  rc@seZdZddZddZdS)alarmcCs$tj|d|_||_|dS)NT)rThreadrrrr)rrrrrrs  zalarm.__init__cCs$t|jtjdtddS)Nz Timeout. )rrr\r]r^rh_exitrrrrrs  z alarm.runN)rrrrrrrrrr-|s r-)r)NN)F)NNNT)= __future__rrrrr\rhrrrrotimerrIrgevent._configrgevent._compatr gevent.monkeyr rrrrbr rTrJrMrSrVrXrar!rdruryrrrrrobjectrrLockr[rrrlrrrrrrrTestCaserr.r-rrrrs               @>   M/