!niHedZddlZedZddlmZddlmZddlm Z ddlm Z ddlm Z dd l m Z ejZgd Ze eeeee d Zej&Zd Zej*ZdZdZej0ZdZej4ZddZy)osNsocket)S_ISREG)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 Q/home/homepc/tiktok-worker/venv/lib/python3.12/site-packages/eventlet/green/os.pyr r s^ b# 2R788  1d1b11 qvvs9 AAAc~ tj|j}t|s t j |d t||S#tj $rYywxYw#t$rH}t|tjk(rYd}~yt|tjk7rYd}~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 . $R+ + ==    |u{{*|u||+,  s/A A*A'&A'* B;3B6B66B;cZ tj|j}t|s t j |d t||S#tj $rYywxYw#t$r6}t|tjtjfvrYd}~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 $/ %b"- - ==    |ELL%++#>>?  s)A A*A'&A'* B)3,B$$B)ctddS)zDwait() -> (pid, status) Wait for completion of a child process.r)rrrrUs 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?)r WNOHANG__original_waitpid__rsleep)pidoptions new_optionsrpidstatuss rrr_si  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)fileflagsmoder;rs rrrrse Dz//$)4$=!eT6  tUD @ tUD 1r Ir/)iN) __import__r r&rr!reventletreventlet.supportrrr eventlet.patcherr __all__ __patched__globalsdirr r r%r r+rrr2rr>r.r/rrKs T  H & - //D   I  L  LL.]], $ LLr/