3 Z_]G @sedZddlZedZddlmZddlmZddlmZddlm Z ddl m Z ej Z d d d d d dgZ e eee eeddd ZejZdd ZejZdd Zdd ZejZdd ZejZdddZdS)osNsocket)greenio) get_errno) greenthread)hubs)slurp_propertiesfdopenreadwritewaitwaitpidopen)ignoreZsrckeyscOsZt|tstd|ytj|f||Stk rT}zt|jWYdd}~XnXdS)zrfdopen(fd [, mode='r' [, bufsize]]) -> file_object Return an open file object connected to a file descriptor.zfd should be int, not %rN) isinstanceint TypeErrorrZ GreenPipeIOErrorOSErrorargs)fdrkwer5/tmp/pip-build-yz_zf6az/eventlet/eventlet/green/os.pyr s   cCsxy t||Sttfk rB}zt|tjkr2WYdd}~Xn8tjk rx}zt|tjkrfdSWYdd}~XnXyt j |ddWqt j k rdSXqWdS)z;read(fd, buffersize) -> string Read a file descriptor.NT)r ) __original_read__rrrerrnoEAGAINrerrorEPIPEr trampolineZIOClosed)rnrrrrr #s cCsxy t||Sttfk rB}zt|tjkr2WYdd}~Xn4tjk rt}zt|tjkrdWYdd}~XnXt j |ddqWdS)zPwrite(fd, string) -> byteswritten Write a string to a file descriptor. NT)r ) __original_write__rrrrrrrr rr!)rstrrrrr 9s cCs tddS)zDwait() -> (pid, status) Wait for completion of a child process.r)r rrrrr JscCsX|tj@dkrt||S|tjB}x0t||\}}|rF|dkrF||fStjdq$WdS)zjwaitpid(...) waitpid(pid, options) -> (pid, status) Wait for completion of a given child process.rg{Gz?N)os_origWNOHANG__original_waitpid__rsleep)pidoptions new_optionsZrpidstatusrrrr Ss   cCsVt|jdkr"|||df\}}}}|dk rs0