ó ‹wÛjc@s÷ddlZddlZddlZddlZddlZddlmZddlZddlZddl m Z ej ej dkdƒdej fd„ƒYƒZdefd „ƒYZd efd „ƒYZd „Zed króeƒndS(iÿÿÿÿN(t run_unittest(tFileIOtposixstests requires a posix system.tTestFileIOSignalInterruptcBs_eZd„Zd„Zd„Zdded„Zd„ZdZd„Z d„Z d „Z RS( cCs d|_dS(N(tNonet_process(tself((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pytsetUpscCsJ|jrF|jjƒdkrFy|jjƒWqFtk rBqFXndS(N(RtpollRtkilltOSError(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyttearDown s  cCsdS(sReturns the infile = ... line of code for the reader process. subclasseses should override this to test different IO objects. s9import _io ;infile = _io.FileIO(sys.stdin.fileno(), "rb")((R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyt_generate_infile_setup_code'stcCs¦|jjƒdkrJtjdƒy|jjƒWqJtk rFqJXn|r||jjƒ\}}||7}||7}n|jd||j ƒ|j ƒfƒdS(s;A common way to cleanup and fail with useful debug output. Kills the process if it is still running, collects remaining output and fails the test with an error message including the output. Args: why: Text to go after "Error from IO process" in the message. stdout, stderr: standard output and error from the process so far to include in the error message. communicate: bool, when True we call communicate() on the process after killing it to gather additional output. gš™™™™™¹?s/Error from IO process %s: STDOUT: %sSTDERR: %s N( RRRttimetsleept terminateR t communicatetfailtdecode(RtwhytstdouttstderrRt stdout_endt stderr_end((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pytfail_with_process_info/s     c Cs¾|jƒ}tjtjddd|dd|ddgdtjdtjd tjƒ|_|jjjt d ƒƒ}|d kr|j d d |ƒn|jj j |ƒd }g}xz|s8t j |jjgddd ƒ\}}}|jjtjƒ|d7}|dkr¿|jjƒ|jdƒq¿q¿W|jjjƒ}|dkrm|j dd |ƒn|jjddƒ\} } |jjrº|j d|jj| | dtƒndS(snGeneric buffered read method test harness to validate EINTR behavior. Also validates that Python signal handlers are run during the read. Args: data_to_write: String to write to the child process for reading before sending it a signal, confirming the signal was handled, writing a final newline and closing the infile pipe. read_and_verify_code: Single "line" of code to read from a file object named 'infile' and validate the result. This will be executed as part of a python subprocess fed data_to_write. s-us-cs\import io, signal, sys ;signal.signal(signal.SIGINT, lambda s, f: sys.stderr.write("$\n")) ;s ;s"sys.stderr.write("Worm Sign!\n") ;sinfile.close()tstdinRRs Worm Sign! swhile awaiting a signigš™™™™™©?iiÈs,reader process failed to handle our signals.s$ swhile awaiting signaltinputs s exited rc=%dRN(((R t subprocesstPopentsyst executabletPIPERRtreadtlenRRtwritetselectt send_signaltsignaltSIGINTR RtreadlineRt returncodetFalse( Rt data_to_writetread_and_verify_codetinfile_setup_codet worm_signt signals_senttrlistt_t signal_lineRR((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyt _test_readingJs<       *        s­got = infile.{read_method_name}() ;expected = {expected!r} ;assert got == expected, ("{read_method_name} returned wrong data.\n""got data %r\nexpected %r" % (got, expected))c Cs/|jddd|jjddddƒƒdS( s1readline() must handle signals and not lose data.R+s hello, world!R,tread_method_nameR(texpectedshello, world! N(R3t_READING_CODE_TEMPLATEtformat(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyt test_readlinešs   c Cs5|jddd|jjdddddgƒƒd S( s2readlines() must handle signals and not lose data.R+s hello world!R,R4t readlinesR5shello sworld! N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyttest_readlines¢s   c CsZ|jddd|jjddddƒƒ|jddd|jjddddƒƒd S( s0readall() must handle signals and not lose data.R+s hello world!R,R4treadallR5s hello world! R!N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyt test_readallªs     ( t__name__t __module__RR R tTrueRR3R6R8R:R<(((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyRs     I  tTestBufferedIOSignalInterruptcBseZd„Zd„ZRS(cCsdS(s?Returns the infile = ... line of code to make a BufferedReader.seinfile = io.open(sys.stdin.fileno(), "rb") ;import _io ;assert isinstance(infile, _io.BufferedReader)((R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR ºsc Cs/|jddd|jjddddƒƒdS( s<BufferedReader.read() must handle signals and not lose data.R+s hello world!R,R4R!R5s hello world! N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR<¿s   (R=R>R R<(((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR@¹s tTestTextIOSignalInterruptcBs,eZd„Zd„Zd„Zd„ZRS(cCsdS(s>Returns the infile = ... line of code to make a TextIOWrapper.srinfile = io.open(sys.stdin.fileno(), "rt", newline=None) ;import _io ;assert isinstance(infile, _io.TextIOWrapper)((R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR Ésc Cs/|jddd|jjddddƒƒdS( s1readline() must handle signals and not lose data.R+s hello, world!R,R4R(R5shello, world! N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR8Îs   c Cs5|jddd|jjdddddgƒƒd S( s2readlines() must handle signals and not lose data.R+s hello world!R,R4R9R5shello sworld! N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR:Ös   c Cs/|jddd|jjddddƒƒdS( s-read() must handle signals and not lose data.R+s hello world!R,R4R!R5s hello world! N(R3R6R7(R((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyR<Þs   (R=R>R R8R:R<(((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyRAÈs   cCsQgtƒjƒD]-}t|tƒrt|tjƒr|^q}t|ŒdS(N(tglobalstvaluest isinstancettypet issubclasstunittesttTestCaseR(ttct test_cases((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyt test_mainçs-t__main__(tosR$R&RRttest.test_supportRRRGt_ioRt skipUnlesstnameRHRR@RARKR=(((sŠ/home/sim/yocto/scarthgap/build/tmp/work/x86_64-linux/python-native/2.7.18/recipe-sysroot-native/usr/lib/python2.7/test/test_file_eintr.pyts