Hi6edZddlZedZddlmZddlmZddlm Z ddlm Z ddlm Z dd l m Z ejZgd Ze eeeee d ZejZd ZejZdZdZejZdZejZddZdS)osNsocket)S_ISREG)greenio) get_errno) greenthread)hubs)slurp_properties)fdopenreadwritewaitwaitpidopen)ignoresrckeysct|tstd|z tj|g|Ri|S#t $r}t |jd}~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 V/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/eventlet/green/os.pyr r s| b#  92R7888 1d111b111 qvs> AAAc t|j}t|s. t j|dn#tj$rYdSwxYw t||S#t$rK}t|tj krYd}~dSt|tj krYd}~nd}~wwxYw)z;read(fd, buffersize) -> string Read a file descriptor.T)r N) os_origstatst_moderr trampolineIOClosed__original_read__rrerrnoEPIPEEAGAIN)rnr"rs rr r %s,,r""*w  .....=   rr  $R++ +   ||u{**rrrrr||u|++,++++ s/AAAA// C9B?B??Cc^ t|j}t|s. t j|dn#tj$rYdSwxYw t||S#t$r2}t|tj tj fvrYd}~nd}~wwxYw)zPwrite(fd, string) -> byteswritten Write a string to a file descriptor. T)r rN) r r!r"rr r#r$__original_write__rrr&r(r')rstr"rs rr r ?s ,,r""*w  $/////=   qq  %b"-- -   ||EL%+#>>>?>>>> s)AAAA// B+9(B&&B+c"tddS)zDwait() -> (pid, status) Wait for completion of a child process.r)rrrrUs 1a==r/c|tjzdkrt||S|tjz} t||\}}|r |dkr||fStjd4)zjwaitpid(...) waitpid(pid, options) -> (pid, status) Wait for completion of a given child process.rTg{Gz?)r WNOHANG__original_waitpid__rsleep)pidoptions new_optionsrpidstatuss rrr_sz  A%%#C111/  $/[AALD& $! V|#  d # # #  $r/ct|jdkr |||df\}}}}|t||||}nt|||}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)fileflagsmoder<rs rrrrsu Dzz///$)4$=!eT6  tUD @ @ @ tUD 1 1r Ir/)r9N) __import__r r&rr!reventletreventlet.supportrrr eventlet.patcherr __all__ __patched__globalsdirr r r%r r+rrr2rr?r.r/rrLso *T   H  &&&&&& ------ /DDD   GII  CLL    L.], $ $ $ Lr/