CNh <edZddlZedZddlmZddlmZddlmZddlm Z ddl m Z ejZ gd Z e eee ee d Zej"Zd Zej&Zd ZdZej,ZdZej0ZddZy)osNsocket)greenio) get_errno) greenthread)hubs)slurp_properties)fdopenreadwritewaitwaitpidopen)ignoresrckeysct|tstd|z tj|g|i|S#t $r}t |j d}~wwxYw)zrfdopen(fd [, mode='r' [, bufsize]]) -> file_object Return an open file object connected to a file descriptor.zfd should be int, not %rN) isinstanceint TypeErrorr GreenPipeOSErrorargs)fdrkwes 3/usr/lib/python3/dist-packages/eventlet/green/os.pyr r s^ b# 2R788  1d1b11 qvvs9 AAAc, t||S#t$rH}t|tjk(rYd}~yt|tj k7rYd}~nd}~wwxYw t j|dn#t j$rYywxYw)z;read(fd, buffersize) -> string Read a file descriptor.TN)r ) __original_read__rrerrnoEPIPEEAGAINr trampolineIOClosed)rnrs rr r $s  $R+ + |u{{*|u||+,    OOBT *}}   s+  A AAA $A<<BBc t||S#t$r6}t|tjtj fvrYd}~nd}~wwxYwt j|dg)zPwrite(fd, string) -> byteswritten Write a string to a file descriptor. TN)r )__original_write__rrr r"r!rr#)rstrs rr r 9s_  %b"- - |ELL%++#>>?  $' s  A,A  ActddS)zDwait() -> (pid, status) Wait for completion of a child process.r)rrr r Gs 1a=r+c|tjzdk7r t||S|tjz} t||\}}|r |dk\r||fStjd0)zjwaitpid(...) waitpid(pid, options) -> (pid, status) Wait for completion of a given child process.rg{Gz?)os_origWNOHANG__original_waitpid__rsleep)pidoptions new_optionsrpidstatuss rrrQsi  A%#C11/ /[ALD&! V|#   d # r+ct|jdk(r |||df\}}}}|t||||}n t|||}tj||S)zt Wrap os.open This behaves identically, but collaborates with the hub's notify_opened protocol. _NormalAccessorN)dir_fd)type__name____original_open__r notify_opened)fileflagsmoder8rs rrrdse Dz//$)4$=!eT6  tUD @ tUD 1r Ir+)iN) __import__r-r reventletreventlet.supportrrreventlet.patcherr __all__ __patched__globalsdirr r rr r'r rr/rr;r*r+rrHs T  H & - //D   I  L  LL$]] ( $ LLr+